telemetry

package

v1.2.0 Latest Latest Go to latest Published: Apr 15, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/krateoplatformops/provider-runtime

Links

Open Source Insights

Documentation ¶

Index ¶

type Config
type Metrics
- func Setup(ctx context.Context, log logging.Logger, cfg Config) (*Metrics, func(context.Context) error, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Enabled        bool
	ServiceName    string
	ExportInterval time.Duration
}

Config controls OpenTelemetry metrics export.

type Metrics ¶

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

Metrics exposes a small set of low-cardinality counters and histograms for provider-runtime consumers.

func Setup ¶

func Setup(ctx context.Context, log logging.Logger, cfg Config) (*Metrics, func(context.Context) error, error)

Setup creates and configures an OTLP metrics pipeline.

When metrics are disabled, Setup returns a nil Metrics handle and a no-op shutdown function.

func (*Metrics) AddQueueDepth ¶

func (m *Metrics) AddQueueDepth(ctx context.Context, delta int64)

func (*Metrics) AddReconcileInFlight ¶

func (m *Metrics) AddReconcileInFlight(delta int64)

func (*Metrics) IncConnectFailure ¶

func (m *Metrics) IncConnectFailure(ctx context.Context)

func (*Metrics) IncCreateFailure ¶

func (m *Metrics) IncCreateFailure(ctx context.Context)

func (*Metrics) IncDeleteFailure ¶

func (m *Metrics) IncDeleteFailure(ctx context.Context)

func (*Metrics) IncFinalizerAddFailure ¶

func (m *Metrics) IncFinalizerAddFailure(ctx context.Context)

func (*Metrics) IncFinalizerRemoveFailure ¶

func (m *Metrics) IncFinalizerRemoveFailure(ctx context.Context)

func (*Metrics) IncGetFailure ¶

func (m *Metrics) IncGetFailure(ctx context.Context)

func (*Metrics) IncObserveFailure ¶

func (m *Metrics) IncObserveFailure(ctx context.Context)

func (*Metrics) IncReconcileErrorRequeue ¶

func (m *Metrics) IncReconcileErrorRequeue(ctx context.Context)

func (*Metrics) IncReconcileFailure ¶

func (m *Metrics) IncReconcileFailure(ctx context.Context)

func (*Metrics) IncReconcileRequeueAfter ¶

func (m *Metrics) IncReconcileRequeueAfter(ctx context.Context)

func (*Metrics) IncReconcileRequeueImmediate ¶

func (m *Metrics) IncReconcileRequeueImmediate(ctx context.Context)

func (*Metrics) IncReconcileSuccess ¶

func (m *Metrics) IncReconcileSuccess(ctx context.Context)

func (*Metrics) IncStartupFailure ¶

func (m *Metrics) IncStartupFailure(ctx context.Context)

func (*Metrics) IncStartupSuccess ¶

func (m *Metrics) IncStartupSuccess(ctx context.Context)

func (*Metrics) IncStatusUpdateFailure ¶

func (m *Metrics) IncStatusUpdateFailure(ctx context.Context)

func (*Metrics) IncUpdateFailure ¶

func (m *Metrics) IncUpdateFailure(ctx context.Context)

func (*Metrics) RecordConnectDuration ¶

func (m *Metrics) RecordConnectDuration(ctx context.Context, d time.Duration)

func (*Metrics) RecordCreateDuration ¶

func (m *Metrics) RecordCreateDuration(ctx context.Context, d time.Duration)

func (*Metrics) RecordDeleteDuration ¶

func (m *Metrics) RecordDeleteDuration(ctx context.Context, d time.Duration)

func (*Metrics) RecordFinalizerAddDuration ¶

func (m *Metrics) RecordFinalizerAddDuration(ctx context.Context, d time.Duration)

func (*Metrics) RecordFinalizerRemoveDuration ¶

func (m *Metrics) RecordFinalizerRemoveDuration(ctx context.Context, d time.Duration)

func (*Metrics) RecordGetDuration ¶

func (m *Metrics) RecordGetDuration(ctx context.Context, d time.Duration)

func (*Metrics) RecordObserveDuration ¶

func (m *Metrics) RecordObserveDuration(ctx context.Context, d time.Duration)

func (*Metrics) RecordQueueOldestItemAge ¶

func (m *Metrics) RecordQueueOldestItemAge(ctx context.Context, d time.Duration)

func (*Metrics) RecordQueueWaitDuration ¶

func (m *Metrics) RecordQueueWaitDuration(ctx context.Context, d time.Duration)

func (*Metrics) RecordQueueWorkDuration ¶

func (m *Metrics) RecordQueueWorkDuration(ctx context.Context, d time.Duration)

func (*Metrics) RecordReconcileDuration ¶

func (m *Metrics) RecordReconcileDuration(ctx context.Context, d time.Duration)

func (*Metrics) RecordStatusUpdateDuration ¶

func (m *Metrics) RecordStatusUpdateDuration(ctx context.Context, d time.Duration)

func (*Metrics) RecordUpdateDuration ¶

func (m *Metrics) RecordUpdateDuration(ctx context.Context, d time.Duration)

Source Files ¶

View all Source files

metrics.go

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