Documentation
¶
Index ¶
Constants ¶
View Source
const ( IncomingByteRateName = "incoming-byte-rate-for-broker-" OutgoingByteRateName = "outgoing-byte-rate-for-broker-" RequestRateName = "request-rate-for-broker-" RequestSizeName = "request-size-for-broker-" RequestLatencyName = "request-latency-in-ms-for-broker-" ResponseRateName = "response-rate-for-broker-" ResponseSizeName = "response-size-for-broker-" BatchSizeName = "batch-size-for-topic-" RecordSendRateName = "record-send-rate-for-topic-" RecordsPerRequestName = "records-per-request-for-topic-" CompressionRatioName = "compression-ratio-for-topic-" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Metrics ¶ added in v1.4.0
type Metrics struct {
IncomingByteRate metrics.Gauge
OutgoingByteRate metrics.Gauge
RequestRate metrics.Gauge
RequestSize metrics.Gauge
RequestLatency metrics.Gauge
ResponseRate metrics.Gauge
ResponseSize metrics.Gauge
BatchSize metrics.Gauge
RecordSendRate metrics.Gauge
RecordsPerRequest metrics.Gauge
CompressionRatio metrics.Gauge
GoMetricsRegistry gometrics.Registry
}
func New ¶
func New(config localconfig.Kafka, metricsProvider metrics.Provider) (consensus.Consenter, *Metrics)
New creates a Kafka-based consenter. Called by orderer's main.go.
func NewMetrics ¶ added in v1.4.0
func (*Metrics) PollGoMetrics ¶ added in v1.4.0
func (m *Metrics) PollGoMetrics()
PollGoMetrics takes the current metric values from go-metrics and publishes them to the gauges exposed through go-kit's metrics.
func (*Metrics) PollGoMetricsUntilStop ¶ added in v1.4.0
PollGoMetricsUntilStop should generally be invoked on a dedicated go routine. This go routine will then invoke PollGoMetrics at the specified frequency until the stopChannel closes.
Source Files
¶
- chain.go
- channel.go
- config.go
- consenter.go
- logger.go
- metrics.go
- partitioner.go
- retry.go
Directories
Click to show internal directories.
Click to hide internal directories.