Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPrimaryPodStatus ¶
Types ¶
type JobController ¶
type JobController struct { 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) 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 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)