shared

Documentation

Index

• Constants
• type K8sClientWrapper
  • func (kcw *K8sClientWrapper) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
• type MockCalculator
  • func (m *MockCalculator) GetTimeToAssumeNodeRebooted() time.Duration
  • func (m *MockCalculator) IsAgent() bool
  • func (m *MockCalculator) SetTimeToAssumeNodeRebooted(timeToAssumeNodeRebooted time.Duration)
  • func (m *MockCalculator) Start(ctx context.Context) error

Constants

const (
	PeerUpdateInterval = 30 * time.Second
	ApiCheckInterval   = 1 * time.Second
	MaxErrorThreshold  = 1
	Namespace          = "self-node-remediation"
	UnhealthyNodeName  = "node1"
	PeerNodeName       = "node2"
)

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 MockCalculator

type MockCalculator struct {
	MockTimeToAssumeNodeRebooted time.Duration
	IsAgentVar                   bool
}

func (*MockCalculator) GetTimeToAssumeNodeRebooted

func (m *MockCalculator) GetTimeToAssumeNodeRebooted() time.Duration

func (*MockCalculator) IsAgent

func (m *MockCalculator) IsAgent() bool

func (*MockCalculator) SetTimeToAssumeNodeRebooted

func (m *MockCalculator) SetTimeToAssumeNodeRebooted(timeToAssumeNodeRebooted time.Duration)

func (*MockCalculator) Start

func (m *MockCalculator) Start(ctx context.Context) error