Versions in this module Expand all Collapse all v1 v1.4.9 Sep 30, 2020 Changes in this version + const DefConnTimeout + const DefDialTimeout + const DefRecvBuffSize + const DefSendBuffSize + func GenerateCertificatesOrPanic() tls.Certificate + type AggregatedSendResult []SendResult + func (ar AggregatedSendResult) AckCount() int + func (ar AggregatedSendResult) NackCount() int + func (ar AggregatedSendResult) String() string + type ChannelDeMultiplexer struct + func NewChannelDemultiplexer() *ChannelDeMultiplexer + func (m *ChannelDeMultiplexer) AddChannel(predicate common.MessageAcceptor) chan interface{} + func (m *ChannelDeMultiplexer) Close() + func (m *ChannelDeMultiplexer) DeMultiplex(msg interface{}) + type Comm interface + Accept func(common.MessageAcceptor) <-chan proto.ReceivedMessage + CloseConn func(peer *RemotePeer) + GetPKIid func() common.PKIidType + Handshake func(peer *RemotePeer) (api.PeerIdentityType, error) + IdentitySwitch func() <-chan common.PKIidType + PresumedDead func() <-chan common.PKIidType + Probe func(peer *RemotePeer) error + Send func(msg *proto.SignedGossipMessage, peers ...*RemotePeer) + SendWithAck func(msg *proto.SignedGossipMessage, timeout time.Duration, minAck int, ...) AggregatedSendResult + Stop func() + func NewCommInstance(s *grpc.Server, certs *common.TLSCertificates, idStore identity.Mapper, ...) (Comm, error) + type CommConfig struct + ConnTimeout time.Duration + DialTimeout time.Duration + RecvBuffSize int + SendBuffSize int + type ConnConfig struct + RecvBuffSize int + SendBuffSize int + type MockStream interface + type ReceivedMessageImpl struct + func (m *ReceivedMessageImpl) Ack(err error) + func (m *ReceivedMessageImpl) GetConnectionInfo() *proto.ConnectionInfo + func (m *ReceivedMessageImpl) GetGossipMessage() *proto.SignedGossipMessage + func (m *ReceivedMessageImpl) GetSourceEnvelope() *proto.Envelope + func (m *ReceivedMessageImpl) Respond(msg *proto.GossipMessage) + type RemotePeer struct + Endpoint string + PKIID common.PKIidType + func (p *RemotePeer) String() string + type SecurityAdvisor interface + OrgByPeerIdentity func(api.PeerIdentityType) api.OrgIdentityType + type SendResult struct + func (sr SendResult) Error() string Incompatible versions in this module v2.1.1+incompatible Jun 1, 2020
Go to main page