pgc

Documentation

Index

• func PrepareForRestore(clientset *kubeapi.Client, clusterName, namespace string) error
• type Controller
  • func (c *Controller) AddPerconaPGClusterEventHandler()
  • func (c *Controller) DeleteSecrets(cr *crv1.PerconaPGCluster) error
  • func (c *Controller) GenerateUsersInternalSecretsData(clusterName, clusterUser string) ([]SecretData, error)
  • func (c *Controller) RunWorker(stopCh <-chan struct{}, doneCh chan<- struct{})
  • func (c *Controller) UpdateUsers(usersSecret *v1.Secret, clusterName, namespace string) error
  • func (c *Controller) UpdateUsersSecret(usersSecret *v1.Secret, namespace string) error
  • func (c *Controller) WorkerCount() int
• type CronRegistry
  • func NewCronRegistry() CronRegistry
• type Schedule
• type SecretData
• type Templates
• type UserSecretData

Functions

func PrepareForRestore

func PrepareForRestore(clientset *kubeapi.Client, clusterName, namespace string) error

Types

type Controller

type Controller struct {
	Client                      *kubeapi.Client
	Queue                       workqueue.RateLimitingInterface
	Informer                    informers.PerconaPGClusterInformer
	PerconaPGClusterWorkerCount int
	// contains filtered or unexported fields
}

Controller holds the connections for the controller

func (*Controller) AddPerconaPGClusterEventHandler

func (c *Controller) AddPerconaPGClusterEventHandler()

AddPerconaPGClusterEventHandler adds the pgcluster event handler to the pgcluster informer

func (*Controller) DeleteSecrets

func (c *Controller) DeleteSecrets(cr *crv1.PerconaPGCluster) error

func (*Controller) GenerateUsersInternalSecretsData

func (c *Controller) GenerateUsersInternalSecretsData(clusterName, clusterUser string) ([]SecretData, error)

func (*Controller) RunWorker

func (c *Controller) RunWorker(stopCh <-chan struct{}, doneCh chan<- struct{})

RunWorker is a long-running function that will continually call the processNextWorkItem function in order to read and process a message on the workqueue.

func (*Controller) UpdateUsers

func (c *Controller) UpdateUsers(usersSecret *v1.Secret, clusterName, namespace string) error

func (*Controller) UpdateUsersSecret

func (c *Controller) UpdateUsersSecret(usersSecret *v1.Secret, namespace string) error

func (*Controller) WorkerCount

func (c *Controller) WorkerCount() int

WorkerCount returns the worker count for the controller

type CronRegistry

type CronRegistry struct {
	// contains filtered or unexported fields
}

func NewCronRegistry

func NewCronRegistry() CronRegistry

type Schedule

type Schedule struct {
	ID           int
	CronSchedule string
}

type SecretData

type SecretData struct {
	Name string
	Data UserSecretData
}

type Templates

type Templates struct {
	// contains filtered or unexported fields
}

type UserSecretData

type UserSecretData struct {
	Password string `json:"password"`
	Roles    string `json:"roles"`
	Name     string `json:"username"`
	UsersTXT string `json:"users.txt"`
}