controller

Documentation

Index

• func GetPrimaryPodStatus(clientset *kubernetes.Clientset, cluster *crv1.Pgcluster, ns string) (error, bool)
• type JobController
  • func (c *JobController) Run() error
  • func (c *JobController) SetupWatch(ns string)
• type NamespaceController
  • func (c *NamespaceController) Run() error
• type PgbackupController
  • func (c *PgbackupController) Run() error
  • func (c *PgbackupController) RunUpdateWorker()
  • func (c *PgbackupController) RunWorker()
  • func (c *PgbackupController) SetupWatch(ns string)
• type PgclusterController
  • func (c *PgclusterController) Run() error
  • func (c *PgclusterController) RunWorker()
  • func (c *PgclusterController) SetupWatch(ns string)
• type PgpolicyController
  • func (c *PgpolicyController) Run() error
  • func (c *PgpolicyController) SetupWatch(ns string)
• type PgreplicaController
  • func (c *PgreplicaController) Run() error
  • func (c *PgreplicaController) RunWorker()
  • func (c *PgreplicaController) SetupWatch(ns string)
• type PgtaskController
  • func (c *PgtaskController) Run() error
  • func (c *PgtaskController) RunWorker()
  • func (c *PgtaskController) SetupWatch(ns string)
• type PodController
  • func (c *PodController) Run() error
  • func (c *PodController) SetupWatch(ns string)

Functions

func GetPrimaryPodStatus

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

Types

type JobController

type JobController struct {
	JobConfig    *rest.Config
	JobClient    *rest.RESTClient
	JobClientset *kubernetes.Clientset
	Ctx          context.Context

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

JobController holds the connections for the controller

func (*JobController) Run

func (c *JobController) Run() error

Run starts an pod resource controller

func (*JobController) SetupWatch

func (c *JobController) SetupWatch(ns string)

type NamespaceController

type NamespaceController struct {
	NamespaceClient        *rest.RESTClient
	NamespaceClientset     *kubernetes.Clientset
	Ctx                    context.Context
	ThePodController       *PodController
	TheJobController       *JobController
	ThePgpolicyController  *PgpolicyController
	ThePgbackupController  *PgbackupController
	ThePgreplicaController *PgreplicaController
	ThePgclusterController *PgclusterController
	ThePgtaskController    *PgtaskController
}

NamespaceController holds the connections for the controller

func (*NamespaceController) Run

func (c *NamespaceController) Run() error

Run starts a namespace resource controller

type PgbackupController

type PgbackupController struct {
	PgbackupClient    *rest.RESTClient
	PgbackupScheme    *runtime.Scheme
	PgbackupClientset *kubernetes.Clientset
	Ctx               context.Context
	Queue             workqueue.RateLimitingInterface
	UpdateQueue       workqueue.RateLimitingInterface

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

PgbackupController holds connections required by the controller

func (*PgbackupController) Run

func (c *PgbackupController) Run() error

Run starts controller

func (*PgbackupController) RunUpdateWorker

func (c *PgbackupController) RunUpdateWorker()

func (*PgbackupController) RunWorker

func (c *PgbackupController) RunWorker()

func (*PgbackupController) SetupWatch

func (c *PgbackupController) SetupWatch(ns string)

type PgclusterController

type PgclusterController 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
}

PgclusterController holds the connections for the controller

func (*PgclusterController) Run

func (c *PgclusterController) Run() error

Run starts an pgcluster resource controller

func (*PgclusterController) RunWorker

func (c *PgclusterController) RunWorker()

func (*PgclusterController) SetupWatch

func (c *PgclusterController) SetupWatch(ns string)

type PgpolicyController

type PgpolicyController struct {
	PgpolicyClient    *rest.RESTClient
	PgpolicyScheme    *runtime.Scheme
	PgpolicyClientset *kubernetes.Clientset
	Ctx               context.Context

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

PgpolicyController holds connections for the controller

func (*PgpolicyController) Run

func (c *PgpolicyController) Run() error

Run starts an pgpolicy resource controller

func (*PgpolicyController) SetupWatch

func (c *PgpolicyController) SetupWatch(ns string)

type PgreplicaController

type PgreplicaController struct {
	PgreplicaClient    *rest.RESTClient
	PgreplicaScheme    *runtime.Scheme
	PgreplicaClientset *kubernetes.Clientset
	Queue              workqueue.RateLimitingInterface
	Ctx                context.Context

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

PgreplicaController holds the connections for the controller

func (*PgreplicaController) Run

func (c *PgreplicaController) Run() error

Run starts an pgreplica resource controller

func (*PgreplicaController) RunWorker

func (c *PgreplicaController) RunWorker()

func (*PgreplicaController) SetupWatch

func (c *PgreplicaController) SetupWatch(ns string)

type PgtaskController

type PgtaskController struct {
	PgtaskConfig    *rest.Config
	PgtaskClient    *rest.RESTClient
	PgtaskScheme    *runtime.Scheme
	PgtaskClientset *kubernetes.Clientset
	Queue           workqueue.RateLimitingInterface
	Ctx             context.Context

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

PgtaskController holds connections for the controller

func (*PgtaskController) Run

func (c *PgtaskController) Run() error

Run starts an pgtask resource controller

func (*PgtaskController) RunWorker

func (c *PgtaskController) RunWorker()

func (*PgtaskController) SetupWatch

func (c *PgtaskController) SetupWatch(ns string)

type PodController

type PodController struct {
	PodClient    *rest.RESTClient
	PodClientset *kubernetes.Clientset
	PodConfig    *rest.Config
	Ctx          context.Context

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

PodController holds the connections for the controller

func (*PodController) Run

func (c *PodController) Run() error

Run starts an pod resource controller

func (*PodController) SetupWatch

func (c *PodController) SetupWatch(ns string)