Documentation ¶
Index ¶
- Constants
- type AggregatedSendResult
- type ChannelDeMultiplexer
- type Comm
- type CommConfig
- type ConnConfig
- type ReceivedMessageImpl
- func (m *ReceivedMessageImpl) Ack(err error)
- func (m *ReceivedMessageImpl) GetConnectionInfo() *protoext.ConnectionInfo
- func (m *ReceivedMessageImpl) GetGossipMessage() *protoext.SignedGossipMessage
- func (m *ReceivedMessageImpl) GetSourceEnvelope() *proto.Envelope
- func (m *ReceivedMessageImpl) Respond(msg *proto.GossipMessage)
- type RemotePeer
- type SecurityAdvisor
- type SendResult
Constants ¶
View Source
const ( DefDialTimeout = time.Second * 3 DefConnTimeout = time.Second * 2 DefRecvBuffSize = 20 DefSendBuffSize = 20 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AggregatedSendResult ¶
type AggregatedSendResult []SendResult
func (AggregatedSendResult) AckCount ¶
func (ar AggregatedSendResult) AckCount() int
func (AggregatedSendResult) NackCount ¶
func (ar AggregatedSendResult) NackCount() int
func (AggregatedSendResult) String ¶
func (ar AggregatedSendResult) String() string
type ChannelDeMultiplexer ¶
type ChannelDeMultiplexer struct {
// contains filtered or unexported fields
}
func NewChannelDemultiplexer ¶
func NewChannelDemultiplexer() *ChannelDeMultiplexer
func (*ChannelDeMultiplexer) AddChannel ¶
func (m *ChannelDeMultiplexer) AddChannel(predicate common.MessageAcceptor) <-chan interface{}
func (*ChannelDeMultiplexer) Close ¶
func (m *ChannelDeMultiplexer) Close()
func (*ChannelDeMultiplexer) DeMultiplex ¶
func (m *ChannelDeMultiplexer) DeMultiplex(msg interface{})
type Comm ¶
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() }
func NewCommInstance ¶
func NewCommInstance(s *grpc.Server, certs *common.TLSCertificates, idStore identity.Mapper, peerIdentity api.PeerIdentityType, secureDialOpts api.PeerSecureDialOpts, sa api.SecurityAdvisor, commMetrics *metrics.CommMetrics, config CommConfig, dialOpts ...grpc.DialOption) (Comm, error)
type CommConfig ¶
type ConnConfig ¶
type ReceivedMessageImpl ¶
type ReceivedMessageImpl struct { *protoext.SignedGossipMessage // contains filtered or unexported fields }
func (*ReceivedMessageImpl) Ack ¶
func (m *ReceivedMessageImpl) Ack(err error)
func (*ReceivedMessageImpl) GetConnectionInfo ¶
func (m *ReceivedMessageImpl) GetConnectionInfo() *protoext.ConnectionInfo
func (*ReceivedMessageImpl) GetGossipMessage ¶
func (m *ReceivedMessageImpl) GetGossipMessage() *protoext.SignedGossipMessage
func (*ReceivedMessageImpl) GetSourceEnvelope ¶
func (m *ReceivedMessageImpl) GetSourceEnvelope() *proto.Envelope
func (*ReceivedMessageImpl) Respond ¶
func (m *ReceivedMessageImpl) Respond(msg *proto.GossipMessage)
type RemotePeer ¶
func (*RemotePeer) String ¶
func (p *RemotePeer) String() string
type SecurityAdvisor ¶
type SecurityAdvisor interface {
OrgByPeerIdentity(api.PeerIdentityType) api.OrgIdentityType
}
type SendResult ¶
type SendResult struct { RemotePeer // contains filtered or unexported fields }
func (SendResult) Error ¶
func (sr SendResult) Error() string
Click to show internal directories.
Click to hide internal directories.