comm

type AggregatedSendResult []SendResult

type ChannelDeMultiplexer struct {
	// contains filtered or unexported fields
}

type Comm interface {

	//getpkiid返回此实例的pki id
	GetPKIid() common.PKIidType

	//发送向远程对等发送消息
	Send(msg *proto.SignedGossipMessage, peers ...*RemotePeer)

	//sendwithack向远程对等端发送消息，等待来自它们的minack的确认，或者直到某个超时结束。
	SendWithAck(msg *proto.SignedGossipMessage, timeout time.Duration, minAck int, peers ...*RemotePeer) AggregatedSendResult

	//Probe探测一个远程节点，如果响应为零，则返回nil。
	//如果不是的话也会出错。
	Probe(peer *RemotePeer) error

	//握手验证远程对等机并返回
	//（其身份，无）成功和（无，错误）
	Handshake(peer *RemotePeer) (api.PeerIdentityType, error)

	//accept返回与某个谓词匹配的其他节点发送的消息的专用只读通道。
	//来自通道的每条消息都可用于向发送者发送回复。
	Accept(common.MessageAcceptor) <-chan proto.ReceivedMessage

	//ExpertedHead返回怀疑处于脱机状态的节点终结点的只读通道
	PresumedDead() <-chan common.PKIidType

	//closeconn关闭到某个端点的连接
	CloseConn(peer *RemotePeer)

	//停止停止模块
	Stop()
}

type ReceivedMessageImpl struct {
	*proto.SignedGossipMessage
	// contains filtered or unexported fields
}

type RemotePeer struct {
	Endpoint string
	PKIID    common.PKIidType
}

type SecurityAdvisor interface {
	//orgByPeerIdentity返回给定PeerIdentityType的组织标识
	OrgByPeerIdentity(api.PeerIdentityType) api.OrgIdentityType
}

type SendResult struct {
	RemotePeer
	// contains filtered or unexported fields
}