cephfs

Documentation

Index

• type PersistentVolumeClaims
  • func NewPersistentVolumeClaims(ctx context.Context, cephConfig *config.CephFs) (*PersistentVolumeClaims, error)
  • func (v *PersistentVolumeClaims) Add(obj runtime.Object) error
  • func (v *PersistentVolumeClaims) All() map[PvcKey]*PvcValue
  • func (v *PersistentVolumeClaims) Delete(obj runtime.Object) error
  • func (v *PersistentVolumeClaims) Filter(filter func(key PvcKey, value *PvcValue) bool) map[PvcKey]*PvcValue
  • func (v *PersistentVolumeClaims) Modify(obj runtime.Object) error
• type PvcKey
• type PvcValue

Types

type PersistentVolumeClaims

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

func NewPersistentVolumeClaims

func NewPersistentVolumeClaims(ctx context.Context, cephConfig *config.CephFs) (*PersistentVolumeClaims, error)

NewPersistentVolumeClaims creates a new continuously updated map of PersistentVolumeClaim objects ensure to provide a K8s API configuration in the given context given K8s API Client in the context is either reused or new client is created if none exists

func (*PersistentVolumeClaims) Add

func (v *PersistentVolumeClaims) Add(obj runtime.Object) error

func (*PersistentVolumeClaims) All

func (v *PersistentVolumeClaims) All() map[PvcKey]*PvcValue

All returns a new copy of the pvc map for safe iteration

func (*PersistentVolumeClaims) Delete

func (v *PersistentVolumeClaims) Delete(obj runtime.Object) error

func (*PersistentVolumeClaims) Filter

func (v *PersistentVolumeClaims) Filter(filter func(key PvcKey, value *PvcValue) bool) map[PvcKey]*PvcValue

Filter will return a filtered copy of the pvc map for save iteration

func (*PersistentVolumeClaims) Modify

func (v *PersistentVolumeClaims) Modify(obj runtime.Object) error

type PvcKey

type PvcKey struct {
	Key       string
	Namespace string
}

type PvcValue

type PvcValue struct {
	Error          error
	FullVolumePath string
	PVC            *coreV1.PersistentVolumeClaim

	// Note: PV can be nil, e.g for unbound PVCs
	PV *coreV1.PersistentVolume
}