Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

etcdraft

package

Go to main page

Versions in this module

v1

v1.4.0

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

v1.4.0-rc2

Dec 20, 2018

v1.4.0-rc1

Dec 10, 2018

v1.3.0

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

v1.3.0-rc1

Sep 25, 2018