configmap

Documentation

Index

• type Controller
  • func NewConfigMapController(restConfig *rest.Config, restClient *rest.RESTClient, ...) (*Controller, error)
  • func (c *Controller) RunWorker(stopCh <-chan struct{}, doneCh chan<- struct{})
  • func (c *Controller) ShutdownWorker()
  • func (c *Controller) WorkerCount() int

Types

type Controller

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

Controller holds connections and other resources for the ConfigMap controller

func NewConfigMapController

func NewConfigMapController(restConfig *rest.Config, restClient *rest.RESTClient,
	clientset *kubernetes.Clientset, coreInformer coreinformers.ConfigMapInformer,
	pgoInformer pgoinformers.PgclusterInformer, workerCount int) (*Controller, error)

NewConfigMapController is responsible for creating a new ConfigMap controller

func (*Controller) RunWorker

func (c *Controller) RunWorker(stopCh <-chan struct{}, doneCh chan<- struct{})

RunWorker is a long-running function that will continually call the processNextWorkItem function in order to read and process a message on the worker queue. Once the worker queue is instructed to shutdown, a message is written to the done channel.

func (*Controller) ShutdownWorker

func (c *Controller) ShutdownWorker()

ShutdownWorker shuts down the work queue

func (*Controller) WorkerCount

func (c *Controller) WorkerCount() int

WorkerCount returns the worker count for the controller