metrics

Documentation

Index

• Variables
• func CtxWithPhaseTracer(ctx context.Context, tracer *PhaseTracer) context.Context
• type PhaseTracer
  • func NewDeleteWorkerPhaseTracer() *PhaseTracer
  • func NewScanWorkerPhaseTracer() *PhaseTracer
  • func PhaseTracerFromCtx(ctx context.Context) *PhaseTracer
  • func (t *PhaseTracer) EndPhase()
  • func (t *PhaseTracer) EnterPhase(phase string)
  • func (t *PhaseTracer) Phase() string

Variables

var (
	PhaseIdle      = "idle"
	PhaseBeginTxn  = "begin_txn"
	PhaseCommitTxn = "commit_txn"
	PhaseQuery     = "query"
	PhaseCheckTTL  = "check_ttl"
	PhaseWaitRetry = "wait_retry"
	PhaseDispatch  = "dispatch"
	PhaseWaitToken = "wait_token"
	PhaseOther     = "other"
)

Phases to trace

var (
	SelectSuccessDuration = metrics.TTLQueryDuration.With(prometheus.Labels{metrics.LblSQLType: "select", metrics.LblResult: metrics.LblOK})
	SelectErrorDuration   = metrics.TTLQueryDuration.With(prometheus.Labels{metrics.LblSQLType: "select", metrics.LblResult: metrics.LblError})
	DeleteSuccessDuration = metrics.TTLQueryDuration.With(prometheus.Labels{metrics.LblSQLType: "delete", metrics.LblResult: metrics.LblOK})
	DeleteErrorDuration   = metrics.TTLQueryDuration.With(prometheus.Labels{metrics.LblSQLType: "delete", metrics.LblResult: metrics.LblError})

	ScannedExpiredRows       = metrics.TTLProcessedExpiredRowsCounter.With(prometheus.Labels{metrics.LblSQLType: "select", metrics.LblResult: metrics.LblOK})
	DeleteSuccessExpiredRows = metrics.TTLProcessedExpiredRowsCounter.With(prometheus.Labels{metrics.LblSQLType: "delete", metrics.LblResult: metrics.LblOK})
	DeleteErrorExpiredRows   = metrics.TTLProcessedExpiredRowsCounter.With(prometheus.Labels{metrics.LblSQLType: "delete", metrics.LblResult: metrics.LblError})

	RunningJobsCnt    = metrics.TTLJobStatus.With(prometheus.Labels{metrics.LblType: "running"})
	CancellingJobsCnt = metrics.TTLJobStatus.With(prometheus.Labels{metrics.LblType: "cancelling"})
)

TTL metrics

Functions

func CtxWithPhaseTracer

func CtxWithPhaseTracer(ctx context.Context, tracer *PhaseTracer) context.Context

CtxWithPhaseTracer create a new context with tracer

Types

type PhaseTracer

type PhaseTracer struct {
	// contains filtered or unexported fields
}

PhaseTracer is used to tracer the phases duration

func NewDeleteWorkerPhaseTracer

func NewDeleteWorkerPhaseTracer() *PhaseTracer

NewDeleteWorkerPhaseTracer returns a tracer for delete worker

func NewScanWorkerPhaseTracer

func NewScanWorkerPhaseTracer() *PhaseTracer

NewScanWorkerPhaseTracer returns a tracer for scan worker

func PhaseTracerFromCtx

func PhaseTracerFromCtx(ctx context.Context) *PhaseTracer

PhaseTracerFromCtx returns a tracer from a given context

func (*PhaseTracer) EndPhase

func (t *PhaseTracer) EndPhase()

EndPhase ends the current phase

func (*PhaseTracer) EnterPhase

func (t *PhaseTracer) EnterPhase(phase string)

EnterPhase enters into a new phase

func (*PhaseTracer) Phase

func (t *PhaseTracer) Phase() string

Phase returns the current phase