telemetry

Documentation

Index

• func GetOTelTracerProviderOptions(oTelCollectorUrl string) ([]trace.TracerProviderOption, trace.SpanExporter, error)
• func GetOtelInstance() *otelConfig
• func ObserveActiveInstances(ctx context.Context, client client.Client, ...) error
• func ObserveDeploymentDuration(ctx context.Context, client client.Client, ...) error
• func ObserveDeploymentInterval(ctx context.Context, client client.Client, ...) error
• func SetUpKeptnMeters(meter interfaces.IMeter, mgr client.Client)
• func SetUpKeptnTaskMeters(meter interfaces.IMeter) common.KeptnMeters
• type Handler
  • func (r *Handler) GetSpan(ctx context.Context, tracer ITracer, reconcileObject client.Object, ...) (context.Context, trace.Span, error)
  • func (r *Handler) UnbindSpan(reconcileObject client.Object, phase string) error
• type ISpanHandler
• type ITracer
• type TracerFactory

Functions

func GetOTelTracerProviderOptions

func GetOTelTracerProviderOptions(oTelCollectorUrl string) ([]trace.TracerProviderOption, trace.SpanExporter, error)

func GetOtelInstance

func GetOtelInstance() *otelConfig

func ObserveActiveInstances

func ObserveActiveInstances(ctx context.Context, client client.Client, reconcileObjectList client.ObjectList, gauge metric.Int64ObservableGauge, o metric.Observer) error

func ObserveDeploymentDuration

func ObserveDeploymentDuration(ctx context.Context, client client.Client, reconcileObjectList client.ObjectList, gauge metric.Float64ObservableGauge, o metric.Observer) error

func ObserveDeploymentInterval

func ObserveDeploymentInterval(ctx context.Context, client client.Client, reconcileObjectList client.ObjectList, gauge metric.Float64ObservableGauge, o metric.Observer) error

func SetUpKeptnMeters

func SetUpKeptnMeters(meter interfaces.IMeter, mgr client.Client)

func SetUpKeptnTaskMeters

func SetUpKeptnTaskMeters(meter interfaces.IMeter) common.KeptnMeters

Types

type Handler

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

func (*Handler) GetSpan

func (r *Handler) GetSpan(ctx context.Context, tracer ITracer, reconcileObject client.Object, phase string, links ...trace.Link) (context.Context, trace.Span, error)

func (*Handler) UnbindSpan

func (r *Handler) UnbindSpan(reconcileObject client.Object, phase string) error

type ISpanHandler

type ISpanHandler interface {
	GetSpan(ctx context.Context, tracer ITracer, reconcileObject client.Object, phase string, links ...trace.Link) (context.Context, trace.Span, error)
	UnbindSpan(reconcileObject client.Object, phase string) error
}

type ITracer

type ITracer interface {
	Start(ctx context.Context, spanName string, opts ...trace.SpanStartOption) (context.Context, trace.Span)
}

type TracerFactory

type TracerFactory interface {
	GetTracer(name string) ITracer
}