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
• type PgclusterController
  • func (c *PgclusterController) Run(ctx context.Context) error
• type PgpolicyController
  • func (c *PgpolicyController) Run(ctx context.Context) error
• type PgreplicaController
  • func (c *PgreplicaController) Run(ctx context.Context) error
• type PgtaskController
  • func (c *PgtaskController) 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
}

PgbackupController holds connections required by the controller

func (*PgbackupController) Run

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

Run starts controller

type PgclusterController

type PgclusterController struct {
	PgclusterClient    *rest.RESTClient
	PgclusterScheme    *runtime.Scheme
	PgclusterClientset *kubernetes.Clientset
	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

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
}

PgreplicaController holds the connections for the controller

func (*PgreplicaController) Run

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

Run starts an pgreplica resource controller

type PgtaskController

type PgtaskController struct {
	PgtaskConfig    *rest.Config
	PgtaskClient    *rest.RESTClient
	PgtaskScheme    *runtime.Scheme
	PgtaskClientset *kubernetes.Clientset
	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

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