shared

Documentation

Index

• Constants
• func GenerateTestConfig() *selfnoderemediationv1alpha1.SelfNodeRemediationConfig
• func VerifySNRStatusExist(k8sClient client.Client, snr *selfnoderemediationv1alpha1.SelfNodeRemediation, ...)
• type K8sClientWrapper
  • func (kcw *K8sClientWrapper) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
• type MockRebootDurationCalculator
  • func (m MockRebootDurationCalculator) GetRebootDuration(_ context.Context, _ *corev1.Node) (time.Duration, error)
  • func (m MockRebootDurationCalculator) SetConfig(_ *selfnoderemediationv1alpha1.SelfNodeRemediationConfig)

Constants

const (
	PeerUpdateInterval = 30 * time.Second
	ApiCheckInterval   = 1 * time.Second
	MaxErrorThreshold  = 1
	// CalculatedRebootDuration is the mock calculator's result
	CalculatedRebootDuration = 3 * time.Second
	Namespace                = "self-node-remediation"
	UnhealthyNodeName        = "node1"
	PeerNodeName             = "node2"
	DsDummyImageName         = "dummy-image"
)

Functions

func GenerateTestConfig

func GenerateTestConfig() *selfnoderemediationv1alpha1.SelfNodeRemediationConfig

func VerifySNRStatusExist

func VerifySNRStatusExist(k8sClient client.Client, snr *selfnoderemediationv1alpha1.SelfNodeRemediation, statusType string, conditionStatus metav1.ConditionStatus)

Types

type K8sClientWrapper

type K8sClientWrapper struct {
	client.Client
	Reader                         client.Reader
	ShouldSimulateFailure          bool
	ShouldSimulatePodDeleteFailure bool
	SimulatedFailureMessage        string
}

func (*K8sClientWrapper) List

func (kcw *K8sClientWrapper) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

type MockRebootDurationCalculator

type MockRebootDurationCalculator struct{}

func (MockRebootDurationCalculator) GetRebootDuration

func (m MockRebootDurationCalculator) GetRebootDuration(_ context.Context, _ *corev1.Node) (time.Duration, error)

func (MockRebootDurationCalculator) SetConfig

func (m MockRebootDurationCalculator) SetConfig(_ *selfnoderemediationv1alpha1.SelfNodeRemediationConfig)