metrics

Documentation

Index

• Constants
• Variables
• func GazconsumerCollectors() []prometheus.Collector
• func GazetteBrokerCollectors() []prometheus.Collector
• func GazetteClientCollectors() []prometheus.Collector
• func GazetteConsumerCollectors() []prometheus.Collector
• func GazretentionCollectors() []prometheus.Collector

Constants

const (
	CoalescedAppendsTotalKey          = "gazette_coalesced_appends_total"
	CommittedBytesTotalKey            = "gazette_committed_bytes_total"
	FailedCommitsTotalKey             = "gazette_failed_commits_total"
	ItemRouteDurationSecondsKey       = "gazette_item_route_duration_seconds"
	RecoveryLogRecoveredBytesTotalKey = "gazette_recoverylog_recovered_bytes_total"
)

Keys for gazette metrics.

const (
	GazretentionDeletedBytesTotalKey      = "gazretention_deleted_bytes_total"
	GazretentionDeletedFragmentsTotalKey  = "gazretention_deleted_fragments_total"
	GazretentionRetainedBytesTotalKey     = "gazretention_retained_bytes_total"
	GazretentionRetainedFragmentsTotalKey = "gazretention_retained_fragments_total"
)

Keys for gazretention metrics.

const (
	GazetteDiscardBytesTotalKey         = "gazette_discard_bytes_total"
	GazetteReadBytesTotalKey            = "gazette_read_bytes_total"
	GazetteWriteBytesTotalKey           = "gazette_write_bytes_total"
	GazetteWriteCountTotalKey           = "gazette_write_count_total"
	GazetteWriteDurationSecondsTotalKey = "gazette_write_duration_seconds_total"
	GazetteWriteFailureTotalKey         = "gazette_write_failure_total"
)

Keys for gazette.Client and gazette.WriteService metrics.

const (
	GazetteConsumerTxCountTotalKey          = "gazette_consumer_tx_count_total"
	GazetteConsumerTxMessagesTotalKey       = "gazette_consumer_tx_messages_total"
	GazetteConsumerTxSecondsTotalKey        = "gazette_consumer_tx_seconds_total"
	GazetteConsumerTxConsumeSecondsTotalKey = "gazette_consumer_tx_consume_seconds_total"
	GazetteConsumerTxStalledSecondsTotalKey = "gazette_consumer_tx_stalled_seconds_total"
	GazetteConsumerTxFlushSecondsTotalKey   = "gazette_consumer_tx_flush_seconds_total"
	GazetteConsumerTxSyncSecondsTotalKey    = "gazette_consumer_tx_sync_seconds_total"
)

Keys for consumer.Runner metrics.

const (
	GazconsumerLagBytesKey = "gazconsumer_lag_bytes"
)

Keys for gazconsumer metrics.

Variables

var (
	CoalescedAppendsTotal = prometheus.NewGauge(prometheus.GaugeOpts{
		Name: CoalescedAppendsTotalKey,
		Help: "Number of journal append requests bundled into a single write transaction.",
	})
	CommittedBytesTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: CommittedBytesTotalKey,
		Help: "Cumulative number of bytes committed.",
	})
	FailedCommitsTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: FailedCommitsTotalKey,
		Help: "Cumulative number of failed commits.",
	})
	ItemRouteDurationSeconds = prometheus.NewHistogram(prometheus.HistogramOpts{
		Name: ItemRouteDurationSecondsKey,
		Help: "Benchmarking of Runner.ItemRoute calls.",
	})
	RecoveryLogRecoveredBytesTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: RecoveryLogRecoveredBytesTotalKey,
		Help: "Cumulative number of bytes recovered.",
	})
)

Collectors for gazette metrics.

var (
	GazretentionDeletedBytesTotal = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: GazretentionDeletedBytesTotalKey,
		Help: "Cumulative number of bytes deleted.",
	}, []string{"prefix"})
	GazretentionDeletedFragmentsTotal = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: GazretentionDeletedFragmentsTotalKey,
		Help: "Cumulative number of fragments deleted.",
	}, []string{"prefix"})
	GazretentionRetainedBytesTotal = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: GazretentionRetainedBytesTotalKey,
		Help: "Cumulative number of bytes retained.",
	}, []string{"prefix"})
	GazretentionRetainedFragmentsTotal = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: GazretentionRetainedFragmentsTotalKey,
		Help: "Cumulative number of fragments retained.",
	}, []string{"prefix"})
)

Collectors for gazretention metrics.

var (
	GazetteDiscardBytesTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteDiscardBytesTotalKey,
		Help: "Cumulative number of bytes read but discarded.",
	})
	GazetteReadBytesTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteReadBytesTotalKey,
		Help: "Cumulative number of bytes read.",
	})
	GazetteWriteBytesTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteWriteBytesTotalKey,
		Help: "Cumulative number of bytes written.",
	})
	GazetteWriteCountTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteWriteCountTotalKey,
		Help: "Cumulative number of writes.",
	})
	GazetteWriteDurationTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteWriteDurationSecondsTotalKey,
		Help: "Cumulative number of seconds spent writing.",
	})
	GazetteWriteFailureTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteWriteFailureTotalKey,
		Help: "Cumulative number of write errors returned to clients.",
	})
)

Collectors for gazette.Client and gazette.WriteService metrics. TODO(rupert): Should prefix be GazetteClient-, "gazette_client_-"?

var (
	GazetteConsumerTxCountTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteConsumerTxCountTotalKey,
		Help: "Cumulative number of transactions",
	})
	GazetteConsumerTxMessagesTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteConsumerTxMessagesTotalKey,
		Help: "Cumulative number of messages.",
	})
	GazetteConsumerTxSecondsTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteConsumerTxSecondsTotalKey,
		Help: "Cumulative number of seconds processing transactions.",
	})
	GazetteConsumerTxConsumeSecondsTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteConsumerTxConsumeSecondsTotalKey,
		Help: "Cumulative number of seconds transactions were processing messages.",
	})
	GazetteConsumerTxStalledSecondsTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteConsumerTxStalledSecondsTotalKey,
		Help: "Cumulative number of seconds transactions were stalled waiting for Gazette IO.",
	})
	GazetteConsumerTxFlushSecondsTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteConsumerTxFlushSecondsTotalKey,
		Help: "Cumulative number of seconds transactions were flushing their commit.",
	})
	GazetteConsumerTxSyncSecondsTotal = prometheus.NewCounter(prometheus.CounterOpts{
		Name: GazetteConsumerTxSyncSecondsTotalKey,
		Help: "Cumulative number of seconds transactions were waiting for their commit to sync.",
	})
)

Collectors for consumer.Runner metrics.

var (
	GazconsumerLagBytes = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: GazconsumerLagBytesKey,
		Help: "Lag of the consumer on a per shard basis.",
	}, []string{"consumer"})
)

Collectors for gazconsumer metrics.

Functions

func GazconsumerCollectors

func GazconsumerCollectors() []prometheus.Collector

func GazetteBrokerCollectors

func GazetteBrokerCollectors() []prometheus.Collector

func GazetteClientCollectors

func GazetteClientCollectors() []prometheus.Collector

GazetteClientCollectors returns the metrics used by gazette.Client and gazette.WriteService.

func GazetteConsumerCollectors

func GazetteConsumerCollectors() []prometheus.Collector

GazetteConsumerCollectors returns the metrics used by the consumer package.

func GazretentionCollectors

func GazretentionCollectors() []prometheus.Collector