router

Mar 10, 2024

Changes in this version

+ var ErrTableEmpty = errors.New("not routing: table empty")

+ var ErrWouldLoop = errors.New("not routing: would loop")

+ type DisconnectPingHandler struct

+ func NewDisconnectPingHandler(r *Router) *DisconnectPingHandler

+ func (h *DisconnectPingHandler) Clean(w *mgr.WorkerCtx) error

+ func (h *DisconnectPingHandler) Handle(w *mgr.WorkerCtx, f frame.Frame, hdr *PingHeader, data []byte) error

+ func (h *DisconnectPingHandler) Send(goingDown bool, disconnected []netip.Addr) error

+ func (h *DisconnectPingHandler) Type() string

+ type DisconnectPingMsg struct

+ Disconnected []netip.Addr

+ GoingDown bool

type ErrorPingHandler

+ func (h *ErrorPingHandler) SendAccessDenied(to netip.Addr, dstIP netip.Addr, protocol uint8, dstPort uint16) error

+ func (h *ErrorPingHandler) SendGeneric(to netip.Addr, text string) error

+ func (h *ErrorPingHandler) SendNoEncryptionKeys(to netip.Addr) error

+ func (h *ErrorPingHandler) SendRejected(to netip.Addr, dstIP netip.Addr, protocol uint8, dstPort uint16) error

+ func (h *ErrorPingHandler) SendUnreachable(to, unreachable netip.Addr) error

+ type ExportedConnection struct

+ DataIn uint64

+ DataOut uint64

+ FirstSeen time.Time

+ Inbound bool

+ LastSeen time.Time

+ LocalIP netip.Addr

+ LocalPort uint16

+ Protocol uint8

+ RemoteIP netip.Addr

+ RemotePort uint16

+ StatusColor string

+ StatusName string

+ func (e *ExportedConnection) HasPorts() bool

+ func (e *ExportedConnection) ProtocolName() string

+ func (e *ExportedConnection) TimeDescription() string

type HelloPingRequest

+ MTU int

type HelloPingResponse

+ MTU int

type PingHeader

+ PingCode uint8

type Router

+ DisconnectPing *DisconnectPingHandler

+ func (r *Router) ExportConnections(maxAge time.Duration) []ExportedConnection

Feb 13, 2024

Changes in this version

+ const PingErrorNoEncryptionKeys

+ const PingErrorNoRoute

+ type ErrorPingHandler struct

+ func NewErrorPingHandler(r *Router) *ErrorPingHandler

+ func (h *ErrorPingHandler) Clean(w *mgr.WorkerCtx) error

+ func (h *ErrorPingHandler) Handle(w *mgr.WorkerCtx, f frame.Frame, hdr *PingHeader, data []byte) error

+ func (h *ErrorPingHandler) Send(errID, msg string, to netip.Addr) error

+ func (h *ErrorPingHandler) Type() string

+ type ErrorPingMsg struct

+ ID string

+ Msg string

type Router

+ ErrorPing *ErrorPingHandler

Jan 24, 2024

Changes in this version

+ var ErrAlreadyActive = errors.New("already active")

+ type AnnouncePingAttachment struct

+ Delay uint16

+ ForwardLabel m.SwitchLabel

+ NextAttachment []byte

+ ReturnLabel m.SwitchLabel

+ Router m.PublicAddress

+ type AnnouncePingHandler struct

+ func NewAnnouncePingHandler(r *Router) *AnnouncePingHandler

+ func (h *AnnouncePingHandler) Clean(w *mgr.WorkerCtx) error

+ func (h *AnnouncePingHandler) Handle(w *mgr.WorkerCtx, f frame.Frame, hdr *PingHeader, data []byte) error

+ func (h *AnnouncePingHandler) Send(peer netip.Addr) error

+ func (h *AnnouncePingHandler) Type() string

+ type AnnouncePingMsg struct

+ Expires time.Time

+ Info *m.RouterInfo

+ ReturnLabel m.SwitchLabel

+ type Config struct

+ Table m.RoutingTableConfig

+ type HelloPingHandler struct

+ func NewHelloPingHandler(r *Router) *HelloPingHandler

+ func (h *HelloPingHandler) Clean(w *mgr.WorkerCtx) error

+ func (h *HelloPingHandler) Handle(w *mgr.WorkerCtx, f frame.Frame, hdr *PingHeader, data []byte) error

+ func (h *HelloPingHandler) Send(dstIP netip.Addr) (notify <-chan struct{}, err error)

+ func (h *HelloPingHandler) Type() string

+ type HelloPingRequest struct

+ KeyExchange []byte

+ KeyExchangeType string

+ type HelloPingResponse struct

+ Err string

+ KeyExchange []byte

+ KeyExchangeType string

+ type PingHandler interface

+ Clean func(w *mgr.WorkerCtx) error

+ Handle func(w *mgr.WorkerCtx, f frame.Frame, pingHdr *PingHeader, pingData []byte) error

+ Type func() string

+ type PingHeader struct

+ AddrHash m.Hash

+ FollowUp bool

+ KeyType string

+ PingID uint64

+ PingType string

+ PublicKey ed25519.PublicKey

+ type PingPongHandler struct

+ func NewPingPongHandler(r *Router) *PingPongHandler

+ func (h *PingPongHandler) Clean(w *mgr.WorkerCtx) error

+ func (h *PingPongHandler) Handle(w *mgr.WorkerCtx, f frame.Frame, hdr *PingHeader, data []byte) error

+ func (h *PingPongHandler) Send(dstIP netip.Addr) (notify <-chan struct{}, err error)

+ func (h *PingPongHandler) Type() string

+ type Router struct

+ AnnouncePing *AnnouncePingHandler

+ HelloPing *HelloPingHandler

+ PingPong *PingPongHandler

+ func New(instance instance, routerConfig Config) (*Router, error)

+ func (r *Router) GetPingHandler(pingType string) PingHandler

+ func (r *Router) Input() chan frame.Frame

+ func (r *Router) RegisterPingHandler(handler PingHandler) error

+ func (r *Router) RouteFrame(f frame.Frame) error

+ func (r *Router) Start(mgr *mgr.Manager) error

+ func (r *Router) Stop(m *mgr.Manager) error

+ func (r *Router) Table() *m.RoutingTable