etcdraft

type BlockPuller interface {
	PullBlock(seq uint64) *common.Block
	Close()
}

type Chain struct {
	BlockCreator *blockCreator
	// contains filtered or unexported fields
}

type ChainGetter interface {
	//getchain获取给定通道的链支持。
	//当给定通道的链支持时返回nil，false
	//找不到。
	GetChain(chainID string) *multichannel.ChainSupport
}

type Config struct {
	WALDir  string //<my channel>的wal数据存储在waldir/<my channel>
	SnapDir string //<my channel>的快照存储在snapdir/<my channel>
}

type Configurator interface {
	Configure(channel string, newNodes []cluster.RemoteNode)
}

type Consenter struct {
	Dialer        *cluster.PredicateDialer
	Communication cluster.Communicator
	*Dispatcher
	Chains         ChainGetter
	Logger         *flogging.FabricLogger
	EtcdRaftConfig Config
	OrdererConfig  localconfig.TopLevel
	Cert           []byte
}

type ConsenterCertificate []byte

type Dispatcher struct {
	Logger        *flogging.FabricLogger
	ChainSelector ReceiverGetter
}

type MembershipChanges struct {
	AddedNodes   []*etcdraft.Consenter
	RemovedNodes []*etcdraft.Consenter
	TotalChanges uint32
}

type MemoryStorage interface {
	raft.Storage
	Append(entries []raftpb.Entry) error
	SetHardState(st raftpb.HardState) error
	CreateSnapshot(i uint64, cs *raftpb.ConfState, data []byte) (raftpb.Snapshot, error)
	Compact(compactIndex uint64) error
	ApplySnapshot(snap raftpb.Snapshot) error
}

type MessageReceiver interface {
	//步骤将给定的步骤请求消息传递给消息接收者
	Step(req *orderer.StepRequest, sender uint64) error

	//Submit将给定的SubmitRequest消息传递给MessageReceiver
	Submit(req *orderer.SubmitRequest, sender uint64) error
}

type Options struct {
	RaftID uint64

	Clock clock.Clock

	WALDir       string
	SnapDir      string
	SnapInterval uint64

	//这主要是为测试目的而配置的。用户不是
	//应更改此。而是使用默认快照TChupentries。
	SnapshotCatchUpEntries uint64

	MemoryStorage MemoryStorage
	Logger        *flogging.FabricLogger

	TickInterval    time.Duration
	ElectionTick    int
	HeartbeatTick   int
	MaxSizePerMsg   uint64
	MaxInflightMsgs int

	RaftMetadata *etcdraft.RaftMetadata
}

type RPC interface {
	Step(dest uint64, msg *orderer.StepRequest) (*orderer.StepResponse, error)
	SendSubmit(dest uint64, request *orderer.SubmitRequest) error
}

type RaftStorage struct {
	SnapshotCatchUpEntries uint64
	// contains filtered or unexported fields
}

type ReceiverGetter interface {
	//ReceiverByChain返回messageReceiver（如果存在），否则返回nil
	ReceiverByChain(channelID string) MessageReceiver
}