Documentation ¶
Index ¶
Constants ¶
View Source
const (
CName = "common.commonspace.peermanager"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PeerManager ¶
type PeerManager interface { app.Component // GetResponsiblePeers dials or gets from cache responsible peers GetResponsiblePeers(ctx context.Context) (peers []peer.Peer, err error) // GetNodePeers dials or gets from cache node peers GetNodePeers(ctx context.Context) (peers []peer.Peer, err error) // BroadcastMessage sends message to all peers BroadcastMessage(ctx context.Context, msg drpc.Message, streamPool streampool.StreamPool) error }
type PeerManagerProvider ¶
Directories ¶
Path | Synopsis |
---|---|
Package mock_peermanager is a generated GoMock package.
|
Package mock_peermanager is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.