controller

Documentation

Index

• type DependentResourceManager
  • func NewDependentResourceManager(policyQueue workqueue.RateLimitingInterface, ...) *DependentResourceManager
  • func (manager *DependentResourceManager) Get(resource policyv1alpha1.DependentResource) (*unstructured.Unstructured, error)
  • func (manager *DependentResourceManager) HasSyncedPolicyDependentResources(name string) (bool, error)
  • func (manager *DependentResourceManager) List(gvr schema.GroupVersionResource) (ret []*unstructured.Unstructured, err error)
  • func (manager *DependentResourceManager) RemoveLifecycle(name string)
  • func (manager *DependentResourceManager) RemovePolicy(name string)
  • func (manager *DependentResourceManager) SetLifecycleDependentResources(name string, references map[policyv1alpha1.DependentResource]struct{})
  • func (manager *DependentResourceManager) SetPolicyDependentGVRs(name string, source schema.GroupVersionResource, ...) error
• type Result
  • func RequeueResult(retry int) Result

Types

type DependentResourceManager

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

func NewDependentResourceManager

func NewDependentResourceManager(
	policyQueue workqueue.RateLimitingInterface,
	lifecycleQueue workqueue.RateLimitingInterface,
	listerWatcherFactory informer.DynamicListerWatcherFactory,
) *DependentResourceManager

func (*DependentResourceManager) Get

func (manager *DependentResourceManager) Get(resource policyv1alpha1.DependentResource) (*unstructured.Unstructured, error)

func (*DependentResourceManager) HasSyncedPolicyDependentResources

func (manager *DependentResourceManager) HasSyncedPolicyDependentResources(name string) (bool, error)

func (*DependentResourceManager) List

func (manager *DependentResourceManager) List(gvr schema.GroupVersionResource) (ret []*unstructured.Unstructured, err error)

func (*DependentResourceManager) RemoveLifecycle

func (manager *DependentResourceManager) RemoveLifecycle(name string)

func (*DependentResourceManager) RemovePolicy

func (manager *DependentResourceManager) RemovePolicy(name string)

func (*DependentResourceManager) SetLifecycleDependentResources

func (manager *DependentResourceManager) SetLifecycleDependentResources(name string, references map[policyv1alpha1.DependentResource]struct{})

func (*DependentResourceManager) SetPolicyDependentGVRs

func (manager *DependentResourceManager) SetPolicyDependentGVRs(name string, source schema.GroupVersionResource, references map[schema.GroupVersionResource]struct{}) error

type Result

type Result interface {
	Requeue() bool
	MaxRetryCount() int
}

var NoRequeueResult Result = noRequeueResult{}

func RequeueResult

func RequeueResult(retry int) Result