pgcluster

Documentation

Index

• type Controller
  • func (c *Controller) AddPGClusterEventHandler()
  • func (c *Controller) RunWorker(stopCh <-chan struct{}, doneCh chan<- struct{})
  • func (c *Controller) WorkerCount() int

Types

type Controller

type Controller struct {
	PgclusterClient      *rest.RESTClient
	PgclusterClientset   kubernetes.Interface
	PgclusterConfig      *rest.Config
	Queue                workqueue.RateLimitingInterface
	Informer             informers.PgclusterInformer
	PgclusterWorkerCount int
}

Controller holds the connections for the controller

func (*Controller) AddPGClusterEventHandler

func (c *Controller) AddPGClusterEventHandler()

AddPGClusterEventHandler adds the pgcluster event handler to the pgcluster informer

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 workqueue.

func (*Controller) WorkerCount

func (c *Controller) WorkerCount() int

WorkerCount returns the worker count for the controller