Versions in this module Expand all Collapse all v1 v1.4.9 Jul 22, 2021 Changes in this version + type Config struct + AliveExpirationCheckInterval time.Duration + AliveExpirationTimeout time.Duration + AliveTimeInterval time.Duration + BindPort int + BootstrapPeers []string + ConnTimeout time.Duration + DialTimeout time.Duration + DigestWaitTime time.Duration + ExternalEndpoint string + ID string + InternalEndpoint string + MaxBlockCountToStore int + MaxPropagationBurstLatency time.Duration + MaxPropagationBurstSize int + MsgExpirationTimeout time.Duration + PropagateIterations int + PropagatePeerNum int + PublishCertPeriod time.Duration + PublishStateInfoInterval time.Duration + PullInterval time.Duration + PullPeerNum int + ReconnectInterval time.Duration + RecvBuffSize int + RequestStateInfoInterval time.Duration + RequestWaitTime time.Duration + ResponseWaitTime time.Duration + SendBuffSize int + SkipBlockVerification bool + TLSCerts *common.TLSCertificates + TimeForMembershipTracker time.Duration + type Gossip interface + Accept func(acceptor common.MessageAcceptor, passThrough bool) (<-chan *proto.GossipMessage, <-chan proto.ReceivedMessage) + Gossip func(msg *proto.GossipMessage) + IdentityInfo func() api.PeerIdentitySet + IsInMyOrg func(member discovery.NetworkMember) bool + JoinChan func(joinMsg api.JoinChannelMessage, chainID common.ChainID) + LeaveChan func(chainID common.ChainID) + PeerFilter func(channel common.ChainID, messagePredicate api.SubChannelSelectionCriteria) (filter.RoutingFilter, error) + Peers func() []discovery.NetworkMember + PeersOfChannel func(common.ChainID) []discovery.NetworkMember + SelfChannelInfo func(common.ChainID) *proto.SignedGossipMessage + SelfMembershipInfo func() discovery.NetworkMember + Send func(msg *proto.GossipMessage, peers ...*comm.RemotePeer) + SendByCriteria func(*proto.SignedGossipMessage, SendCriteria) error + Stop func() + SuspectPeers func(s api.PeerSuspector) + UpdateChaincodes func(chaincode []*proto.Chaincode, chainID common.ChainID) + UpdateLedgerHeight func(height uint64, chainID common.ChainID) + UpdateMetadata func(metadata []byte) + func NewGossipService(conf *Config, s *grpc.Server, sa api.SecurityAdvisor, ...) Gossip + type SendCriteria struct + Channel common.ChainID + IsEligible filter.RoutingFilter + MaxPeers int + MinAck int + Timeout time.Duration + func (sc SendCriteria) String() string