controllertools

package
v1.4.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PodDisruptionBudgetControlInterface 

type PodDisruptionBudgetControlInterface interface {
	PatchPodDisruptionBudget(ctx context.Context, namespace, name string, pt types.PatchType, data []byte, options metav1.PatchOptions) error
}

type PodDisruptionBudgetControllerRefManager 

type PodDisruptionBudgetControllerRefManager struct {
	kubecontroller.BaseControllerRefManager

	PodDisruptionBudgetControl PodDisruptionBudgetControlInterface
	// contains filtered or unexported fields
}

func NewPodDisruptionBudgetControllerRefManager 

func NewPodDisruptionBudgetControllerRefManager(
	ctx context.Context,
	controller metav1.Object,
	controllerGVK schema.GroupVersionKind,
	selector labels.Selector,
	canAdopt func() error,
	PodDisruptionBudgetControl PodDisruptionBudgetControlInterface,
) *PodDisruptionBudgetControllerRefManager

func (*PodDisruptionBudgetControllerRefManager) AdoptPodDisruptionBudget 

func (m *PodDisruptionBudgetControllerRefManager) AdoptPodDisruptionBudget(podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error

func (*PodDisruptionBudgetControllerRefManager) ClaimPodDisruptionBudgets 

func (m *PodDisruptionBudgetControllerRefManager) ClaimPodDisruptionBudgets(podDisruptionBudgets []*policyv1beta1.PodDisruptionBudget) (map[string]*policyv1beta1.PodDisruptionBudget, error)

func (*PodDisruptionBudgetControllerRefManager) ReleasePodDisruptionBudget 

func (m *PodDisruptionBudgetControllerRefManager) ReleasePodDisruptionBudget(podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error

type RealPodDisruptionBudgetControl 

type RealPodDisruptionBudgetControl struct {
	KubeClient kubernetes.Interface
	Recorder   record.EventRecorder
}

func (RealPodDisruptionBudgetControl) PatchPodDisruptionBudget 

func (r RealPodDisruptionBudgetControl) PatchPodDisruptionBudget(ctx context.Context, namespace, name string, pt types.PatchType, data []byte, options metav1.PatchOptions) error

type RealSecretControl 

type RealSecretControl struct {
	KubeClient kubernetes.Interface
	Recorder   record.EventRecorder
}

func (RealSecretControl) PatchSecret 

func (r RealSecretControl) PatchSecret(ctx context.Context, namespace, name string, pt types.PatchType, data []byte, options metav1.PatchOptions) error

type RealServiceControl 

type RealServiceControl struct {
	KubeClient kubernetes.Interface
	Recorder   record.EventRecorder
}

func (RealServiceControl) PatchService 

func (r RealServiceControl) PatchService(ctx context.Context, namespace, name string, pt types.PatchType, data []byte, options metav1.PatchOptions) error

type RealStatefulSetControl 

type RealStatefulSetControl struct {
	KubeClient kubernetes.Interface
	Recorder   record.EventRecorder
}

func (RealStatefulSetControl) PatchStatefulSet 

func (r RealStatefulSetControl) PatchStatefulSet(ctx context.Context, namespace, name string, pt types.PatchType, data []byte, options metav1.PatchOptions) error

type SecretControlInterface 

type SecretControlInterface interface {
	PatchSecret(ctx context.Context, namespace, name string, pt types.PatchType, data []byte, options metav1.PatchOptions) error
}

type SecretControllerRefManager 

type SecretControllerRefManager struct {
	kubecontroller.BaseControllerRefManager

	SecretControl SecretControlInterface
	// contains filtered or unexported fields
}

func NewSecretControllerRefManager 

func NewSecretControllerRefManager(
	ctx context.Context,
	controller metav1.Object,
	controllerGVK schema.GroupVersionKind,
	selector labels.Selector,
	canAdopt func() error,
	SecretControl SecretControlInterface,
) *SecretControllerRefManager

func (*SecretControllerRefManager) AdoptSecret 

func (m *SecretControllerRefManager) AdoptSecret(secret *corev1.Secret) error

func (*SecretControllerRefManager) ClaimSecrets 

func (m *SecretControllerRefManager) ClaimSecrets(secrets []*corev1.Secret) (map[string]*corev1.Secret, error)

func (*SecretControllerRefManager) ReleaseSecret 

func (m *SecretControllerRefManager) ReleaseSecret(secret *corev1.Secret) error

type ServiceControlInterface 

type ServiceControlInterface interface {
	PatchService(ctx context.Context, namespace, name string, pt types.PatchType, data []byte, options metav1.PatchOptions) error
}

type ServiceControllerRefManager 

type ServiceControllerRefManager struct {
	kubecontroller.BaseControllerRefManager

	ServiceControl ServiceControlInterface
	// contains filtered or unexported fields
}

func NewServiceControllerRefManager 

func NewServiceControllerRefManager(
	ctx context.Context,
	controller metav1.Object,
	controllerGVK schema.GroupVersionKind,
	selector labels.Selector,
	canAdopt func() error,
	ServiceControl ServiceControlInterface,
) *ServiceControllerRefManager

func (*ServiceControllerRefManager) AdoptService 

func (m *ServiceControllerRefManager) AdoptService(service *corev1.Service) error

func (*ServiceControllerRefManager) ClaimServices 

func (m *ServiceControllerRefManager) ClaimServices(services []*corev1.Service) (map[string]*corev1.Service, error)

func (*ServiceControllerRefManager) ReleaseService 

func (m *ServiceControllerRefManager) ReleaseService(service *corev1.Service) error

type StatefulSetControlInterface 

type StatefulSetControlInterface interface {
	PatchStatefulSet(ctx context.Context, namespace, name string, pt types.PatchType, data []byte, options metav1.PatchOptions) error
}

type StatefulSetControllerRefManager 

type StatefulSetControllerRefManager struct {
	kubecontroller.BaseControllerRefManager
	// contains filtered or unexported fields
}

func NewStatefulSetControllerRefManager 

func NewStatefulSetControllerRefManager(
	ctx context.Context,
	controller metav1.Object,
	controllerGVK schema.GroupVersionKind,
	selector labels.Selector,
	canAdopt func() error,
	statefulSetControl StatefulSetControlInterface,
) *StatefulSetControllerRefManager

func (*StatefulSetControllerRefManager) AdoptStatefulSet 

func (m *StatefulSetControllerRefManager) AdoptStatefulSet(statefulSet *appsv1.StatefulSet) error

func (*StatefulSetControllerRefManager) ClaimStatefulSets 

func (m *StatefulSetControllerRefManager) ClaimStatefulSets(sets []*appsv1.StatefulSet) (map[string]*appsv1.StatefulSet, error)

func (*StatefulSetControllerRefManager) ReleaseStatefulSet 

func (m *StatefulSetControllerRefManager) ReleaseStatefulSet(statefulSet *appsv1.StatefulSet) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.