pvc

Documentation

Index

• func ReadSubVolumePathFromMeta(path string) (string, error)
• func ResolveSubVolumeName(pv *v1.PersistentVolume) (string, error)
• type Collection
  • func Collect(cfg *Configuration, options ...collector.ConfigManipulator) (*Collection, error)
  • func (v *Collection) Add(obj runtime.Object) error
  • func (v *Collection) All() map[Key]*Value
  • func (v *Collection) Delete(obj runtime.Object) error
  • func (v *Collection) Filter(filter func(key Key, value *Value) bool) map[Key]*Value
  • func (v *Collection) Modify(obj runtime.Object) error
• type Configuration
• type Key
• type Value

Functions

func ReadSubVolumePathFromMeta

func ReadSubVolumePathFromMeta(path string) (string, error)

func ResolveSubVolumeName

func ResolveSubVolumeName(pv *v1.PersistentVolume) (string, error)

Types

type Collection

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

func Collect

func Collect(cfg *Configuration, options ...collector.ConfigManipulator) (*Collection, error)

Collect PVC objects lazy

func (*Collection) Add

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

func (*Collection) All

func (v *Collection) All() map[Key]*Value

func (*Collection) Delete

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

func (*Collection) Filter

func (v *Collection) Filter(filter func(key Key, value *Value) bool) map[Key]*Value

func (*Collection) Modify

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

type Configuration

type Configuration struct {
	K8sConfig *config.KubernetesApiConfiguration
	CephFS    *config.CephFs
}

type Key

type Key struct {
	Key       string
	Namespace string
}

type Value

type Value struct {
	Error          error
	FullVolumePath string
	PV             *v1.PersistentVolume
	PVC            *v1.PersistentVolumeClaim
}