clusterimportpolicy

Documentation

Index

• Constants
• Variables
• func NewReconcilingCondition(reason string, err error) (cond metav1.Condition)
• func NewValidateCondition(reason string, err error) (cond metav1.Condition)
• type Controller
  • func NewController(mapper meta.RESTMapper, client clientset.Interface, ...) (*Controller, error)
  • func (c *Controller) Run(workers int, stopCh <-chan struct{})

Constants

const PolicyControllerFinalizer = "clusterpedia.io/cluster-import-policy-controller"

Variables

var NoRequeueResult = controller.NoRequeueResult

Functions

func NewReconcilingCondition

func NewReconcilingCondition(reason string, err error) (cond metav1.Condition)

func NewValidateCondition

func NewValidateCondition(reason string, err error) (cond metav1.Condition)

Types

type Controller

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

func NewController

func NewController(
	mapper meta.RESTMapper,
	client clientset.Interface,
	policyInformer policyinformers.ClusterImportPolicyInformer,
	lifecycleInformer policyinformers.PediaClusterLifecycleInformer,
	queue workqueue.RateLimitingInterface,
	dependentManager *controller.DependentResourceManager,
) (*Controller, error)

func (*Controller) Run

func (c *Controller) Run(workers int, stopCh <-chan struct{})