registrationworker

Documentation

Index

• type Worker
  • func NewWorker(queue workqueue.RateLimitingInterface, cache cache.Indexer, ...) *Worker
  • func (w *Worker) Run(stopCh chan struct{})

Types

type Worker

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

Worker structure for registration worker

func NewWorker

func NewWorker(queue workqueue.RateLimitingInterface, cache cache.Indexer, k8sClient *kclient.KubeClient) *Worker

NewWorker factory function to create a new registration worker

func (*Worker) Run

func (w *Worker) Run(stopCh chan struct{})

Run function to start running the registration worker