beacon

func (*Server) Addr ¶

func (s *Server) Addr() net.Addr

Addr returns the server's bound address. Only valid after Ready() fires.

func (*Server) Close ¶

func (s *Server) Close() error

func (*Server) ListenAndServe ¶

func (s *Server) ListenAndServe(addr string) error

func (*Server) LocalNodeCount ¶

func (s *Server) LocalNodeCount() int

LocalNodeCount returns the number of locally registered nodes.

func (*Server) PeerNodeCount ¶

func (s *Server) PeerNodeCount() int

PeerNodeCount returns the number of nodes known via gossip from peer beacons.

func (*Server) Ready ¶

func (s *Server) Ready() <-chan struct{}

Ready returns a channel that is closed when the server has bound its port.

func (*Server) RelayDropped ¶

func (s *Server) RelayDropped() uint64

RelayDropped returns the count of relay packets dropped (capacity / errors).

func (*Server) RelayForwarded ¶

func (s *Server) RelayForwarded() uint64

RelayForwarded returns the count of relay packets the beacon has forwarded since startup. Used by /api/stats to surface observable evidence that the relay path is live.

func (*Server) RelayNotFound ¶

func (s *Server) RelayNotFound() uint64

RelayNotFound returns the count of relay packets dropped because the destination node was not registered with the beacon.

func (*Server) SendPunchCommand ¶

func (s *Server) SendPunchCommand(nodeID uint32, targetIP net.IP, targetPort uint16) error

SendPunchCommand tells a node to send UDP to a target endpoint.

func (*Server) ServeHealth ¶

func (s *Server) ServeHealth(addr string) error

ServeHealth starts a simple HTTP server with a /healthz endpoint for load balancer health checks.

func (*Server) SetHealthy ¶

func (s *Server) SetHealthy(ok bool)

SetHealthy sets the health status (for graceful drain on scale-down).

func (*Server) SetRegistry ¶

func (s *Server) SetRegistry(addr string)

SetRegistry sets the registry address for dynamic peer discovery. The beacon will periodically register itself and discover peers via the registry.