checks

type Checker ¶

type Checker interface {
	Check(ctx context.Context) Result
	Type() string
}

func NewChecker(cfg *config.CheckConfig) (Checker, error)

type DNSChecker ¶

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

func NewDNSChecker(cfg *config.DNSCheckConfig) *DNSChecker

func (c *DNSChecker) Check(ctx context.Context) Result

func (c *DNSChecker) Type() string

type HTTPChecker ¶

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

func NewHTTPChecker(cfg *config.HTTPCheckConfig) (*HTTPChecker, error)

func (c *HTTPChecker) Check(ctx context.Context) Result

func (c *HTTPChecker) Type() string

type HealthTransition ¶

type HealthTransition struct {
	Ctx         context.Context // trace context; may be nil when called synthetically
	VIPName     string
	Healthy     bool
	Reason      string
	CheckResult Result
}

HealthTransition is fired when a VIP crosses the rise or fall threshold. Ctx carries the trace context of the check that caused the transition so that downstream operations (e.g. BGP announce/withdraw) appear as child spans.

type PingChecker ¶

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

func NewPingChecker(cfg *config.PingCheckConfig) *PingChecker

func (c *PingChecker) Check(ctx context.Context) Result

func (c *PingChecker) Type() string

type Result ¶

type Result struct {
	Success  bool          `json:"success"`
	Detail   string        `json:"detail"`
	Duration time.Duration `json:"duration"`
	Err      error         `json:"-"`
	TimedOut bool          `json:"timed_out,omitempty"`
}

type Scheduler ¶

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

func NewScheduler(cfg SchedulerConfig) *Scheduler

func (s *Scheduler) ConsecutiveFail() int

func (s *Scheduler) ConsecutiveOK() int

func (s *Scheduler) IsHealthy() bool

func (s *Scheduler) LastResult() Result

func (s *Scheduler) Run(ctx context.Context)

func (s *Scheduler) SetCallbacks(onTransition func(HealthTransition), onCheckResult func(string, Result))

func (s *Scheduler) TriggerCheck(ctx context.Context) (Result, error)

func (s *Scheduler) VIPName() string

type SchedulerConfig ¶

type SchedulerConfig struct {
	VIPName       string
	Checker       Checker
	Interval      time.Duration
	Timeout       time.Duration
	Rise          int
	Fall          int
	OnTransition  func(HealthTransition)
	OnCheckResult func(vipName string, result Result)
}

type TCPChecker ¶ added in v0.3.0

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

TCPChecker dials host:port over TCP. A successful connection means the port is open and accepting connections; the connection is closed immediately after.

func NewTCPChecker(cfg *config.TCPCheckConfig) *TCPChecker

func (c *TCPChecker) Check(ctx context.Context) Result

func (c *TCPChecker) Type() string

type UDPChecker ¶ added in v0.3.0

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

UDPChecker probes a UDP port by sending a small datagram and waiting for an ICMP port-unreachable reply. On Linux, when a UDP socket is connected and a datagram is sent to a port with no listener, the kernel delivers the ICMP error back to the socket as ECONNREFUSED on the next I/O call — without requiring elevated privileges or raw sockets.

Decision logic:

• ECONNREFUSED on read → nothing is listening → check fails
• Read timeout (no ICMP received) → datagram was accepted → check passes
• Actual data received → server responded → check passes

func NewUDPChecker(cfg *config.UDPCheckConfig) *UDPChecker

func (c *UDPChecker) Check(ctx context.Context) Result

func (c *UDPChecker) Type() string