Documentation
¶
Index ¶
- Variables
- func RecheckDeletionTimestamp(getObject func() (metav1.Object, error)) func() error
- type DeployClientInterface
- type DeploymentControllerRefManager
- type RealDeployClient
- type RealSetClient
- type RealSvcClient
- type ServiceControllerRefManager
- type SetClientInterface
- type StatefulSetControllerRefManager
- type SvcClientInterface
Constants ¶
This section is empty.
Variables ¶
View Source
var (
KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc
)
Functions ¶
Types ¶
type DeployClientInterface ¶
type DeployClientInterface interface {
PatchDeployment(namespace, name string, data []byte) error
DeleteDeployment(namespace, name string) error
}
TODO: Deprecated in future since this is redundant?
type DeploymentControllerRefManager ¶
type DeploymentControllerRefManager struct {
// contains filtered or unexported fields
}
DeploymentControllerRefManager is responsible for claiming deployments
func NewDeploymentControllerRefManager ¶
func NewDeploymentControllerRefManager( dpClient DeployClientInterface, controller metav1.Object, selector labels.Selector, controllerKind schema.GroupVersionKind, canAdopt func() error, ) *DeploymentControllerRefManager
func (*DeploymentControllerRefManager) ClaimDeployment ¶
func (dcrm *DeploymentControllerRefManager) ClaimDeployment(dpList []*appsv1.Deployment) ([]*appsv1.Deployment, error)
type RealDeployClient ¶
type RealDeployClient struct {
// contains filtered or unexported fields
}
func NewRealDeployClient ¶
func NewRealDeployClient(kubeClient clientset.Interface) *RealDeployClient
func (RealDeployClient) DeleteDeployment ¶
func (rdc RealDeployClient) DeleteDeployment(namespace, name string) error
func (RealDeployClient) PatchDeployment ¶
func (rdc RealDeployClient) PatchDeployment(namespace, name string, data []byte) error
type RealSetClient ¶
type RealSetClient struct {
// contains filtered or unexported fields
}
func NewRealSetClient ¶
func NewRealSetClient(kubeClient clientset.Interface) *RealSetClient
func (*RealSetClient) DeleteStatefulSet ¶
func (rssc *RealSetClient) DeleteStatefulSet(namespace, name string) error
func (*RealSetClient) PatchStatefulSet ¶
func (rssc *RealSetClient) PatchStatefulSet(namespace, name string, data []byte) error
type RealSvcClient ¶
type RealSvcClient struct {
// contains filtered or unexported fields
}
func NewRealSvcClient ¶
func NewRealSvcClient(kubeClient clientset.Interface) *RealSvcClient
func (*RealSvcClient) DeleteService ¶
func (rsc *RealSvcClient) DeleteService(namespace, name string) error
func (*RealSvcClient) PatchService ¶
func (rsc *RealSvcClient) PatchService(namespace, name string, data []byte) error
type ServiceControllerRefManager ¶
type ServiceControllerRefManager struct {
// contains filtered or unexported fields
}
ServiceControllerRefManager is responsible for claiming services
func NewServiceControllerRefManager ¶
func NewServiceControllerRefManager( svcClient SvcClientInterface, controller metav1.Object, selector labels.Selector, controllerKind schema.GroupVersionKind, canAdopt func() error, ) *ServiceControllerRefManager
func (*ServiceControllerRefManager) ClaimService ¶
type SetClientInterface ¶
type StatefulSetControllerRefManager ¶
type StatefulSetControllerRefManager struct {
// contains filtered or unexported fields
}
StatefulSetControllerRefManager is responsible for claiming statefulsets
func NewStatefulSetControllerRefManager ¶
func NewStatefulSetControllerRefManager( setClient SetClientInterface, controller metav1.Object, selector labels.Selector, controllerKind schema.GroupVersionKind, canAdopt func() error, ) *StatefulSetControllerRefManager
func (*StatefulSetControllerRefManager) ClaimStatefulSet ¶
func (sscrm *StatefulSetControllerRefManager) ClaimStatefulSet(setList []*appsv1.StatefulSet) ([]*appsv1.StatefulSet, error)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.