namespace

Documentation

Index

• type Controller
  • func NewNamespaceController(controllerManager controller.Manager, informer coreinformers.NamespaceInformer, ...) (*Controller, error)
  • func (c *Controller) RunWorker(stopCh <-chan struct{})
  • func (c *Controller) ShutdownWorker()
  • func (c *Controller) WorkerCount() int

Types

type Controller

type Controller struct {
	ControllerManager controller.Manager
	Informer          coreinformers.NamespaceInformer
	// contains filtered or unexported fields
}

Controller holds the connections for the controller

func NewNamespaceController

func NewNamespaceController(controllerManager controller.Manager,
	informer coreinformers.NamespaceInformer, workerCount int) (*Controller, error)

NewNamespaceController creates a new namespace controller that will watch for namespace events as responds accordingly. This adding and removing controller groups as namespaces watched by the PostgreSQL Operator are added and deleted.

func (*Controller) RunWorker

func (c *Controller) RunWorker(stopCh <-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