controller

Documentation

Index

• Variables
• func InitializeReplicaCreation(clientset pgo.Interface, clusterName, namespace string) error
• func SetClusterInitializedStatus(clientset pgo.Interface, clusterName, namespace string) error
• type Manager
• type WorkerRunner

Variables

var ErrControllerGroupExists = errors.New("A controller group for the namespace specified already" +
	"exists")

ErrControllerGroupExists is the error that is thrown when a controller group for a specific namespace already exists

Functions

func InitializeReplicaCreation

func InitializeReplicaCreation(clientset pgo.Interface, clusterName,
	namespace string) error

InitializeReplicaCreation initializes the creation of replicas for a cluster. For a regular (i.e. non-standby) cluster this is called following the creation of the initial cluster backup, which is needed to bootstrap replicas. However, for a standby cluster this is called as soon as the primary PG pod reports ready and the cluster is marked as initialized.

func SetClusterInitializedStatus

func SetClusterInitializedStatus(clientset pgo.Interface, clusterName,
	namespace string) error

SetClusterInitializedStatus sets the status of a pgcluster CR to indicate that it has been initialized. This is specifically done by patching the status of the pgcluster CR with the proper initialization status.

Types

type Manager

type Manager interface {
	AddGroup(namespace string) error
	AddAndRunGroup(namespace string) error
	RemoveAll()
	RemoveGroup(namespace string)
	RunAll() error
	RunGroup(namespace string) error
}

Manager defines the interface for a controller manager

type WorkerRunner

type WorkerRunner interface {
	RunWorker(stopCh <-chan struct{}, doneCh chan<- struct{})
	WorkerCount() int
}

WorkerRunner is an interface for controllers the have worker queues that need to be run