active

Documentation

Index

• Constants
• Variables
• func GenerateMyActiveConfigMap() *corev1.ConfigMap
• func GetActiveConfigMap(client client.Client) (*corev1.ConfigMap, error)
• func IsThisOperatorActive(cm *corev1.ConfigMap) (bool, string)
• func WaitUntilActive(cs *kubernetes.Clientset, client client.Client, ctx context.Context, ...)

Constants

const (
	ActiveConfigMapName = "active-operator"
)

Variables

var OsExitOverride = os.Exit

var TickerRateOverride = 1000 * time.Millisecond

Functions

func GenerateMyActiveConfigMap

func GenerateMyActiveConfigMap() *corev1.ConfigMap

GenerateMyActiveConfigMap returns a ConfigMap that matches what the expected ConfigMap would be.

func GetActiveConfigMap

func GetActiveConfigMap(client client.Client) (*corev1.ConfigMap, error)

GetActiveConfigMap returns the ConfigMap for the active operator if it exists. If the ConfigMap does not exist then no map is returned and no error. If there is a problem fetching the ConfigMap then the error is returned.

func IsThisOperatorActive

func IsThisOperatorActive(cm *corev1.ConfigMap) (bool, string)

IsThisOperatorActive will process the passed in ConfigMap and check that this running operator is the active one based on the OperatorNamespace. The first return value is if this running operator is active. The 2nd return value is the namespace of the active operator, if the namespace is not in the ConfigMap then an empty string will be returned.

func WaitUntilActive

func WaitUntilActive(cs *kubernetes.Clientset, client client.Client, ctx context.Context, log logr.Logger)