Versions in this module Expand all Collapse all v1 v1.4.9 Jul 22, 2021 Changes in this version + const BatchSizeName + const CompressionRatioName + const IncomingByteRateName + const OutgoingByteRateName + const RecordSendRateName + const RecordsPerRequestName + const RequestLatencyName + const RequestRateName + const RequestSizeName + const ResponseRateName + const ResponseSizeName + type InactiveChainRegistry interface + TrackChain func(chainName string, genesisBlock *cb.Block, createChain func()) + type Metrics struct + BatchSize metrics.Gauge + CompressionRatio metrics.Gauge + GoMetricsRegistry gometrics.Registry + IncomingByteRate metrics.Gauge + LastOffsetPersisted metrics.Gauge + OutgoingByteRate metrics.Gauge + RecordSendRate metrics.Gauge + RecordsPerRequest metrics.Gauge + RequestLatency metrics.Gauge + RequestRate metrics.Gauge + RequestSize metrics.Gauge + ResponseRate metrics.Gauge + ResponseSize metrics.Gauge + func New(config localconfig.Kafka, mp metrics.Provider, healthChecker healthChecker, ...) (consensus.Consenter, *Metrics) + func NewMetrics(p metrics.Provider, registry gometrics.Registry) *Metrics + func (m *Metrics) PollGoMetrics() + func (m *Metrics) PollGoMetricsUntilStop(frequency time.Duration, stopChannel <-chan struct{})
Go to main page