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) AdoptOrphanedPvcs(ctx context.Context, cls *appsv1alpha1.CollaSet) ([]*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) ReleasePvcsOwnerRef(cls *appsv1alpha1.CollaSet, pvcs []*corev1.PersistentVolumeClaim) ([]*corev1.PersistentVolumeClaim, error)
  • func (pc *RealPvcControl) SetPvcsOwnerRef(cls *appsv1alpha1.CollaSet, pvcs []*corev1.PersistentVolumeClaim) ([]*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)
	AdoptOrphanedPvcs(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
	SetPvcsOwnerRef(*appsv1alpha1.CollaSet, []*corev1.PersistentVolumeClaim) ([]*corev1.PersistentVolumeClaim, error)
	ReleasePvcsOwnerRef(*appsv1alpha1.CollaSet, []*corev1.PersistentVolumeClaim) ([]*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) AdoptOrphanedPvcs

func (pc *RealPvcControl) AdoptOrphanedPvcs(ctx context.Context, cls *appsv1alpha1.CollaSet) ([]*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) ReleasePvcsOwnerRef

func (pc *RealPvcControl) ReleasePvcsOwnerRef(cls *appsv1alpha1.CollaSet, pvcs []*corev1.PersistentVolumeClaim) ([]*corev1.PersistentVolumeClaim, error)

func (*RealPvcControl) SetPvcsOwnerRef

func (pc *RealPvcControl) SetPvcsOwnerRef(cls *appsv1alpha1.CollaSet, pvcs []*corev1.PersistentVolumeClaim) ([]*corev1.PersistentVolumeClaim, error)