Versions in this module Expand all Collapse all v2 v2.3.2 Nov 21, 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 + MaxConnectionAttempts int + MaxPropagationBurstLatency time.Duration + MaxPropagationBurstSize int + MsgExpirationFactor 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 + func GlobalConfig(endpoint string, certs *common.TLSCertificates, bootPeers ...string) (*Config, error) + type Node struct + func New(conf *Config, s *grpc.Server, sa api.SecurityAdvisor, ...) *Node + func (g *Node) Accept(acceptor common.MessageAcceptor, passThrough bool) (<-chan *pg.GossipMessage, <-chan protoext.ReceivedMessage) + func (g *Node) Gossip(msg *pg.GossipMessage) + func (g *Node) IdentityInfo() api.PeerIdentitySet + func (g *Node) IsInMyOrg(member discovery.NetworkMember) bool + func (g *Node) JoinChan(joinMsg api.JoinChannelMessage, channelID common.ChannelID) + func (g *Node) LeaveChan(channelID common.ChannelID) + func (g *Node) PeerFilter(channel common.ChannelID, messagePredicate api.SubChannelSelectionCriteria) (filter.RoutingFilter, error) + func (g *Node) Peers() []discovery.NetworkMember + func (g *Node) PeersOfChannel(channel common.ChannelID) []discovery.NetworkMember + func (g *Node) SelfChannelInfo(chain common.ChannelID) *protoext.SignedGossipMessage + func (g *Node) SelfMembershipInfo() discovery.NetworkMember + func (g *Node) Send(msg *pg.GossipMessage, peers ...*comm.RemotePeer) + func (g *Node) SendByCriteria(msg *protoext.SignedGossipMessage, criteria SendCriteria) error + func (g *Node) Stop() + func (g *Node) SuspectPeers(isSuspected api.PeerSuspector) + func (g *Node) UpdateChaincodes(chaincodes []*pg.Chaincode, channelID common.ChannelID) + func (g *Node) UpdateLedgerHeight(height uint64, channelID common.ChannelID) + func (g *Node) UpdateMetadata(md []byte) + type SendCriteria struct + Channel common.ChannelID + IsEligible filter.RoutingFilter + MaxPeers int + MinAck int + Timeout time.Duration + func (sc SendCriteria) String() string Other modules containing this package github.com/waszqt/fabric