metrics

Documentation

Index

• Constants
• func NewMetricsServer(vertex *dfv1.Vertex, opts ...Option) *metricsServer
• type Option
  • func WithHealthCheckExecutor(f func() error) Option
  • func WithLagReader(r isb.LagReader) Option
  • func WithLookbackSeconds(seconds int64) Option
  • func WithRater(r isb.Ratable) Option
  • func WithRefreshInterval(d time.Duration) Option

Constants

const (
	LabelPipeline           = "pipeline"
	LabelVertex             = "vertex"
	LabelPeriod             = "period"
	LabelVertexReplicaIndex = "replica"

	VertexProcessingRate  = "vertex_processing_rate"
	VertexPendingMessages = "vertex_pending_messages"
)

Functions

func NewMetricsServer

func NewMetricsServer(vertex *dfv1.Vertex, opts ...Option) *metricsServer

NewMetricsServer returns a Prometheus metrics server instance, which can be used to start an HTTPS service to expose Prometheus metrics.

Types

type Option

type Option func(*metricsServer)

func WithHealthCheckExecutor

func WithHealthCheckExecutor(f func() error) Option

WithHealthCheckExecutor appends a health check executor

func WithLagReader

func WithLagReader(r isb.LagReader) Option

WithLagReader sets the lag reader

func WithLookbackSeconds

func WithLookbackSeconds(seconds int64) Option

WithLookbackSeconds sets lookback seconds for avg rate and pending calculation

func WithRater

func WithRater(r isb.Ratable) Option

WithRater sets the rater

func WithRefreshInterval

func WithRefreshInterval(d time.Duration) Option

WithRefreshInterval sets how often to refresh the rate and pending