node

Documentation

Index

• type Node
  • func NewNode(key *utils.PrivateKey, logger *log.Logger, config utils.Config) (*Node, error)
  • func (p *Node) AddNode(info utils.NodeInfo)
  • func (p *Node) Close()
  • func (p *Node) Handle(handler func(utils.NodeID, interface{}) interface{})
  • func (p *Node) KnownNodes() []utils.NodeInfo
  • func (p *Node) RegisterMessageType(name string, typ interface{})
  • func (p *Node) Run()
  • func (p *Node) Send(dst utils.NodeID, msg interface{}, handler func(interface{})) error

Types

type Node

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

func NewNode

func NewNode(key *utils.PrivateKey, logger *log.Logger, config utils.Config) (*Node, error)

func (*Node) AddNode

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

func (*Node) Close

func (p *Node) Close()

func (*Node) Handle

func (p *Node) Handle(handler func(utils.NodeID, interface{}) interface{})

func (*Node) KnownNodes

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

func (*Node) RegisterMessageType

func (p *Node) RegisterMessageType(name string, typ interface{})

func (*Node) Run

func (p *Node) Run()

func (*Node) Send

func (p *Node) Send(dst utils.NodeID, msg interface{}, handler func(interface{})) error