Versions in this module Expand all Collapse all v1 v1.0.0 Jul 11, 2017 Changes in this version + func GenerateCertificatesOrPanic() tls.Certificate + func SetDialTimeout(timeout time.Duration) + 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) + PresumedDead func() <-chan common.PKIidType + Probe func(peer *RemotePeer) error + Send func(msg *proto.SignedGossipMessage, peers ...*RemotePeer) + Stop func() + func NewCommInstance(s *grpc.Server, cert *tls.Certificate, idStore identity.Mapper, ...) (Comm, error) + func NewCommInstanceWithServer(port int, idMapper identity.Mapper, peerIdentity api.PeerIdentityType, ...) (Comm, error) + type ReceivedMessageImpl struct + 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
Go to main page