router

Documentation

Index

• type Message
• type Router
  • func NewRouter(key *utils.PrivateKey, logger *log.Logger, config utils.Config) (*Router, error)
  • func (p *Router) AddNode(info utils.NodeInfo)
  • func (p *Router) Close()
  • func (p *Router) Discover(addrs []net.UDPAddr)
  • func (p *Router) Join(group utils.NodeID)
  • func (p *Router) KnownNodes() []utils.NodeInfo
  • func (p *Router) RecvMessage() (Message, error)
  • func (p *Router) SendMessage(dst utils.NodeID, payload []byte) error

Types

type Message

type Message struct {
	ID      utils.NodeID
	Payload []byte
}

type Router

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

func NewRouter

func NewRouter(key *utils.PrivateKey, logger *log.Logger, config utils.Config) (*Router, error)

func (*Router) AddNode

func (p *Router) AddNode(info utils.NodeInfo)

func (*Router) Close

func (p *Router) Close()

func (*Router) Discover

func (p *Router) Discover(addrs []net.UDPAddr)

func (*Router) Join

func (p *Router) Join(group utils.NodeID)

func (*Router) KnownNodes

func (p *Router) KnownNodes() []utils.NodeInfo

func (*Router) RecvMessage

func (p *Router) RecvMessage() (Message, error)

func (*Router) SendMessage

func (p *Router) SendMessage(dst utils.NodeID, payload []byte) error