Versions in this module Expand all Collapse all v2 v2.3.2 Nov 21, 2021 Changes in this version + var ErrChainStopped = errors.New("chain stopped") + type BlockPullerCreator struct + ClusterVerifyBlocks ClusterVerifyBlocksFunc + func NewBlockPullerCreator(channelID string, logger *flogging.FabricLogger, ...) (*BlockPullerCreator, error) + func (creator *BlockPullerCreator) BlockPuller(configBlock *common.Block, stopChannel chan struct{}) (ChannelPuller, error) + func (creator *BlockPullerCreator) UpdateVerifierFromConfigBlock(configBlock *common.Block) error + func (creator *BlockPullerCreator) VerifyBlockSequence(blocks []*common.Block, _ string) error + type BlockPullerFactory interface + BlockPuller func(configBlock *common.Block, stopChannel chan struct{}) (ChannelPuller, error) + UpdateVerifierFromConfigBlock func(configBlock *common.Block) error + type Chain struct + func NewChain(ledgerResources LedgerResources, clusterConsenter consensus.ClusterConsenter, ...) (*Chain, error) + func (c *Chain) Halt() + func (c *Chain) Height() uint64 + func (c *Chain) IsRunning() bool + func (c *Chain) Start() + func (c *Chain) StatusReport() (types.ConsensusRelation, types.Status) + type ChainCreator interface + SwitchFollowerToChain func(chainName string) + type ChannelParticipationMetricsReporter interface + ReportConsensusRelationAndStatusMetrics func(channelID string, relation types.ConsensusRelation, status types.Status) + type ChannelPuller interface + Close func() + HeightsByEndpoints func() (map[string]uint64, error) + PullBlock func(seq uint64) *common.Block + UpdateEndpoints func(endpoints []cluster.EndpointCriteria) + type ClusterVerifyBlocksFunc func(blockBuff []*common.Block, signatureVerifier cluster.BlockVerifier) error + type LedgerResources interface + Append func(block *common.Block) error + Block func(number uint64) *common.Block + ChannelID func() string + Height func() uint64 + type Options struct + Cert []byte + HeightPollMaxInterval time.Duration + HeightPollMinInterval time.Duration + Logger *flogging.FabricLogger + PullRetryMaxInterval time.Duration + PullRetryMinInterval time.Duration + TimeAfter TimeAfter + type TimeAfter func(d time.Duration) <-chan time.Time
Go to main page