p2p

Documentation

Index

• func GenKeyPair() (crypto.PrivKey, crypto.PubKey, peer.ID, error)
• type Service
  • func New(addr, userAgent, peers, privKeyStr string, feederNode bool, ...) (*Service, error)
  • func NewWithHost(p2phost host.Host, peers string, feederNode bool, bc *blockchain.Blockchain, ...) (*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) 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)
  • func (s *Service) WithListener(l junoSync.EventListener)

Functions

func GenKeyPair

func GenKeyPair() (crypto.PrivKey, crypto.PubKey, peer.ID, error)

Note: the curve used to generate the key pair will mostly likely change in the future.

Types

type Service

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

func New

func New(addr, userAgent, peers, privKeyStr string, feederNode bool, bc *blockchain.Blockchain, snNetwork *utils.Network,
	log utils.SimpleLogger,
) (*Service, error)

func NewWithHost

func NewWithHost(p2phost host.Host, peers string, feederNode bool, bc *blockchain.Blockchain, 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) 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)

func (*Service) WithListener

func (s *Service) WithListener(l junoSync.EventListener)