p2p

Documentation

Index

• type Service
  • func New(addr, userAgent, bootPeers, privKeyStr string, snNetwork utils.Network, ...) (*Service, error)
  • func NewWithHost(p2phost host.Host, bootPeers string, snNetwork utils.Network, ...) (*Service, error)
  • func (s *Service) ListenAddrs() ([]multiaddr.Multiaddr, error)
  • func (s *Service) NewStream(ctx context.Context, pids ...protocol.ID) (network.Stream, error)
  • func (s *Service) PublishOnTopic(topic string, data []byte) error
  • func (s *Service) Run(ctx context.Context) error
  • func (s *Service) SetProtocolHandler(pid protocol.ID, handler func(network.Stream))
  • func (s *Service) SubscribePeerConnectednessChanged(ctx context.Context) (<-chan event.EvtPeerConnectednessChanged, error)
  • func (s *Service) SubscribeToTopic(topic string) (chan []byte, func(), error)

Types

type Service

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

func New

func New(addr, userAgent, bootPeers, privKeyStr string, snNetwork utils.Network, log utils.SimpleLogger) (*Service, error)

func NewWithHost

func NewWithHost(p2phost host.Host, bootPeers string, snNetwork utils.Network, log utils.SimpleLogger) (*Service, error)

func (*Service) ListenAddrs

func (s *Service) ListenAddrs() ([]multiaddr.Multiaddr, error)

func (*Service) NewStream

func (s *Service) NewStream(ctx context.Context, pids ...protocol.ID) (network.Stream, error)

NewStream creates a bidirectional connection to a random peer that implements a set of protocol ids

func (*Service) PublishOnTopic

func (s *Service) PublishOnTopic(topic string, data []byte) error

func (*Service) Run

func (s *Service) Run(ctx context.Context) error

Run starts the p2p service. Calling any other function before run is undefined behaviour

func (*Service) SetProtocolHandler

func (s *Service) SetProtocolHandler(pid protocol.ID, handler func(network.Stream))

func (*Service) SubscribePeerConnectednessChanged

func (s *Service) SubscribePeerConnectednessChanged(ctx context.Context) (<-chan event.EvtPeerConnectednessChanged, error)

func (*Service) SubscribeToTopic

func (s *Service) SubscribeToTopic(topic string) (chan []byte, func(), error)