Documentation ¶
Index ¶
- Constants
- func NewConnectableHost(h host.Host) *connectableHost
- func NewDirectSender(ctx context.Context, h host.Host, ...) (*directSender, 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
- type ChannelLoadBalancer
- type ConnectableHost
- type ConnectionMonitor
- type LocalSyncTimer
- type MutexHolder
- type OutgoingChannelLoadBalancer
- func (oplb *OutgoingChannelLoadBalancer) AddChannel(channel string) error
- func (oplb *OutgoingChannelLoadBalancer) Close() error
- func (oplb *OutgoingChannelLoadBalancer) CollectOneElementFromChannels() *SendableData
- func (oplb *OutgoingChannelLoadBalancer) GetChannelOrDefault(channel string) chan *SendableData
- func (oplb *OutgoingChannelLoadBalancer) IsInterfaceNil() bool
- func (oplb *OutgoingChannelLoadBalancer) RemoveChannel(channel string) error
- type PeerDiscovererWithSharder
- type PeerInfoHandler
- type SendableData
Constants ¶
const ( // TestListenAddrWithIp4AndTcp defines the local host listening ip v.4 address and TCP used in testing TestListenAddrWithIp4AndTcp = "/ip4/127.0.0.1/tcp/" // DirectSendID represents the protocol ID for sending and receiving direct P2P messages DirectSendID = protocol.ID("/erd/directsend/1.0.0") )
Variables ¶
This section is empty.
Functions ¶
func NewConnectableHost ¶
NewConnectableHost creates a new connectable host implementation
func NewDirectSender ¶
func NewDirectSender( ctx context.Context, h host.Host, messageHandler func(msg *pubsub.Message, fromConnectedPeer core.PeerID) error, signer p2p.SignerVerifier, ) (*directSender, error)
NewDirectSender returns a new instance of direct sender object
func NewMessage ¶
NewMessage returns a new instance of a Message object
func NewMockMessenger ¶
func NewMockMessenger( args ArgsNetworkMessenger, mockNet mocknet.Mocknet, ) (*networkMessenger, error)
NewMockMessenger creates a new sandbox testable instance of libP2P messenger It should not open ports on current machine Should be used only in testing!
func NewNetworkMessenger ¶
func NewNetworkMessenger(args ArgsNetworkMessenger) (*networkMessenger, error)
NewNetworkMessenger creates a libP2P messenger by opening a port on the current machine
Types ¶
type ArgsNetworkMessenger ¶
type ArgsNetworkMessenger struct { ListenAddress string Marshalizer p2p.Marshalizer P2pConfig config.P2PConfig SyncTimer p2p.SyncTimer PreferredPeersHolder p2p.PreferredPeersHolderHandler NodeOperationMode p2p.NodeOperation PeersRatingHandler p2p.PeersRatingHandler ConnectionWatcherType string P2pPrivateKey commonCrypto.PrivateKey P2pSingleSigner commonCrypto.SingleSigner P2pKeyGenerator commonCrypto.KeyGenerator }
ArgsNetworkMessenger defines the options used to create a p2p wrapper
type ChannelLoadBalancer ¶
type ChannelLoadBalancer interface { AddChannel(channel string) error RemoveChannel(channel string) error GetChannelOrDefault(channel string) chan *SendableData CollectOneElementFromChannels() *SendableData Close() error IsInterfaceNil() bool }
ChannelLoadBalancer defines what a load balancer that uses chans should do
type ConnectableHost ¶
type ConnectableHost interface { host.Host ConnectToPeer(ctx context.Context, address string) error AddressToPeerInfo(address string) (*peer.AddrInfo, error) IsInterfaceNil() bool }
ConnectableHost is an enhanced Host interface that has the ability to connect to a string address
type ConnectionMonitor ¶
type ConnectionMonitor interface { network.Notifiee IsConnectedToTheNetwork(netw network.Network) bool SetThresholdMinConnectedPeers(thresholdMinConnectedPeers int, netw network.Network) ThresholdMinConnectedPeers() int Close() error IsInterfaceNil() bool }
ConnectionMonitor defines the behavior of a connection monitor
type LocalSyncTimer ¶
type LocalSyncTimer struct { }
LocalSyncTimer uses the local system to provide the current time
func (*LocalSyncTimer) CurrentTime ¶
func (lst *LocalSyncTimer) CurrentTime() time.Time
CurrentTime returns the local current time
func (*LocalSyncTimer) IsInterfaceNil ¶
func (lst *LocalSyncTimer) IsInterfaceNil() bool
IsInterfaceNil returns true if there is no value under the interface
type MutexHolder ¶
type MutexHolder struct {
// contains filtered or unexported fields
}
MutexHolder holds a cache of mutexes: pairs of (key, *sync.Mutex)
func NewMutexHolder ¶
func NewMutexHolder(mutexesCapacity int) (*MutexHolder, error)
NewMutexHolder creates a new instance of MutexHolder with specified capacity.
type OutgoingChannelLoadBalancer ¶
type OutgoingChannelLoadBalancer struct {
// contains filtered or unexported fields
}
OutgoingChannelLoadBalancer is a component that evenly balances requests to be sent
func NewOutgoingChannelLoadBalancer ¶
func NewOutgoingChannelLoadBalancer() *OutgoingChannelLoadBalancer
NewOutgoingChannelLoadBalancer creates a new instance of a ChannelLoadBalancer instance
func (*OutgoingChannelLoadBalancer) AddChannel ¶
func (oplb *OutgoingChannelLoadBalancer) AddChannel(channel string) error
AddChannel adds a new channel to the throttler, if it does not exists
func (*OutgoingChannelLoadBalancer) Close ¶
func (oplb *OutgoingChannelLoadBalancer) Close() error
Close finishes all started go routines in this instance
func (*OutgoingChannelLoadBalancer) CollectOneElementFromChannels ¶
func (oplb *OutgoingChannelLoadBalancer) CollectOneElementFromChannels() *SendableData
CollectOneElementFromChannels gets the waiting object from mainChan. It is a blocking call.
func (*OutgoingChannelLoadBalancer) GetChannelOrDefault ¶
func (oplb *OutgoingChannelLoadBalancer) GetChannelOrDefault(channel string) chan *SendableData
GetChannelOrDefault fetches the required channel or the default if the channel is not present
func (*OutgoingChannelLoadBalancer) IsInterfaceNil ¶
func (oplb *OutgoingChannelLoadBalancer) IsInterfaceNil() bool
IsInterfaceNil returns true if there is no value under the interface
func (*OutgoingChannelLoadBalancer) RemoveChannel ¶
func (oplb *OutgoingChannelLoadBalancer) RemoveChannel(channel string) error
RemoveChannel removes an existing channel from the throttler
type PeerDiscovererWithSharder ¶
type PeerDiscovererWithSharder interface { p2p.PeerDiscoverer SetSharder(sharder p2p.Sharder) error }
PeerDiscovererWithSharder extends the PeerDiscoverer with the possibility to set the sharder
type PeerInfoHandler ¶
PeerInfoHandler is the signature of the handler that gets called whenever an action for a peerInfo is triggered