network

Documentation

Index

• Variables
• type Network
  • func NewNetwork(h host.Host) (*Network, error)
  • func (n *Network) AddrInfo() peer.AddrInfo
  • func (n *Network) Connect(p peer.AddrInfo) error
  • func (n *Network) Messages() <-chan []byte
  • func (n *Network) MultiAddrs() []string
  • func (n *Network) PeerID() peer.ID
  • func (n *Network) Peers() []peer.ID
  • func (n *Network) Publish(ctx context.Context, data []byte) error
  • func (n *Network) RegisterStreamHandler(id core.ProtocolID, handler network.StreamHandler)
  • func (n *Network) Send(ctx context.Context, protocol core.ProtocolID, p peer.ID, data []byte) error
  • func (n *Network) Start() error
  • func (n *Network) Stop() error

Variables

var ErrNilHost = errors.New("host is nil")

ErrNilHost is returned when trying to instantiate a network with a nil host

Types

type Network

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

Host wraps a libp2p host. It contains the current pubsub state. Host implements the Network interface

func NewNetwork

func NewNetwork(h host.Host) (*Network, error)

NewNetwork returns a Network

func (*Network) AddrInfo

func (n *Network) AddrInfo() peer.AddrInfo

AddrInfo returns the host's AddrInfo

func (*Network) Connect

func (n *Network) Connect(p peer.AddrInfo) error

Connect connects directly to a peer

func (*Network) Messages

func (n *Network) Messages() <-chan []byte

Messages returns the receive-only pubsub message channel

func (*Network) MultiAddrs

func (n *Network) MultiAddrs() []string

func (*Network) PeerID

func (n *Network) PeerID() peer.ID

func (*Network) Peers

func (n *Network) Peers() []peer.ID

func (*Network) Publish

func (n *Network) Publish(ctx context.Context, data []byte) error

Publish publishes some data

func (*Network) RegisterStreamHandler

func (n *Network) RegisterStreamHandler(id core.ProtocolID, handler network.StreamHandler)

RegisterStreamHandler registers a handler and protocol ID on the libp2p host

func (*Network) Send

func (n *Network) Send(ctx context.Context, protocol core.ProtocolID, p peer.ID, data []byte) error

Send opens a stream and sends data to the given peer

func (*Network) Start

func (n *Network) Start() error

Start begins pubsub by subscribing to the markets topic

func (*Network) Stop

func (n *Network) Stop() error

Stop cancels all subscriptions