management

package
v0.0.0-...-93b3a4f Latest Latest
Warning

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

Go to latest
Published: May 6, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsOperatorAlwaysManaged

func IsOperatorAlwaysManaged() bool

IsOperatorAlwaysManaged means the operator can't be set to unmanaged state.

func IsOperatorManaged

func IsOperatorManaged(state v1.ManagementState) bool

IsOperatorManaged indicates whether the operator management state allows the control loop to proceed and manage the operand.

func IsOperatorNotRemovable

func IsOperatorNotRemovable() bool

IsOperatorNotRemovable means the operator can't bet set to removed state.

func IsOperatorUnknownState

func IsOperatorUnknownState(state v1.ManagementState) bool

func SetOperatorAlwaysManaged

func SetOperatorAlwaysManaged()

SetOperatorAlwaysManaged is one time choice when an operator want to opt-out from supporting the "unmanaged" state. This is a case of control plane operators or operators that are required to always run otherwise the cluster will get into unstable state or critical components will stop working.

func SetOperatorNotRemovable

func SetOperatorNotRemovable()

SetOperatorNotRemovable is one time choice the operator author can make to indicate the operator does not support removing of his operand. This makes sense for operators like kube-apiserver where removing operand will lead to a bricked, non-automatically recoverable state.

Types

type ManagementStateController

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

ManagementStateController watches changes of `managementState` field and react in case that field is set to an unsupported value. As each operator can opt-out from supporting `unmanaged` or `removed` states, this controller will add failing condition when the value for this field is set to this values for those operators.

func NewOperatorManagementStateController

func NewOperatorManagementStateController(
	name string,
	operatorClient operatorv1helpers.OperatorClient,
	recorder events.Recorder,
) *ManagementStateController

func (*ManagementStateController) Run

func (c *ManagementStateController) Run(workers int, stopCh <-chan struct{})

Jump to

Keyboard shortcuts

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