healthcheck

type HealthCheckSettings ¶

type HealthCheckSettings struct {
	TransmitInterval time.Duration
	ReceiveInterval  time.Duration
	DetectMultiplier int
	MaxBackoff       time.Duration
}

HealthCheckSettings contains the configuration for a health check session.

func DefaultSettings() HealthCheckSettings

type Listener ¶

type Listener struct {
	// contains filtered or unexported fields
}

Listener handles incoming health check packets on a UDP port. When a valid request is received matching the local hostname, it sends a reply with swapped source/destination.

The handler and all packet processing are lock-free by design. SetHandler must be called before Start; after that the handler field is read-only and safe for concurrent access from the read loop goroutine.

func NewListener(localHostname string, port int) (*Listener, error)

func (l *Listener) SetHandler(h packetHandler)

func (l *Listener) Start(ctx context.Context) error

func (l *Listener) Stop()

type Manager ¶

type Manager struct {
	// contains filtered or unexported fields
}

Manager manages multiple peer health check sessions. It coordinates the listener and all active sessions, and dispatches state change callbacks when peer health transitions occur.

func NewManager(localHostname string, port int, onStateChange StateChangeFunc) (*Manager, error)

func (m *Manager) AddPeer(peerHostname string, overlayIP net.IP, settings HealthCheckSettings) error

func (m *Manager) GetAllPeerStatuses() map[string]*PeerStatus

func (m *Manager) GetPeerStatus(peerHostname string) (*PeerStatus, error)

func (m *Manager) RemovePeer(peerHostname string) error

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

func (m *Manager) Stop()

func (m *Manager) UpdatePeerSettings(peerHostname string, settings HealthCheckSettings) error

type PeerStatus ¶

type PeerStatus struct {
	State              SessionState
	Since              time.Time
	LastRTT            time.Duration
	PacketsSent        uint64
	PacketsReceived    uint64
	ConsecutiveReplies int
	RequiredReplies    int
	FlapCount          int
}

PeerStatus contains the current health status of a peer.

type SessionState ¶

type SessionState int

SessionState represents the health state of a peer session.

const (
	// StateDown indicates the peer is unreachable.
	StateDown SessionState = iota
	// StateUp indicates the peer is healthy and responding.
	StateUp
	// StateAdminDown indicates the session has been administratively disabled.
	StateAdminDown
)

func (s SessionState) String() string

type StateChangeFunc ¶

type StateChangeFunc func(peerHostname string, newState, oldState SessionState)

StateChangeFunc is called when a peer's health state changes.