kafka

Documentation

Index

• Constants
• type Metrics
  • func New(config localconfig.Kafka, metricsProvider metrics.Provider) (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{})

Constants

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-"
)

Types

type Metrics

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创建了一个基于Kafka的同意者。由订购方的main.go调用。

func NewMetrics

func NewMetrics(p metrics.Provider, registry gometrics.Registry) *Metrics

func (*Metrics) PollGoMetrics

func (m *Metrics) PollGoMetrics()

Pollgometrics从Go度量中获取当前度量值并将其发布到 通过Go Kit的度量标准暴露的仪表。

func (*Metrics) PollGoMetricsUntilStop

func (m *Metrics) PollGoMetricsUntilStop(frequency time.Duration, stopChannel <-chan struct{})

pollgometricsuntilstop通常应在专用的go例程上调用。这个例行程序 然后以指定的频率调用pollgometrics，直到stopChannel关闭。