configmap

package
v4.3.3+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 17, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL