p2p

Feb 17, 2024

Changes in this version

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

type Service

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

Aug 22, 2023

Changes in this version

type Service

+ func NewWithHost(p2phost host.Host, bootPeers string, snNetwork utils.Network, ...) (*Service, 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) SetProtocolHandler(pid protocol.ID, handler func(network.Stream))

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

Aug 7, 2023

Changes in this version

+ type Service struct

+ 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)