telemetry

Documentation

Index

• Constants
• Variables
• func InitExporter(ctx context.Context, opts *Options, memStore *cache.MemoryStore, ...) error
• func NewSpanFromContext(ctx context.Context, name string, opts ...trace.SpanStartOption) (context.Context, trace.Span)
• type ErrorHandleFunc
  • func (f ErrorHandleFunc) Handle(err error)
• type MetricsServer
  • func NewMetricsServer(log *logrus.Entry, registry *WrappedRegistry, port int) *MetricsServer
  • func (m *MetricsServer) Close() error
  • func (m *MetricsServer) ListenAndServe()
• type Options
• type WrappedRegistry
  • func NewWrappedRegistry(promRegistry *prom.Registry, labels ...*dto.LabelPair) *WrappedRegistry
  • func (wr *WrappedRegistry) Gather() ([]*dto.MetricFamily, error)
  • func (wr *WrappedRegistry) MustRegister(collector ...prom.Collector)
  • func (wr *WrappedRegistry) Register(collector prom.Collector) error
  • func (wr *WrappedRegistry) Unregister(collector prom.Collector) bool

Constants

const (
	ExporterInvalid uint8 = iota
	ExporterPrometheus
	ExporterJaeger
	ExporterOTLP
	ExporterStdout
)

Variables

var KeyEndpoint = attribute.Key(keyPrefix + "endpoint")

var KeyOrigin = attribute.Key(keyPrefix + "origin")

Functions

func InitExporter

func InitExporter(ctx context.Context, opts *Options, memStore *cache.MemoryStore, logEntry *logrus.Entry) error

InitExporter initialises configured metrics and/or trace exporter.

func NewSpanFromContext

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

Types

type ErrorHandleFunc

type ErrorHandleFunc func(error)

func (ErrorHandleFunc) Handle

func (f ErrorHandleFunc) Handle(err error)

type MetricsServer

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

func NewMetricsServer

func NewMetricsServer(log *logrus.Entry, registry *WrappedRegistry, port int) *MetricsServer

func (*MetricsServer) Close

func (m *MetricsServer) Close() error

func (*MetricsServer) ListenAndServe

func (m *MetricsServer) ListenAndServe()

type Options

type Options struct {
	Metrics              bool
	MetricsCollectPeriod time.Duration // internal collect for pusher configuration
	MetricsEndpoint      string
	MetricsExporter      string
	MetricsPort          int
	ServiceName          string
	Traces               bool
	TracesEndpoint       string
}

type WrappedRegistry

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

func NewWrappedRegistry

func NewWrappedRegistry(promRegistry *prom.Registry, labels ...*dto.LabelPair) *WrappedRegistry

func (*WrappedRegistry) Gather

func (wr *WrappedRegistry) Gather() ([]*dto.MetricFamily, error)

func (*WrappedRegistry) MustRegister

func (wr *WrappedRegistry) MustRegister(collector ...prom.Collector)

func (*WrappedRegistry) Register

func (wr *WrappedRegistry) Register(collector prom.Collector) error

func (*WrappedRegistry) Unregister

func (wr *WrappedRegistry) Unregister(collector prom.Collector) bool