arednlink

Documentation

Index

• Constants
• func HandleConnection(config *config.Config, conn net.Conn, broadcastChan chan Message, ...)
• type Command
  • func (c Command) String() string
• type Connection
• type Message
  • func (m *Message) Bytes() []byte
• type Server
  • func NewServer(config *config.Config, routes ***xsync.MapOf[string, string], ...) (*Server, error)
  • func (s *Server) Stop()

Constants

const HopDefault = 64

Functions

func HandleConnection

func HandleConnection(
	config *config.Config,
	conn net.Conn,
	broadcastChan chan Message,
	hosts *xsync.MapOf[string, string],
	services *xsync.MapOf[string, string],
	routes ***xsync.MapOf[string, string],
)

Types

type Command

type Command byte

const (
	CommandVersion        Command = 'V'
	CommandUpdateHosts    Command = 'H'
	CommandUpdateServices Command = 'U'
	CommandSync           Command = 'S'
	CommandKeepAlive      Command = 'K'
)

func (Command) String

func (c Command) String() string

type Connection

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

type Message

type Message struct {
	Length    uint16
	Command   Command
	Payload   []byte
	Source    net.IP
	Hops      uint8
	ConnID    string // Internal use for tracking connections
	DestIface string // Internal use for tracking interfaces
}

func (*Message) Bytes

func (m *Message) Bytes() []byte

type Server

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

func NewServer

func NewServer(
	config *config.Config,
	routes ***xsync.MapOf[string, string],
	hosts *xsync.MapOf[string, string],
	services *xsync.MapOf[string, string],
	broadcastChan chan Message,
) (*Server, error)

func (*Server) Stop

func (s *Server) Stop()