Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Metrics ¶
func NewMetrics ¶
type OrdererConfigFetcher ¶
type OrdererConfigFetcher interface {
OrdererConfig() (channelconfig.Orderer, bool)
}
type Receiver ¶
type Receiver interface { //应按顺序调用已排序的消息 //“messagebatches”中的每个批都将被包装成一个块。 //`pending`指示接收器中是否仍有挂起的消息。 Ordered(msg *cb.Envelope) (messageBatches [][]*cb.Envelope, pending bool) //CUT返回当前批次并开始新批次 Cut() []*cb.Envelope }
接收器定义有序广播消息的接收器
func NewReceiverImpl ¶
func NewReceiverImpl(channelID string, sharedConfigFetcher OrdererConfigFetcher, metrics *Metrics) Receiver
NewReceiverImpl基于给定的configtxorder管理器创建接收器实现
Click to show internal directories.
Click to hide internal directories.