etcdraft

Jan 28, 2021

Changes in this version

type Config

+ TickIntervalOverride string

Sep 30, 2020

Changes in this version

type ConsenterCertificate

+ ConsenterCertificate []byte

+ Logger *flogging.FabricLogger

Jul 22, 2020

Changes in this version

type PeriodicCheck

+ ReportCleared func()

Jul 17, 2019

Changes in this version

type Options

+ MigrationInit bool

Apr 11, 2019

Changes in this version

+ const BYTE

+ const DefaultEvictionSuspicion

+ const DefaultLeaderlessCheckInterval

+ const DefaultSnapshotIntervalSize

+ const GIGABYTE

+ const KILOBYTE

+ const MEGABYTE

+ const TERABYTE

+ var MaxSnapshotFiles = 5

+ func CheckConfigMetadata(metadata *etcdraft.ConfigMetadata) error

+ func ConfChange(blockMetadata *etcdraft.BlockMetadata, confState *raftpb.ConfState) *raftpb.ConfChange

+ func ConfigChannelHeader(block *common.Block) (hdr *common.ChannelHeader, err error)

+ func ListSnapshots(logger *flogging.FabricLogger, snapDir string) []uint64

+ func MetadataHasDuplication(md *etcdraft.ConfigMetadata) error

+ func NodeExists(id uint64, nodes []uint64) bool

+ func ReadBlockMetadata(blockMetadata *common.Metadata, configMetadata *etcdraft.ConfigMetadata) (*etcdraft.BlockMetadata, error)

type BlockPuller

+ HeightsByEndpoints func() (map[string]uint64, error)

type Chain

+ Metrics *Metrics

+ Node *node

+ func (c *Chain) Consensus(req *orderer.ConsensusRequest, sender uint64) error

+ func (c *Chain) MigrationStatus() migration.Status

type Config

+ EvictionSuspicion string

type Consenter

+ CreateChain func(chainName string)

+ InactiveChainRegistry InactiveChainRegistry

+ Metrics *Metrics

+ type CreateBlockPuller func() (BlockPuller, error)

+ type CreateChainCallback func()

type Dispatcher

+ func (d *Dispatcher) OnConsensus(channel string, sender uint64, request *orderer.ConsensusRequest) error

+ type InactiveChainRegistry interface

+ TrackChain func(chainName string, genesisBlock *common.Block, createChain CreateChainCallback)

+ type LedgerBlockPuller struct

+ BlockRetriever cluster.BlockRetriever

+ Height func() uint64

+ func (ledgerPuller *LedgerBlockPuller) PullBlock(seq uint64) *common.Block

type MembershipChanges

+ ConfChange *raftpb.ConfChange

+ NewBlockMetadata *etcdraft.BlockMetadata

+ NewConsenters map[uint64]*etcdraft.Consenter

+ RotatedNode uint64

+ func (mc *MembershipChanges) Changed() bool

+ func (mc *MembershipChanges) Rotated() bool

+ func (mc *MembershipChanges) String() string

type MessageReceiver

+ Consensus func(req *orderer.ConsensusRequest, sender uint64) error

+ type Metrics struct

+ ClusterSize metrics.Gauge

+ CommittedBlockNumber metrics.Gauge

+ ConfigProposalsReceived metrics.Counter

+ DataPersistDuration metrics.Histogram

+ IsLeader metrics.Gauge

+ LeaderChanges metrics.Counter

+ NormalProposalsReceived metrics.Counter

+ ProposalFailures metrics.Counter

+ SnapshotBlockNumber metrics.Gauge

+ func NewMetrics(p metrics.Provider) *Metrics

type Options

+ BlockMetadata *etcdraft.BlockMetadata

+ Cert []byte

+ Consenters map[uint64]*etcdraft.Consenter

+ EvictionSuspicion time.Duration

+ LeaderCheckInterval time.Duration

+ MaxInflightBlocks int

+ Metrics *Metrics

+ SnapshotIntervalSize uint32

+ type PeriodicCheck struct

+ CheckInterval time.Duration

+ Condition func() bool

+ Logger *flogging.FabricLogger

+ Report func(cumulativePeriod time.Duration)

+ func (pc *PeriodicCheck) Run()

+ func (pc *PeriodicCheck) Stop()

type RPC

+ SendConsensus func(dest uint64, msg *orderer.ConsensusRequest) error

Jan 9, 2019

Changes in this version

+ const DefaultSnapshotCatchUpEntries

+ func ConfigEnvelopeFromBlock(block *common.Block) (*common.Envelope, error)

+ func ConsensusMetadataFromConfigBlock(block *common.Block) (*etcdraft.Metadata, error)

+ func ConsentersToMap(consenters []*etcdraft.Consenter) map[string]struct

+ func EndpointconfigFromFromSupport(support consensus.ConsenterSupport) (*cluster.EndpointConfig, error)

+ func IsMembershipUpdate(block *common.Block, currentMetadata *etcdraft.RaftMetadata) (bool, error)

+ func LastConfigBlock(block *common.Block, support consensus.ConsenterSupport) (*common.Block, error)

+ func MembershipByCert(consenters map[uint64]*etcdraft.Consenter) map[string]struct

+ func MetadataFromConfigUpdate(update *common.ConfigUpdate) (*etcdraft.Metadata, error)

