raftsupport

Documentation

Index

• type ClusterInfoReceiver
  • func NewClusterInfoReceiver(actor p2pcommon.ActorService, mf p2pcommon.MoFactory, ...) *ClusterInfoReceiver
  • func (br *ClusterInfoReceiver) ReceiveResp(msg p2pcommon.Message, msgBody p2pcommon.MessageBody) (ret bool)
  • func (br *ClusterInfoReceiver) StartGet()

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()