Versions in this module Expand all Collapse all v1 v1.4.6 Feb 25, 2020 Changes in this version + const Blocking + const DefAntiEntropyBatchSize + const DefAntiEntropyInterval + const DefAntiEntropyMaxRetries + const DefAntiEntropyStateResponseTimeout + const DefChannelBufferSize + const DefMaxBlockDistance + const NonBlocking + type Configuration struct + AntiEntropyBatchSize uint64 + AntiEntropyInterval time.Duration + AntiEntropyMaxRetries int + AntiEntropyStateResponseTimeout time.Duration + BlockingMode bool + ChannelBufferSize int + EnableStateTransfer bool + MaxBlockDistance int + type GossipAdapter interface + Accept func(acceptor common2.MessageAcceptor, passThrough bool) (<-chan *proto.GossipMessage, <-chan proto.ReceivedMessage) + PeersOfChannel func(common2.ChainID) []discovery.NetworkMember + Send func(msg *proto.GossipMessage, peers ...*comm.RemotePeer) + UpdateLedgerHeight func(height uint64, chainID common2.ChainID) + type GossipStateProvider interface + AddPayload func(payload *proto.Payload) error + Stop func() + func NewGossipStateProvider(chainID string, services *ServicesMediator, ledger ledgerResources, ...) GossipStateProvider + type GossipStateProviderImpl struct + func (s *GossipStateProviderImpl) AddPayload(payload *proto.Payload) error + func (s *GossipStateProviderImpl) Stop() + type MCSAdapter interface + VerifyBlock func(chainID common2.ChainID, seqNum uint64, signedBlock []byte) error + VerifyByChannel func(chainID common2.ChainID, peerIdentity api.PeerIdentityType, ...) error + type PayloadsBuffer interface + Close func() + Next func() uint64 + Pop func() *proto.Payload + Push func(payload *proto.Payload) + Ready func() chan struct{} + Size func() int + func NewPayloadsBuffer(next uint64) PayloadsBuffer + type PayloadsBufferImpl struct + func (b *PayloadsBufferImpl) Close() + func (b *PayloadsBufferImpl) Next() uint64 + func (b *PayloadsBufferImpl) Pop() *proto.Payload + func (b *PayloadsBufferImpl) Push(payload *proto.Payload) + func (b *PayloadsBufferImpl) Ready() chan struct{} + func (b *PayloadsBufferImpl) Size() int + type ServicesMediator struct Incompatible versions in this module v2.0.1+incompatible Feb 26, 2020
Go to main page