+ func MetadataFromConfigValue(configValue *common.ConfigValue) (*etcdraft.Metadata, error)

+ func RaftPeers(consenters map[uint64]*etcdraft.Consenter) []raft.Peer

+ type BlockPuller interface

+ Close func()

+ PullBlock func(seq uint64) *common.Block

type Chain

+ BlockCreator *blockCreator

+ func (c *Chain) Step(req *orderer.StepRequest, sender uint64) error

+ type ChainGetter interface

+ GetChain func(chainID string) *multichannel.ChainSupport

+ type Config struct

+ SnapDir string

+ WALDir string

+ type Configurator interface

+ Configure func(channel string, newNodes []cluster.RemoteNode)

+ type Consenter struct

+ Cert []byte

+ Chains ChainGetter

+ Communication cluster.Communicator

+ Dialer *cluster.PredicateDialer

+ EtcdRaftConfig Config

+ Logger *flogging.FabricLogger

+ OrdererConfig localconfig.TopLevel

+ func New(clusterDialer *cluster.PredicateDialer, conf *localconfig.TopLevel, ...) *Consenter

+ func (c *Consenter) HandleChain(support consensus.ConsenterSupport, metadata *common.Metadata) (consensus.Chain, error)

+ func (c *Consenter) ReceiverByChain(channelID string) MessageReceiver

+ func (c *Consenter) TargetChannel(message proto.Message) string

+ type ConsenterCertificate []byte

+ func (conCert ConsenterCertificate) IsConsenterOfChannel(configBlock *common.Block) error

+ type MembershipChanges struct

+ AddedNodes []*etcdraft.Consenter

+ RemovedNodes []*etcdraft.Consenter

+ TotalChanges uint32

+ func ComputeMembershipChanges(oldConsenters map[uint64]*etcdraft.Consenter, ...) *MembershipChanges

+ func (mc *MembershipChanges) UpdateRaftMetadataAndConfChange(raftMetadata *etcdraft.RaftMetadata) *raftpb.ConfChange

+ type MemoryStorage interface

+ Append func(entries []raftpb.Entry) error

+ ApplySnapshot func(snap raftpb.Snapshot) error

+ Compact func(compactIndex uint64) error

+ CreateSnapshot func(i uint64, cs *raftpb.ConfState, data []byte) (raftpb.Snapshot, error)

+ SetHardState func(st raftpb.HardState) error

type Options

+ MemoryStorage MemoryStorage

+ RaftMetadata *etcdraft.RaftMetadata

+ SnapDir string

+ SnapInterval uint64

+ SnapshotCatchUpEntries uint64

+ WALDir string

+ type RPC interface

+ SendSubmit func(dest uint64, request *orderer.SubmitRequest) error

+ Step func(dest uint64, msg *orderer.StepRequest) (*orderer.StepResponse, error)

+ type RaftStorage struct

+ SnapshotCatchUpEntries uint64

+ func CreateStorage(lg *flogging.FabricLogger, applied uint64, walDir string, snapDir string, ...) (*RaftStorage, error)

+ func (rs *RaftStorage) ApplySnapshot(snap raftpb.Snapshot)

+ func (rs *RaftStorage) Close() error

+ func (rs *RaftStorage) Snapshot() raftpb.Snapshot

+ func (rs *RaftStorage) Store(entries []raftpb.Entry, hardstate raftpb.HardState, snapshot raftpb.Snapshot) error

+ func (rs *RaftStorage) TakeSnapshot(i uint64, cs *raftpb.ConfState, data []byte) error

Oct 10, 2018

Changes in this version

+ type Chain struct

+ func NewChain(support consensus.ConsenterSupport, opts Options, observe chan<- uint64) (*Chain, error)

+ func (c *Chain) Configure(env *common.Envelope, configSeq uint64) error

+ func (c *Chain) Errored() <-chan struct{}

+ func (c *Chain) Halt()

+ func (c *Chain) Order(env *common.Envelope, configSeq uint64) error

+ func (c *Chain) Start()

+ func (c *Chain) Submit(req *orderer.SubmitRequest, sender uint64) error

+ func (c *Chain) WaitReady() error

+ type Dispatcher struct

+ ChainSelector ReceiverGetter

+ Logger *flogging.FabricLogger

+ func (d *Dispatcher) OnStep(channel string, sender uint64, request *orderer.StepRequest) (*orderer.StepResponse, error)

+ func (d *Dispatcher) OnSubmit(channel string, sender uint64, request *orderer.SubmitRequest) (*orderer.SubmitResponse, error)

+ type MessageReceiver interface

+ Step func(req *orderer.StepRequest, sender uint64) error

+ Submit func(req *orderer.SubmitRequest, sender uint64) error

+ type Options struct

+ Clock clock.Clock

+ ElectionTick int

+ HeartbeatTick int

+ Logger *flogging.FabricLogger

+ MaxInflightMsgs int

+ MaxSizePerMsg uint64

+ Peers []raft.Peer

+ RaftID uint64

+ Storage Storage

+ TickInterval time.Duration

+ type ReceiverGetter interface

+ ReceiverByChain func(channelID string) MessageReceiver

+ type Storage interface

+ Append func(entries []raftpb.Entry) error