status

type MockStatus ¶ added in v1.4.0

type MockStatus struct {
	mock.Mock
}

TODO use mockery to generate mock

func (m *MockStatus) AddCertificateSigningRequests(name string, labels map[string]string)

func (m *MockStatus) AddCronJobs(cjs []types.NamespacedName)

func (m *MockStatus) AddDaemonsets(dss []types.NamespacedName)

func (m *MockStatus) AddDeployments(deps []types.NamespacedName)

func (m *MockStatus) AddStatefulSets(sss []types.NamespacedName)

func (m *MockStatus) ClearDegraded()

func (m *MockStatus) IsAvailable() bool

func (m *MockStatus) IsDegraded() bool

func (m *MockStatus) IsProgressing() bool

func (m *MockStatus) OnCRFound()

func (m *MockStatus) OnCRNotFound()

func (m *MockStatus) ReadyToMonitor()

func (m *MockStatus) RemoveCertificateSigningRequests(label string)

func (m *MockStatus) RemoveCronJobs(cjs ...types.NamespacedName)

func (m *MockStatus) RemoveDaemonsets(dss ...types.NamespacedName)

func (m *MockStatus) RemoveDeployments(dps ...types.NamespacedName)

func (m *MockStatus) RemoveStatefulSets(sss ...types.NamespacedName)

func (m *MockStatus) Run(context.Context)

func (m *MockStatus) SetDegraded(reason operator.TigeraStatusReason, msg string, err error, log logr.Logger)

func (m *MockStatus) SetMetaData(meta *metav1.ObjectMeta)

func (m *MockStatus) WasCalled(method string, arguments ...interface{}) bool

type StatusManager ¶

type StatusManager interface {
	Run(ctx context.Context)
	OnCRFound()
	OnCRNotFound()
	AddDaemonsets(dss []types.NamespacedName)
	AddDeployments(deps []types.NamespacedName)
	AddStatefulSets(sss []types.NamespacedName)
	AddCronJobs(cjs []types.NamespacedName)
	AddCertificateSigningRequests(name string, labels map[string]string)
	RemoveDaemonsets(dss ...types.NamespacedName)
	RemoveDeployments(dps ...types.NamespacedName)
	RemoveStatefulSets(sss ...types.NamespacedName)
	RemoveCronJobs(cjs ...types.NamespacedName)
	RemoveCertificateSigningRequests(name string)
	SetDegraded(reason operator.TigeraStatusReason, msg string, err error, log logr.Logger)
	ClearDegraded()
	IsAvailable() bool
	IsProgressing() bool
	IsDegraded() bool
	ReadyToMonitor()
	SetMetaData(meta *metav1.ObjectMeta)
}

StatusManager manages the status for a single controller and component, and reports the status via a TigeraStatus API object. The status manager uses the following conditions/states to represent the component's current status:

• Available: The component is successfully running. All pods launched by the component are healthy. An upgrade may or may not be occurring.
• Progressing: A state change is occurring. It may be that the component is being installed for the first time, or being upgraded to a new configuration or version.
• Degraded: The component is not running the desired state and is not progressing towards it. Either the component has not been installed, has been updated with invalid configuration, or has crashed.

Each of these states can be set independently of each other. For example, a component can be both available and degraded if it is running successfully but a configuration change has resulted in a configuration that cannot be actioned.

func New(client client.Client, component string, kubernetesVersion *common.VersionInfo) StatusManager