network

Documentation

Index

• Constants
• Variables
• func RegisterAPI(net *Network)
• type API
  • func (api *API) Connections() (c Connections)
  • func (api *API) Peers() peer.IDSlice
  • func (api *API) PeersInStore() peer.IDSlice
  • func (api *API) Status() Status
• type Connections
• type Network
  • func NewNetwork(chain *core.BlockChain, logger log.Logger) *Network
  • func (n *Network) Connected(network network.Network, c network.Conn)
  • func (n *Network) Disconnected(_ network.Network, c network.Conn)
  • func (n *Network) Listen(network.Network, multiaddr.Multiaddr)
  • func (n *Network) ListenClose(network.Network, multiaddr.Multiaddr)
  • func (n *Network) OnStart() error
  • func (n *Network) OnStop()
• type Status

Constants

const MaxBackupBootstrapSize = 20

Variables

var ProtocolID,
	ProtocolGetBlocks,
	ProtocolState,

	TopicPeer,
	TopicBlock,
	TopicTx string

Functions

func RegisterAPI

func RegisterAPI(net *Network)

Types

type API

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

func (*API) Connections

func (api *API) Connections() (c Connections)

func (*API) Peers

func (api *API) Peers() peer.IDSlice

func (*API) PeersInStore

func (api *API) PeersInStore() peer.IDSlice

func (*API) Status

func (api *API) Status() Status

type Connections

type Connections struct {
	Num         int                      `json:"num"`
	Connections []map[string]interface{} `json:"connections"`
}

type Network

type Network struct {
	service.BaseService
	// contains filtered or unexported fields
}

func NewNetwork

func NewNetwork(chain *core.BlockChain, logger log.Logger) *Network

func (*Network) Connected

func (n *Network) Connected(network network.Network, c network.Conn)

called when a connection opened

func (*Network) Disconnected

func (n *Network) Disconnected(_ network.Network, c network.Conn)

called when a connection closed

func (*Network) Listen

func (n *Network) Listen(network.Network, multiaddr.Multiaddr)

called when network starts listening on an addr

func (*Network) ListenClose

func (n *Network) ListenClose(network.Network, multiaddr.Multiaddr)

called when network stops listening on an addr

func (*Network) OnStart

func (n *Network) OnStart() error

OnStart starts the Network. It implements service.Service.

func (*Network) OnStop

func (n *Network) OnStop()

OnStop stops the Network. It implements service.Service.

type Status

type Status struct {
	PeersInTopic peer.IDSlice `json:"peersInTopic"`
	Connections  Connections  `json:"connections"`
}