peers

Documentation

Index

• Constants
• type Peers
  • func New(myNodeName string, peerUpdateInterval time.Duration, reader client.Reader, ...) *Peers
  • func (p *Peers) GetPeersAddresses(role Role) [][]v1.NodeAddress
  • func (p *Peers) Start(ctx context.Context) error
• type Response
• type Role

Constants

const (
	HealthyBecauseCRNotFound                       reason = "CR Not found, node is considered healthy"
	HealthyBecauseErrorsThresholdNotReached        reason = "Errors number hasn't reached threshold not querying peers yet, node is considered healthy"
	HealthyBecauseNoPeersResponseNotReachedTimeout reason = "No response from peer. The duration of peer not responding hasn't passed the threshold so still considered healthy"
	HealthyBecauseNoPeersWereFound                 reason = "No Peers where found, node is considered healthy"
	HealthyBecauseMostPeersCantAccessAPIServer     reason = "Most peers couldn't access API server, node is considered healthy"

	UnHealthyBecausePeersResponse  reason = "Node is reported unhealthy by it's peers"
	UnHealthyBecauseNodeIsIsolated reason = "Node is isolated, node is considered unhealthy"
)

Types

type Peers

type Peers struct {
	client.Reader
	// contains filtered or unexported fields
}

func New

func New(myNodeName string, peerUpdateInterval time.Duration, reader client.Reader, log logr.Logger, apiServerTimeout time.Duration) *Peers

func (*Peers) GetPeersAddresses

func (p *Peers) GetPeersAddresses(role Role) [][]v1.NodeAddress

func (*Peers) Start

func (p *Peers) Start(ctx context.Context) error

type Response

type Response struct {
	IsHealthy bool
	Reason    reason
}

type Role

type Role int8

const (
	Worker Role = iota
	ControlPlane
)