Versions in this module Expand all Collapse all v1 v1.1.66 Jun 17, 2021 v1.1.65 Jun 17, 2021 Changes in this version + const DirectSendID + const ListenAddrWithIp4AndTcp + const ListenLocalhostAddrWithIp4AndTcp + func NewConnectableHost(h host.Host) *connectableHost + func NewDirectSender(ctx context.Context, h host.Host, ...) (*directSender, error) + func NewIdentityProvider(host host.Host, networkShardingCollector p2p.NetworkShardingCollector, ...) (*identityProvider, error) + func NewMessage(msg *pubsub.Message, marshalizer p2p.Marshalizer) (*message.Message, error) + func NewMockMessenger(args ArgsNetworkMessenger, mockNet mocknet.Mocknet) (*networkMessenger, error) + func NewNetworkMessenger(args ArgsNetworkMessenger) (*networkMessenger, error) + type ArgsNetworkMessenger struct + ListenAddress string + Marshalizer p2p.Marshalizer + P2pConfig config.P2PConfig + SyncTimer p2p.SyncTimer + type ConnectableHost interface + ConnectToPeer func(ctx context.Context, address string) error + IsInterfaceNil func() bool + type ConnectionMonitor interface + IsConnectedToTheNetwork func(netw network.Network) bool + IsInterfaceNil func() bool + SetThresholdMinConnectedPeers func(thresholdMinConnectedPeers int, netw network.Network) + ThresholdMinConnectedPeers func() int + type LocalSyncTimer struct + func (lst *LocalSyncTimer) CurrentTime() time.Time + func (lst *LocalSyncTimer) IsInterfaceNil() bool + type MutexHolder struct + func NewMutexHolder(mutexesCapacity int) (*MutexHolder, error) + func (mh *MutexHolder) Get(key string) *sync.Mutex + type Option func(*networkMessenger) error + func WithAuthentication(networkShardingCollector p2p.NetworkShardingCollector, ...) Option + type PeerDiscovererWithSharder interface + SetSharder func(sharder Sharder) error + type PeerInfoHandler func(pInfo peer.AddrInfo) + type Sharder interface + ComputeEvictionList func(pidList []peer.ID) []peer.ID + Has func(pid peer.ID, list []peer.ID) bool + IsInterfaceNil func() bool