The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterInfoReceiver ¶
type ClusterInfoReceiver struct {
// contains filtered or unexported fields
}
ClusterInfoReceiver is send p2p getClusterInfo to connected peers and receive p2p responses one of peers return successful response The first version will be simplified version. it send and receive one by one.
func NewClusterInfoReceiver ¶
func NewClusterInfoReceiver(actor p2pcommon.ActorService, mf p2pcommon.MoFactory, peers []p2pcommon.RemotePeer, ttl time.Duration, req *message.GetCluster) *ClusterInfoReceiver
func (*ClusterInfoReceiver) ReceiveResp ¶
func (br *ClusterInfoReceiver) ReceiveResp(msg p2pcommon.Message, msgBody p2pcommon.MessageBody) (ret bool)
ReceiveResp must be called just in read go routine
func (*ClusterInfoReceiver) StartGet ¶
func (br *ClusterInfoReceiver) StartGet()
Source Files
Click to show internal directories.
Click to hide internal directories.