Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPrimaryPodStatus ¶
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) 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)
Source Files
Click to show internal directories.
Click to hide internal directories.