node

Documentation

Index

• Constants
• Variables
• func ConnectNode(addr ma.Multiaddr, bind int, local core.SafeLocalData) (core.Node, error)
• func CoreNode(conn net.Conn, local core.SafeLocalData) (core.Node, error)
• func DialFromStringAddr(addr string, bind int) (net.Conn, error)
• func InitManager(cfg *config.Config) (core.NodeManager, error)
• func MultiDial(addr ma.Multiaddr, bind int) (net.Conn, error)
• type Nodes
  • func NewNodes() *Nodes
  • func (n Nodes) Marshal() ([]byte, error)
  • func (n *Nodes) Unmarshal(bytes []byte) error

Constants

const (
	// AlreadyConnectedRequest ...
	AlreadyConnectedRequest = iota + 1
	// InfoRequest ...
	InfoRequest
	// LDsRequest ...
	LDsRequest
	// PeerRequest ...
	PeerRequest
)

Variables

var ErrNoData = errors.New("no data respond")

ErrNoData ...

Functions

func ConnectNode

func ConnectNode(addr ma.Multiaddr, bind int, local core.SafeLocalData) (core.Node, error)

ConnectNode ...

func CoreNode

func CoreNode(conn net.Conn, local core.SafeLocalData) (core.Node, error)

CoreNode ...

func DialFromStringAddr

func DialFromStringAddr(addr string, bind int) (net.Conn, error)

DialFromStringAddr ...

func InitManager

func InitManager(cfg *config.Config) (core.NodeManager, error)

InitManager ...

func MultiDial

func MultiDial(addr ma.Multiaddr, bind int) (net.Conn, error)

MultiDial ...

Types

type Nodes

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

Nodes ...

func NewNodes

func NewNodes() *Nodes

NewNodes ...

func (Nodes) Marshal

func (n Nodes) Marshal() ([]byte, error)

Marshal ...

func (*Nodes) Unmarshal

func (n *Nodes) Unmarshal(bytes []byte) error

Unmarshal ...