utils

Documentation

Index

• Constants
• Variables
• func GetAllRemediationTemplates(healthCheck client.Object) []*v1.ObjectReference
• func GetDeploymentNamespace() (string, error)
• func GetLogWithNHC(log logr.Logger, nhc *v1alpha1.NodeHealthCheck) logr.Logger
• func GetMachineNamespaceName(node *v1.Node) (namespace, name string, err error)
• func GetRemediationDuration(nhc *v1alpha1.NodeHealthCheck, remediationCR *unstructured.Unstructured) (currentRemediationDuration, previousRemediationsDuration time.Duration)
• func IsConditionTrue(conditions []metav1.Condition, conditionType string, reason string) bool
• func IsHealthyMHC(unhealthyConditions []v1beta1.UnhealthyCondition, ...) (bool, *time.Duration)
• func IsHealthyNHC(unhealthyConditions []remediationv1alpha1.UnhealthyCondition, ...) (bool, *time.Duration)
• func MHCByFeatureGateEventMapperFunc(c client.Client, logger logr.Logger, featureGates featuregates.Accessor) handler.MapFunc
• func MHCByMachineMapperFunc(c client.Client, logger logr.Logger, featureGates featuregates.Accessor) handler.MapFunc
• func MHCByNodeMapperFunc(c client.Client, logger logr.Logger, featureGates featuregates.Accessor) handler.MapFunc
• func MinRequeueDuration(old, new *time.Duration) *time.Duration
• func NHCByMHCEventMapperFunc(c client.Client, logger logr.Logger) handler.MapFunc
• func NHCByNodeMapperFunc(c client.Client, logger logr.Logger) handler.MapFunc
• func NHCByRemediationCRMapperFunc(logger logr.Logger) handler.MapFunc
• func NHCByRemediationTemplateCRMapperFunc(c client.Client, logger logr.Logger) handler.MapFunc
• func SetMachineCondition(mhc *v1beta1.MachineHealthCheck, condition *v1beta1.Condition)

Constants

const (
	EventReasonDetectedUnhealthy  = "DetectedUnhealthy"
	EventReasonRemediationCreated = "RemediationCreated"
	EventReasonRemediationSkipped = "RemediationSkipped"
	EventReasonRemediationRemoved = "RemediationRemoved"
	EventReasonDisabled           = "Disabled"
	EventReasonEnabled            = "Enabled"
)

const (
	MachineNodeNameIndex = "machineNodeNameIndex"
)

Variables

var (
	// DefaultRemediationDuration is used for node lease calculations for remediations without configured timeout
	DefaultRemediationDuration = 10 * time.Minute
)

var MachineAnnotationNotFoundError = errors.New("machine annotation not found")

MachineAnnotationNotFoundError indicates that in GetMachineNsName the machine annotation wasn't found on the given node

Functions

func GetAllRemediationTemplates

func GetAllRemediationTemplates(healthCheck client.Object) []*v1.ObjectReference

GetAllRemediationTemplates returns a slice of all ObjectReferences used as RemedediationTemplate in the given NodeHealthCheck

func GetDeploymentNamespace

func GetDeploymentNamespace() (string, error)

GetDeploymentNamespace returns the Namespace this operator is deployed on.

func GetLogWithNHC

func GetLogWithNHC(log logr.Logger, nhc *v1alpha1.NodeHealthCheck) logr.Logger

GetLogWithNHC return a logger with NHC namespace and name

func GetMachineNamespaceName

func GetMachineNamespaceName(node *v1.Node) (namespace, name string, err error)

GetMachineNamespaceName returns machine namespace and name of the given Node. Returns MachineAnnotationNotFoundError in case the needed annotation doesn't exist on the given node

func GetRemediationDuration

func GetRemediationDuration(nhc *v1alpha1.NodeHealthCheck, remediationCR *unstructured.Unstructured) (currentRemediationDuration, previousRemediationsDuration time.Duration)

GetRemediationDuration returns the expected remediation duration for the given CR, and all previous used templates

func IsConditionTrue

func IsConditionTrue(conditions []metav1.Condition, conditionType string, reason string) bool

IsConditionTrue return true when the conditions contain a condition of given type and reason with status true

func IsHealthyMHC

func IsHealthyMHC(unhealthyConditions []v1beta1.UnhealthyCondition, nodeConditions []corev1.NodeCondition, now time.Time) (bool, *time.Duration)

func IsHealthyNHC

func IsHealthyNHC(unhealthyConditions []remediationv1alpha1.UnhealthyCondition, nodeConditions []corev1.NodeCondition, now time.Time) (bool, *time.Duration)

func MHCByFeatureGateEventMapperFunc

func MHCByFeatureGateEventMapperFunc(c client.Client, logger logr.Logger, featureGates featuregates.Accessor) handler.MapFunc

MHCByFeatureGateEventMapperFunc return the FeatureGateEvent-to-NHC mapper function

func MHCByMachineMapperFunc

func MHCByMachineMapperFunc(c client.Client, logger logr.Logger, featureGates featuregates.Accessor) handler.MapFunc

MHCByMachineMapperFunc return the Machine-to-MHC mapper function

func MHCByNodeMapperFunc

func MHCByNodeMapperFunc(c client.Client, logger logr.Logger, featureGates featuregates.Accessor) handler.MapFunc

MHCByNodeMapperFunc return the Node-to-MHC mapper function

func MinRequeueDuration

func MinRequeueDuration(old, new *time.Duration) *time.Duration

MinRequeueDuration returns the minimal valid requeue duration

func NHCByMHCEventMapperFunc

func NHCByMHCEventMapperFunc(c client.Client, logger logr.Logger) handler.MapFunc

NHCByMHCEventMapperFunc return the MHC-event-to-NHC mapper function

func NHCByNodeMapperFunc

func NHCByNodeMapperFunc(c client.Client, logger logr.Logger) handler.MapFunc

NHCByNodeMapperFunc return the Node-to-NHC mapper function

func NHCByRemediationCRMapperFunc

func NHCByRemediationCRMapperFunc(logger logr.Logger) handler.MapFunc

NHCByRemediationCRMapperFunc return the RemediationCR-to-NHC mapper function

func NHCByRemediationTemplateCRMapperFunc

func NHCByRemediationTemplateCRMapperFunc(c client.Client, logger logr.Logger) handler.MapFunc

NHCByRemediationTemplateCRMapperFunc return the RemediationTemplateCR-to-NHC mapper function

func SetMachineCondition

func SetMachineCondition(mhc *v1beta1.MachineHealthCheck, condition *v1beta1.Condition)