blockcutter

Documentation

Index

• type Metrics
  • func NewMetrics(p metrics.Provider) *Metrics
• type OrdererConfigFetcher
• type Receiver
  • func NewReceiverImpl(channelID string, sharedConfigFetcher OrdererConfigFetcher, metrics *Metrics) Receiver

Types

type Metrics

type Metrics struct {
	BlockFillDuration metrics.Histogram
}

func NewMetrics

func NewMetrics(p metrics.Provider) *Metrics

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管理器创建接收器实现