cephfs

package
v2.3.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 9, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 (*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 added in v2.3.7

type PvcKey struct {
	Key       string
	Namespace string
}

type PvcValue added in v2.3.7

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

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

Jump to

Keyboard shortcuts

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