pvccontrol

Documentation

Index

• func IsPodPvcTmpChanged(cls *appsv1alpha1.CollaSet, pod *corev1.Pod, ...) (bool, error)
• type Interface
  • func NewRealPvcControl(client client.Client, scheme *runtime.Scheme) Interface
• type RealPvcControl
  • func (pc *RealPvcControl) AdoptPvc(cls *appsv1alpha1.CollaSet, pvc *corev1.PersistentVolumeClaim) error
  • func (pc *RealPvcControl) CreatePodPvcs(ctx context.Context, cls *appsv1alpha1.CollaSet, pod *corev1.Pod, ...) error
  • func (pc *RealPvcControl) DeletePodPvcs(ctx context.Context, cls *appsv1alpha1.CollaSet, pod *corev1.Pod, ...) error
  • func (pc *RealPvcControl) DeletePodUnusedPvcs(ctx context.Context, cls *appsv1alpha1.CollaSet, pod *corev1.Pod, ...) error
  • func (pc *RealPvcControl) GetFilteredPvcs(ctx context.Context, cls *appsv1alpha1.CollaSet) ([]*corev1.PersistentVolumeClaim, error)
  • func (pc *RealPvcControl) OrphanPvc(cls *appsv1alpha1.CollaSet, pvc *corev1.PersistentVolumeClaim) error

Functions

func IsPodPvcTmpChanged

func IsPodPvcTmpChanged(cls *appsv1alpha1.CollaSet, pod *corev1.Pod, existingPvcs []*corev1.PersistentVolumeClaim) (bool, error)

Types

type Interface

type Interface interface {
	GetFilteredPvcs(context.Context, *appsv1alpha1.CollaSet) ([]*corev1.PersistentVolumeClaim, error)
	CreatePodPvcs(context.Context, *appsv1alpha1.CollaSet, *corev1.Pod, []*corev1.PersistentVolumeClaim) error
	DeletePodPvcs(context.Context, *appsv1alpha1.CollaSet, *corev1.Pod, []*corev1.PersistentVolumeClaim) error
	DeletePodUnusedPvcs(context.Context, *appsv1alpha1.CollaSet, *corev1.Pod, []*corev1.PersistentVolumeClaim) error
	OrphanPvc(*appsv1alpha1.CollaSet, *corev1.PersistentVolumeClaim) error
	AdoptPvc(*appsv1alpha1.CollaSet, *corev1.PersistentVolumeClaim) error
}

func NewRealPvcControl

func NewRealPvcControl(client client.Client, scheme *runtime.Scheme) Interface

type RealPvcControl

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

func (*RealPvcControl) AdoptPvc

func (pc *RealPvcControl) AdoptPvc(cls *appsv1alpha1.CollaSet, pvc *corev1.PersistentVolumeClaim) error

func (*RealPvcControl) CreatePodPvcs

func (pc *RealPvcControl) CreatePodPvcs(ctx context.Context, cls *appsv1alpha1.CollaSet, pod *corev1.Pod, existingPvcs []*corev1.PersistentVolumeClaim) error

func (*RealPvcControl) DeletePodPvcs

func (pc *RealPvcControl) DeletePodPvcs(ctx context.Context, cls *appsv1alpha1.CollaSet, pod *corev1.Pod, pvcs []*corev1.PersistentVolumeClaim) error

func (*RealPvcControl) DeletePodUnusedPvcs

func (pc *RealPvcControl) DeletePodUnusedPvcs(ctx context.Context, cls *appsv1alpha1.CollaSet, pod *corev1.Pod, existingPvcs []*corev1.PersistentVolumeClaim) error

func (*RealPvcControl) GetFilteredPvcs

func (pc *RealPvcControl) GetFilteredPvcs(ctx context.Context, cls *appsv1alpha1.CollaSet) ([]*corev1.PersistentVolumeClaim, error)

func (*RealPvcControl) OrphanPvc

func (pc *RealPvcControl) OrphanPvc(cls *appsv1alpha1.CollaSet, pvc *corev1.PersistentVolumeClaim) error