comm

type AggregatedSendResult []SendResult

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

type Comm interface {
	GetPKIid() common.PKIidType

	Send(msg *protoext.SignedGossipMessage, peers ...*RemotePeer)

	SendWithAck(msg *protoext.SignedGossipMessage, timeout time.Duration, minAck int, peers ...*RemotePeer) AggregatedSendResult

	Probe(peer *RemotePeer) error

	Handshake(peer *RemotePeer) (api.PeerIdentityType, error)

	Accept(common.MessageAcceptor) <-chan protoext.ReceivedMessage

	PresumedDead() <-chan common.PKIidType

	CloseConn(peer *RemotePeer)

	Stop()
}

type CommConfig struct {
	DialTimeout  time.Duration
	ConnTimeout  time.Duration
	RecvBuffSize int
	SendBuffSize int
}

type ConnConfig struct {
	RecvBuffSize int
	SendBuffSize int
}

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

type RemotePeer struct {
	Endpoint string
	PKIID    common.PKIidType
}

type SecurityAdvisor interface {
	OrgByPeerIdentity(api.PeerIdentityType) api.OrgIdentityType
}

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