controller

Documentation

Index

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

Functions

func GetPrimaryPodStatus

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

Types

type JobController

type JobController struct {
	JobClient    *rest.RESTClient
	JobClientset *kubernetes.Clientset
	Namespace    string
}

JobController holds the connections for the controller

func (*JobController) Run

func (c *JobController) Run(ctx context.Context) error

Run starts an pod resource 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

func (*PgpolicyController) Run

func (c *PgpolicyController) Run(ctx context.Context) error

Run starts an pgpolicy resource 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

func (*PgupgradeController) Run

func (c *PgupgradeController) Run(ctx context.Context) error

Run starts an pgupgrade resource controller

type PodController

type PodController struct {
	PodClient    *rest.RESTClient
	PodClientset *kubernetes.Clientset
	Namespace    string
}

PodController holds the connections for the controller

func (*PodController) Run

func (c *PodController) Run(ctx context.Context) error

Run starts an pod resource controller