telemetry

Documentation

Index

• Variables
• func Close(ctx context.Context) error
• func Initialize(_ string, logger util.Logger)
• func InitializeIfNeeded(enabled bool, version string, logger util.Logger) bool
• func LoggerFor(logger util.Logger, span *Span) util.Logger
• func MetricsCounter(subsystem string, name string, help string, logger util.Logger, ...) *prometheus.CounterVec
• func MetricsGauge(subsystem string, name string, help string, logger util.Logger, ...) *prometheus.GaugeVec
• func MetricsHistogram(subsystem string, name string, help string, logger util.Logger, ...) *prometheus.HistogramVec
• func MetricsSummary(subsystem string, name string, help string, logger util.Logger) prometheus.Summary
• func RunProcess(ctx context.Context, cmd string, path string, in io.Reader, out io.Writer, ...) (int, error)
• func RunProcessSimple(ctx context.Context, cmd string, path string, logger util.Logger) (int, string, error)
• func WrapHTTPClient(cl *http.Client) *http.Client
• type Attribute
  • func (a *Attribute) ToOT() attribute.KeyValue
• type CounterAndGauge
  • func NewCounterAndGauge(subsystem string, name string, help string, logger util.Logger, ...) *CounterAndGauge
  • func (x *CounterAndGauge) Observe(labelValues ...string)
• type CounterAndHistogram
  • func NewCounterAndHistogram(subsystem string, name string, help string, logger util.Logger, ...) *CounterAndHistogram
  • func (x *CounterAndHistogram) Observe(startTime time.Time, labelValues ...string)
• type ErrHandler
  • func (e *ErrHandler) Handle(err error)
• type Span
  • func StartAsyncSpan(ctx context.Context, spanName string, logger util.Logger, opts ...any) (context.Context, *Span, util.Logger)
  • func StartSpan(ctx context.Context, spanName string, logger util.Logger, opts ...any) (context.Context, *Span, util.Logger)
  • func (s *Span) Attribute(k string, v any)
  • func (s *Span) Attributes(attrs ...*Attribute)
  • func (s *Span) Complete()
  • func (s *Span) Event(name string, attrs ...*Attribute)
  • func (s *Span) OnError(err error)
  • func (s *Span) SetHTTPStatus(code int)
  • func (s *Span) SetName(name string)
  • func (s *Span) SetStatus(status string, description string)
  • func (s *Span) SpanID() string
  • func (s *Span) String() string
  • func (s *Span) TraceID() string

Variables

var (
	Enabled = true
)

var SkipControllerMetrics = util.GetEnvBool("controller_metrics_disabled", false)

Functions

func Close

func Close(ctx context.Context) error

func Initialize

func Initialize(_ string, logger util.Logger)

func InitializeIfNeeded

func InitializeIfNeeded(enabled bool, version string, logger util.Logger) bool

func LoggerFor

func LoggerFor(logger util.Logger, span *Span) util.Logger

func MetricsCounter

func MetricsCounter(subsystem string, name string, help string, logger util.Logger, labelNames ...string) *prometheus.CounterVec

func MetricsGauge

func MetricsGauge(subsystem string, name string, help string, logger util.Logger, labelNames ...string) *prometheus.GaugeVec

func MetricsHistogram

func MetricsHistogram(subsystem string, name string, help string, logger util.Logger, labelNames ...string) *prometheus.HistogramVec

func MetricsSummary

func MetricsSummary(subsystem string, name string, help string, logger util.Logger) prometheus.Summary

func RunProcess

func RunProcess(ctx context.Context, cmd string, path string, in io.Reader, out io.Writer, er io.Writer, logger util.Logger) (int, error)

func RunProcessSimple

func RunProcessSimple(ctx context.Context, cmd string, path string, logger util.Logger) (int, string, error)

func WrapHTTPClient

func WrapHTTPClient(cl *http.Client) *http.Client

Types

type Attribute

type Attribute struct {
	Key   string `json:"key"`
	Value any    `json:"value"`
}

func (*Attribute) ToOT

func (a *Attribute) ToOT() attribute.KeyValue

type CounterAndGauge

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

func NewCounterAndGauge

func NewCounterAndGauge(subsystem string, name string, help string, logger util.Logger, labelNames ...string) *CounterAndGauge

func (*CounterAndGauge) Observe

func (x *CounterAndGauge) Observe(labelValues ...string)

type CounterAndHistogram

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

func NewCounterAndHistogram

func NewCounterAndHistogram(subsystem string, name string, help string, logger util.Logger, labelNames ...string) *CounterAndHistogram

func (*CounterAndHistogram) Observe

func (x *CounterAndHistogram) Observe(startTime time.Time, labelValues ...string)

type ErrHandler

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

func (*ErrHandler) Handle

func (e *ErrHandler) Handle(err error)

type Span

type Span struct {
	OT trace.Span
	// contains filtered or unexported fields
}

func StartAsyncSpan

func StartAsyncSpan(ctx context.Context, spanName string, logger util.Logger, opts ...any) (context.Context, *Span, util.Logger)

func StartSpan

func StartSpan(ctx context.Context, spanName string, logger util.Logger, opts ...any) (context.Context, *Span, util.Logger)

func (*Span) Attribute

func (s *Span) Attribute(k string, v any)

func (*Span) Attributes

func (s *Span) Attributes(attrs ...*Attribute)

func (*Span) Complete

func (s *Span) Complete()

Complete must be called, usually through a `defer` block.

func (*Span) Event

func (s *Span) Event(name string, attrs ...*Attribute)

func (*Span) OnError

func (s *Span) OnError(err error)

func (*Span) SetHTTPStatus

func (s *Span) SetHTTPStatus(code int)

func (*Span) SetName

func (s *Span) SetName(name string)

func (*Span) SetStatus

func (s *Span) SetStatus(status string, description string)

func (*Span) SpanID

func (s *Span) SpanID() string

func (*Span) String

func (s *Span) String() string

func (*Span) TraceID

func (s *Span) TraceID() string