telemetry

package
v0.0.31 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 7, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitMetrics

func InitMetrics(ctx context.Context) error

func InitSentry

func InitSentry()

InitSentry configures the global Sentry client using environment variables that are already used for the frontend:

  • SENTRY_DSN
  • SENTRY_ENVIRONMENT (falls back to APP_ENV if empty)

If SENTRY_DSN is not set, this is a no-op.

func RecordDBLocksCount

func RecordDBLocksCount(ctx context.Context, count int64)

func RecordDBLongQueriesCount

func RecordDBLongQueriesCount(ctx context.Context, count int64)

func RecordEventWorkerEventsCount

func RecordEventWorkerEventsCount(ctx context.Context, count int)

func RecordEventWorkerTickDuration

func RecordEventWorkerTickDuration(ctx context.Context, d time.Duration)

func RecordExecutorWorkerNodesCount

func RecordExecutorWorkerNodesCount(ctx context.Context, count int)

func RecordExecutorWorkerTickDuration

func RecordExecutorWorkerTickDuration(ctx context.Context, d time.Duration)

func RecordNodeRequestWorkerRequestsCount

func RecordNodeRequestWorkerRequestsCount(ctx context.Context, count int)

func RecordNodeRequestWorkerTickDuration

func RecordNodeRequestWorkerTickDuration(ctx context.Context, d time.Duration)

func RecordQueueWorkerNodesCount

func RecordQueueWorkerNodesCount(ctx context.Context, count int)

func RecordQueueWorkerTickDuration

func RecordQueueWorkerTickDuration(ctx context.Context, d time.Duration)

func RecordStuckQueueItemsCount

func RecordStuckQueueItemsCount(ctx context.Context, count int)

func RecordWorkflowCleanupWorkerTickDuration

func RecordWorkflowCleanupWorkerTickDuration(ctx context.Context, d time.Duration)

func RecordWorkflowCleanupWorkerWorkflowsCount

func RecordWorkflowCleanupWorkerWorkflowsCount(ctx context.Context, count int)

func StartPeriodicMetricsReporter

func StartPeriodicMetricsReporter()

Types

type Periodic

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

func NewPeriodic

func NewPeriodic(ctx context.Context) *Periodic

func (*Periodic) Start

func (p *Periodic) Start()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL