statusmanager

package

v0.2.0 Latest Latest Go to latest Published: Nov 19, 2020 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation ¶

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

This section is empty.

This section is empty.

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

func (f *FakeRESTMapper) KindFor(resource schema.GroupVersionResource) (schema.GroupVersionKind, error)

func (f *FakeRESTMapper) KindsFor(resource schema.GroupVersionResource) ([]schema.GroupVersionKind, error)

func (f *FakeRESTMapper) RESTMapping(gk schema.GroupKind, versions ...string) (*meta.RESTMapping, error)

func (f *FakeRESTMapper) RESTMappings(gk schema.GroupKind, versions ...string) ([]*meta.RESTMapping, error)

func (f *FakeRESTMapper) ResourceFor(input schema.GroupVersionResource) (schema.GroupVersionResource, error)

func (f *FakeRESTMapper) ResourceSingularizer(resource string) (singular string, err error)

func (f *FakeRESTMapper) ResourcesFor(input schema.GroupVersionResource) ([]schema.GroupVersionResource, error)

type NodeStatus struct {
	Address string
	Success bool
	Reason  string
}

type StatusLevel int

const (
	ClusterConfig StatusLevel = iota
	OperatorConfig
	PodDeployment
	RolloutHung
	ClusterNode
)

type StatusManager struct {
	sync.Mutex

	OperatorNamespace string
	// contains filtered or unexported fields
}

StatusManager coordinates changes to ClusterOperator.Status

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

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) SetFromNodes(cachedNodeSet map[string]*NodeStatus)

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 (status *StatusManager) SetNotDegraded(statusLevel StatusLevel)