telemetry

Jun 27, 2024

Changes in this version

+ func HTTPClient() *http.Client

Sep 27, 2023

Changes in this version

+ var Enabled = true

Mar 26, 2023

Changes in this version

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

Sep 10, 2022

Changes in this version

+ 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

+ type CounterAndGauge struct

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

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

+ type CounterAndHistogram struct

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

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

Apr 30, 2022

Changes in this version

+ 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 *zap.SugaredLogger) (int, string, error)

Mar 9, 2022

Changes in this version

+ func Close() error

+ func Initialize(logger *zap.SugaredLogger)

+ func InitializeIfNeeded(enabled bool, logger *zap.SugaredLogger) bool

+ func LoggerFor(logger *zap.SugaredLogger, span *Span) *zap.SugaredLogger

+ func NewGRPCConnection(address string, maxMsgSize int, opts ...grpc.DialOption) (*grpc.ClientConn, error)

+ func NewGRPCServer(maxMsgSize int, opts ...grpc.ServerOption) *grpc.Server

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

+ type Attribute struct

+ Key string

+ Value interface{}

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

+ type ErrHandler struct

+ func (e *ErrHandler) Handle(err error)

+ type Span struct

+ OT trace.Span

+ func StartAsyncSpan(ctx context.Context, spanName string, logger *zap.SugaredLogger, ...) (context.Context, *Span, *zap.SugaredLogger)

+ func StartSpan(ctx context.Context, spanName string, logger *zap.SugaredLogger, ...) (context.Context, *Span, *zap.SugaredLogger)

+ func (s *Span) Attribute(k string, v interface{})

+ 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