telemetry

package
v0.28.0 Latest Latest
Warning

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

 Go to latest Published: Jul 9, 2026 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IntegrationSecretOperationCreate = "create"
	IntegrationSecretOperationUpdate = "update"
)

Operation values for integration secret writes.

Variables

This section is empty.

Functions

func ConfigureTestTracerProvider added in v0.26.0 

func ConfigureTestTracerProvider(exporter sdktrace.SpanExporter) func()

* ConfigureTestTracerProvider enables tracing against exporter for unit tests. * Returns a cleanup function that restores the previous tracer state.

func CriticalGRPCClientStatsHandler added in v0.26.0 

func CriticalGRPCClientStatsHandler() stats.Handler

func CriticalGRPCServerStatsHandler added in v0.26.0 

func CriticalGRPCServerStatsHandler() stats.Handler

func FinishSpan added in v0.27.0 

func FinishSpan(span trace.Span, err *error)

func GRPCGatewayDialOptions added in v0.26.0 

func GRPCGatewayDialOptions() []grpc.DialOption

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 InitTracing added in v0.26.0 

func InitTracing(ctx context.Context) error

func IsCriticalGRPCMethod added in v0.26.0 

func IsCriticalGRPCMethod(fullMethod string) bool

func IsCriticalHTTPHandler added in v0.26.0 

func IsCriticalHTTPHandler(method, path string) bool

func IsCriticalHTTPRoute added in v0.26.0 

func IsCriticalHTTPRoute(route string) bool

func MayTraceHTTPRequest added in v0.26.0 

func MayTraceHTTPRequest(r *http.Request) bool

func RecordDBLocksCount 

func RecordDBLocksCount(ctx context.Context, count int64)

func RecordDBLongQueriesCount 

func RecordDBLongQueriesCount(ctx context.Context, count int64)

func RecordDBPoolStats added in v0.26.0 

func RecordDBPoolStats(ctx context.Context, maxOpen, open, inUse, idle int64)

func RecordDBPoolWaitCount added in v0.26.0 

func RecordDBPoolWaitCount(ctx context.Context, count int64)

func RecordDBPoolWaitDuration added in v0.26.0 

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

func RecordDBRowsAffected added in v0.18.0 

func RecordDBRowsAffected(ctx context.Context, count int64, tableName, operation string)

func RecordEmailWorkerEmailProcessing added in v0.27.0 

func RecordEmailWorkerEmailProcessing(ctx context.Context, d time.Duration, emailType, outcome, reason string)

func RecordEventWorkerEventProcessing added in v0.26.0 

func RecordEventWorkerEventProcessing(ctx context.Context, d time.Duration, outcome, reason string)

func RecordEventWorkerEventsCount 

func RecordEventWorkerEventsCount(ctx context.Context, count int)

func RecordEventWorkerTickDuration 

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

func RecordExecutorWorkerExecution added in v0.26.0 

func RecordExecutorWorkerExecution(ctx context.Context, d time.Duration, outcome, reason, component string)

func RecordExecutorWorkerNodesCount 

func RecordExecutorWorkerNodesCount(ctx context.Context, count int)

func RecordExecutorWorkerTickDuration 

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

func RecordIntegrationSecretWrite added in v0.26.0 

func RecordIntegrationSecretWrite(ctx context.Context, appName, operation string)

func RecordNodeRequestWorkerRequestsCount 

func RecordNodeRequestWorkerRequestsCount(ctx context.Context, count int)

func RecordNodeRequestWorkerTickDuration 

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

func RecordPendingEventsCount added in v0.18.0 

func RecordPendingEventsCount(ctx context.Context, count int64)

func RecordPendingExecutionsCount added in v0.18.0 

func RecordPendingExecutionsCount(ctx context.Context, count int64)

func RecordQueueWorkerNodeProcessing added in v0.26.0 

func RecordQueueWorkerNodeProcessing(ctx context.Context, d time.Duration, outcome, reason string)

func RecordQueueWorkerNodesCount 

func RecordQueueWorkerNodesCount(ctx context.Context, count int)

func RecordQueueWorkerTickDuration 

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

func RecordRunFinalizerRunProcessing added in v0.26.0 

func RecordRunFinalizerRunProcessing(ctx context.Context, d time.Duration, trigger, outcome, reason string)

func RecordRunFinalizerRunsCount added in v0.26.0 

func RecordRunFinalizerRunsCount(ctx context.Context, count int)

func RecordRunFinalizerTickDuration added in v0.26.0 

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

func RecordStuckQueueItemsCount 

func RecordStuckQueueItemsCount(ctx context.Context, count int)

func RecordWebhookCleanupWorkerTickDuration added in v0.27.0 

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

func RecordWebhookCleanupWorkerWebhookProcessing added in v0.27.0 

func RecordWebhookCleanupWorkerWebhookProcessing(ctx context.Context, d time.Duration, outcome, reason string)

func RecordWebhookCleanupWorkerWebhooksCount added in v0.27.0 

func RecordWebhookCleanupWorkerWebhooksCount(ctx context.Context, count int)

func RecordWebhookProvisionerWorkerTickDuration added in v0.27.0 

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

func RecordWebhookProvisionerWorkerWebhookProcessing added in v0.27.0 

func RecordWebhookProvisionerWorkerWebhookProcessing(ctx context.Context, d time.Duration, outcome, reason, appName string)

func RecordWebhookProvisionerWorkerWebhooksCount added in v0.27.0 

func RecordWebhookProvisionerWorkerWebhooksCount(ctx context.Context, count int)

func RecordWorkflowCleanupWorkerCanvasesCount added in v0.6.0 

func RecordWorkflowCleanupWorkerCanvasesCount(ctx context.Context, count int)

func RecordWorkflowCleanupWorkerTickDuration 

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

func ShutdownTracing added in v0.26.0 

func ShutdownTracing(ctx context.Context) error

func Span added in v0.27.0 

func Span(ctx context.Context, name string, opts ...trace.SpanStartOption) (context.Context, func(*error))

Span starts a span and returns ctx plus a done callback for defer done(&err).

func StartBeacon added in v0.1.0 

func StartBeacon()

func StartPeriodicMetricsReporter 

func StartPeriodicMetricsReporter()

func StartSpan added in v0.26.0 

func StartSpan(ctx context.Context, name string, opts ...trace.SpanStartOption) (context.Context, trace.Span)

func Tracer added in v0.26.0 

func Tracer() trace.Tracer

func TracingEnabled added in v0.26.0 

func TracingEnabled() bool

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.