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
Namespace string
}
JobController holds the connections for the controller
type PgbackupController ¶
type PgbackupController struct {
PgbackupClient *rest.RESTClient
PgbackupScheme *runtime.Scheme
PgbackupClientset *kubernetes.Clientset
Namespace string
Queue workqueue.RateLimitingInterface
UpdateQueue workqueue.RateLimitingInterface
}
PgbackupController holds connections required by the controller
func (*PgbackupController) Run ¶
func (c *PgbackupController) Run(ctx context.Context) error
Run starts controller
func (*PgbackupController) RunUpdateWorker ¶
func (c *PgbackupController) RunUpdateWorker()
func (*PgbackupController) RunWorker ¶
func (c *PgbackupController) RunWorker()
type PgclusterController ¶
type PgclusterController struct {
PgclusterClient *rest.RESTClient
PgclusterScheme *runtime.Scheme
PgclusterClientset *kubernetes.Clientset
Queue workqueue.RateLimitingInterface
Namespace string
}
PgclusterController holds the connections for the controller
func (*PgclusterController) Run ¶
func (c *PgclusterController) Run(ctx context.Context) error
Run starts an pgcluster resource controller
func (*PgclusterController) RunWorker ¶
func (c *PgclusterController) RunWorker()
type PgpolicyController ¶
type PgpolicyController struct {
PgpolicyClient *rest.RESTClient
PgpolicyScheme *runtime.Scheme
PgpolicyClientset *kubernetes.Clientset
Namespace string
}
PgpolicyController holds connections for the controller
type PgreplicaController ¶
type PgreplicaController struct {
PgreplicaClient *rest.RESTClient
PgreplicaScheme *runtime.Scheme
PgreplicaClientset *kubernetes.Clientset
Namespace string
Ctx context.Context
Queue workqueue.RateLimitingInterface
}
PgreplicaController holds the connections for the controller
func (*PgreplicaController) Run ¶
func (c *PgreplicaController) Run(ctx context.Context) error
Run starts an pgreplica resource controller
func (*PgreplicaController) RunWorker ¶
func (c *PgreplicaController) RunWorker()
type PgtaskController ¶
type PgtaskController struct {
PgtaskConfig *rest.Config
PgtaskClient *rest.RESTClient
PgtaskScheme *runtime.Scheme
PgtaskClientset *kubernetes.Clientset
Queue workqueue.RateLimitingInterface
Namespace string
}
PgtaskController holds connections for the controller
func (*PgtaskController) Run ¶
func (c *PgtaskController) Run(ctx context.Context) error
Run starts an pgtask resource controller
func (*PgtaskController) RunWorker ¶
func (c *PgtaskController) RunWorker()
type PgupgradeController ¶
type PgupgradeController struct {
PgupgradeClient *rest.RESTClient
PgupgradeClientset *kubernetes.Clientset
PgupgradeScheme *runtime.Scheme
Namespace string
}
PgupgradeController holds the connections for the controller
type PodController ¶
type PodController struct {
PodClient *rest.RESTClient
PodClientset *kubernetes.Clientset
Namespace string
}
PodController holds the connections for the controller
Click to show internal directories.
Click to hide internal directories.