pgcluster

Documentation

Index

• func GetPrimaryPodStatus(clientset *kubernetes.Clientset, cluster *crv1.Pgcluster, ns string) (error, bool)
• type Controller
  • func (c *Controller) Run() error
  • func (c *Controller) RunWorker()
  • func (c *Controller) SetupWatch(ns string)

Functions

func GetPrimaryPodStatus

func GetPrimaryPodStatus(clientset *kubernetes.Clientset, cluster *crv1.Pgcluster, ns string) (error, bool)

Types

type Controller

type Controller struct {
	PgclusterClient    *rest.RESTClient
	PgclusterScheme    *runtime.Scheme
	PgclusterClientset *kubernetes.Clientset
	Queue              workqueue.RateLimitingInterface
	Ctx                context.Context

	InformerNamespaces map[string]struct{}
	// contains filtered or unexported fields
}

Controller holds the connections for the controller

func (*Controller) Run

func (c *Controller) Run() error

Run starts an pgcluster resource controller

func (*Controller) RunWorker

func (c *Controller) RunWorker()

func (*Controller) SetupWatch

func (c *Controller) SetupWatch(ns string)