storage

package

v0.0.0-...-5986324 Latest Latest Go to latest Published: Feb 25, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/altinity/clickhouse-operator

Documentation ¶

Index ¶

func ErrIsDataLoss(err error) bool
type ErrorDataPersistence
type PVC
- func NewStoragePVC(pvcKube interfaces.IKubePVC) *PVC
type Reconciler
- func NewStorageReconciler(task *common.Task, namer interfaces.INameManager, ...) *Reconciler
- func (w *Reconciler) ReconcilePVCs(ctx context.Context, host *api.Host, which api.WhichStatefulSet) (res ErrorDataPersistence)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ErrIsDataLoss ¶

func ErrIsDataLoss(err error) bool

Types ¶

type ErrorDataPersistence ¶

type ErrorDataPersistence error

ErrorDataPersistence specifies errors of the PVCs and PVs

var (
	ErrPVCWithLostPVDeleted ErrorDataPersistence = errors.New("pvc with lost pv deleted")
	ErrPVCIsLost            ErrorDataPersistence = errors.New("pvc is lost")
)

type PVC ¶

type PVC struct {
	interfaces.IKubePVC
	// contains filtered or unexported fields
}

func NewStoragePVC ¶

func NewStoragePVC(pvcKube interfaces.IKubePVC) *PVC

func (*PVC) DeletePVC ¶

func (c *PVC) DeletePVC(ctx context.Context, host *api.Host) error

deletePVC deletes PersistentVolumeClaim

func (*PVC) UpdateOrCreate ¶

func (c *PVC) UpdateOrCreate(ctx context.Context, pvc *core.PersistentVolumeClaim) (*core.PersistentVolumeClaim, error)

UpdateOrCreate

func (*PVC) WalkDiscoveredPVCs ¶

func (c *PVC) WalkDiscoveredPVCs(ctx context.Context, host *api.Host, f func(pvc *core.PersistentVolumeClaim))

type Reconciler ¶

type Reconciler struct {
	// contains filtered or unexported fields
}

func NewStorageReconciler ¶

func NewStorageReconciler(task *common.Task, namer interfaces.INameManager, pvc interfaces.IKubeStoragePVC) *Reconciler

func (*Reconciler) ReconcilePVCs ¶

func (w *Reconciler) ReconcilePVCs(ctx context.Context, host *api.Host, which api.WhichStatefulSet) (res ErrorDataPersistence)

ReconcilePVCs reconciles all PVCs of a host

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL