Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Metrics ¶ added in v1.4.0
type OrdererConfigFetcher ¶ added in v1.1.1
type OrdererConfigFetcher interface {
OrdererConfig() (channelconfig.Orderer, bool)
}
type Receiver ¶
type Receiver interface {
// Ordered should be invoked sequentially as messages are ordered
// Each batch in `messageBatches` will be wrapped into a block.
// `pending` indicates if there are still messages pending in the receiver.
Ordered(msg *cb.Envelope) (messageBatches [][]*cb.Envelope, pending bool)
// Cut returns the current batch and starts a new one
Cut() []*cb.Envelope
}
Receiver defines a sink for the ordered broadcast messages
func NewReceiverImpl ¶
func NewReceiverImpl(channelID string, sharedConfigFetcher OrdererConfigFetcher, metrics *Metrics) Receiver
NewReceiverImpl creates a Receiver implementation based on the given configtxorderer manager
Source Files
¶
- blockcutter.go
- metrics.go
Click to show internal directories.
Click to hide internal directories.