allof

Documentation

Index

• func Decode(packet, topic []byte) (ttl byte, data []byte, err error)
• func Encode(ttl byte, msg, topic []byte) []byte
• type Node
  • func Listen(network, addr string, topic []byte) (*Node, error)
  • func (node *Node) Add(ip net.IP, port int)
  • func (node *Node) Addr() netip.AddrPort
  • func (node *Node) Close() error
  • func (node *Node) Ping() error
  • func (node *Node) Recv(ctx context.Context) ([]byte, error)
  • func (node *Node) Send(ttl byte, msg []byte) error

Functions

func Decode

func Decode(packet, topic []byte) (ttl byte, data []byte, err error)

func Encode

func Encode(ttl byte, msg, topic []byte) []byte

Types

type Node

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

func Listen

func Listen(network, addr string, topic []byte) (*Node, error)

func (*Node) Add

func (node *Node) Add(ip net.IP, port int)

func (*Node) Addr

func (node *Node) Addr() netip.AddrPort

func (*Node) Close

func (node *Node) Close() error

func (*Node) Ping

func (node *Node) Ping() error

func (*Node) Recv

func (node *Node) Recv(ctx context.Context) ([]byte, error)

func (*Node) Send

func (node *Node) Send(ttl byte, msg []byte) error