Versions in this module Expand all Collapse all v0 v0.0.0 May 17, 2024 Changes in this version + const DirectSendID + const ListenAddrWithIp4AndTcp + const ListenLocalhostAddrWithIp4AndTcp + var DurationBetweenReconnectAttempts = time.Duration(time.Second * 5) + var ThresholdMinimumConnectedPeers = 3 + func NewConnectableHost(h host.Host) *connectableHost + func NewDirectSender(ctx context.Context, h host.Host, ...) (*directSender, error) + func NewMemoryMessenger(ctx context.Context, mockNet mocknet.Mocknet, ...) (*networkMessenger, error) + func NewNetworkMessenger(ctx context.Context, port int, p2pPrivKey crypto.PrivKey, ...) (*networkMessenger, error) + func NewNetworkMessengerOnFreePort(ctx context.Context, p2pPrivKey crypto.PrivKey, conMgr ifconnmgr.ConnManager, ...) (*networkMessenger, error) + type ConnectableHost interface + ConnectToPeer func(ctx context.Context, address string) error + type Libp2pContext struct + func NewLibp2pContext(ctx context.Context, connHost ConnectableHost) (*Libp2pContext, error) + func (lctx *Libp2pContext) Context() context.Context + func (lctx *Libp2pContext) Host() ConnectableHost + type Message struct + func NewMessage(message *pubsub.Message) *Message + func (m *Message) Data() []byte + func (m *Message) From() []byte + func (m *Message) Key() []byte + func (m *Message) Peer() p2p.PeerID + func (m *Message) SeqNo() []byte + func (m *Message) Signature() []byte + func (m *Message) TopicIDs() []string + type PeerInfoHandler func(pInfo peerstore.PeerInfo)
Go to main page