Versions in this module Expand all Collapse all v1 v1.4.9 Jul 22, 2021 Changes in this version + func ClassifyError(err error) cb.Status + type ChannelSupport interface + type ChannelSupportRegistrar interface + BroadcastChannelSupport func(msg *cb.Envelope) (*cb.ChannelHeader, bool, ChannelSupport, error) + type Consenter interface + Configure func(config *cb.Envelope, configSeq uint64) error + Order func(env *cb.Envelope, configSeq uint64) error + WaitReady func() error + type Handler struct + Metrics *Metrics + SupportRegistrar ChannelSupportRegistrar + func (bh *Handler) Handle(srv ab.AtomicBroadcast_BroadcastServer) error + func (bh *Handler) ProcessMessage(msg *cb.Envelope, addr string) (resp *ab.BroadcastResponse) + type Metrics struct + EnqueueDuration metrics.Histogram + ProcessedCount metrics.Counter + ValidateDuration metrics.Histogram + func NewMetrics(p metrics.Provider) *Metrics + type MetricsTracker struct + ChannelID string + EnqueueStartTime time.Time + Metrics *Metrics + TxType string + ValidateDuration time.Duration + ValidateStartTime time.Time + func (mt *MetricsTracker) BeginEnqueue() + func (mt *MetricsTracker) BeginValidate() + func (mt *MetricsTracker) EndValidate() + func (mt *MetricsTracker) Record(resp *ab.BroadcastResponse)
Go to main page