controller

package
v1.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 25, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL