statusmanager

Documentation

Index

• Constants
• type Adaptor
• type StatusK8s
• type StatusLevel
• type StatusManager
  • func New(client client.Client, mapper meta.RESTMapper, ...) (*StatusManager, error)
  • func (status *StatusManager) CombineConditions(conditions *[]configv1.ClusterOperatorStatusCondition, ...) (bool, string)
  • func (status *StatusManager) SetDaemonSets(daemonSets []types.NamespacedName)
  • func (status *StatusManager) SetDegraded(statusLevel StatusLevel, reason, message string)
  • func (status *StatusManager) SetDeployments(deployments []types.NamespacedName)
  • func (status *StatusManager) SetFromPods()
  • func (status *StatusManager) SetNotDegraded(statusLevel StatusLevel)
  • func (status *StatusManager) SetRelatedObjects(relatedObjects []configv1.ObjectReference)
• type StatusOc

Constants

const (
	// if a rollout has not made any progress by this time,
	// mark ourselves as Degraded
	ProgressTimeout = 10 * time.Minute
)

Types

type Adaptor

type Adaptor interface {
	// contains filtered or unexported methods
}

type StatusK8s

type StatusK8s struct{}

type StatusLevel

type StatusLevel int

const (
	ClusterConfig StatusLevel = iota
	OperatorConfig
	PodDeployment
	RolloutHung
	ClusterNode
)

type StatusManager

type StatusManager struct {
	sync.Mutex

	OperatorNamespace string
	AdaptorName       string
	Adaptor
	// contains filtered or unexported fields
}

Status coordinates changes to AntreaInstall.status and ClusterOperator.Status.

func New

func New(client client.Client, mapper meta.RESTMapper, name, operatorNamespace, version string, sharedInfo *sharedinfo.SharedInfo) (*StatusManager, error)

func (*StatusManager) CombineConditions

func (status *StatusManager) CombineConditions(conditions *[]configv1.ClusterOperatorStatusCondition,
	newConditions *[]configv1.ClusterOperatorStatusCondition) (bool, string)

func (*StatusManager) SetDaemonSets

func (status *StatusManager) SetDaemonSets(daemonSets []types.NamespacedName)

func (*StatusManager) SetDegraded

func (status *StatusManager) SetDegraded(statusLevel StatusLevel, reason, message string)

func (*StatusManager) SetDeployments

func (status *StatusManager) SetDeployments(deployments []types.NamespacedName)

func (*StatusManager) SetFromPods

func (status *StatusManager) SetFromPods()

SetFromPods sets the operator Degraded/Progressing/Available status, based on the current status of the manager's DaemonSets and Deployments.

func (*StatusManager) SetNotDegraded

func (status *StatusManager) SetNotDegraded(statusLevel StatusLevel)

func (*StatusManager) SetRelatedObjects

func (status *StatusManager) SetRelatedObjects(relatedObjects []configv1.ObjectReference)

type StatusOc

type StatusOc struct{}