p2p

Documentation

Index

• type Service
  • func New(addr, userAgent string, bootPeers string, privKeyStr string, ...) (*Service, error)
  • func (s *Service) ListenAddrs() ([]multiaddr.Multiaddr, error)
  • func (s *Service) Run(ctx context.Context) error
  • func (s *Service) SubscribePeerConnectednessChanged(ctx context.Context) (<-chan event.EvtPeerConnectednessChanged, error)

Types

type Service

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

func New

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

func (*Service) ListenAddrs

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

func (*Service) Run

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

func (*Service) SubscribePeerConnectednessChanged

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