self

Documentation

Index

• Variables
• func Meter() metric.Meter
• type Metrics
  • func (m *Metrics) Aggregation(kind metric.InstrumentKind) metric.Aggregation
  • func (m *Metrics) Export(ctx context.Context, rm *metricdata.ResourceMetrics) error
  • func (Metrics) ForceFlush(context.Context) error
  • func (Metrics) Shutdown(context.Context) error
  • func (m *Metrics) Temporality(kind metric.InstrumentKind) metricdata.Temporality
• type Shutdown
  • func Setup(ctx context.Context, m collector_metrics.MetricsServiceServer, ...) (Shutdown, error)
• type Trace
  • func (m *Trace) ExportSpans(ctx context.Context, spans []trace.ReadOnlySpan) error
  • func (Trace) ForceFlush(context.Context) error
  • func (Trace) Shutdown(context.Context) error

Variables

var Resource = resource.NewWithAttributes(
	semconv.SchemaURL,
	semconv.ServiceName("requiemdb"),
)

Functions

func Meter

func Meter() metric.Meter

Meter returns metrics meter for current version of rq

Types

type Metrics

type Metrics struct {
	Collector collector_metrics.MetricsServiceServer
	// contains filtered or unexported fields
}

func (*Metrics) Aggregation

func (m *Metrics) Aggregation(kind metric.InstrumentKind) metric.Aggregation

func (*Metrics) Export

func (m *Metrics) Export(ctx context.Context, rm *metricdata.ResourceMetrics) error

func (Metrics) ForceFlush

func (Metrics) ForceFlush(context.Context) error

func (Metrics) Shutdown

func (Metrics) Shutdown(context.Context) error

func (*Metrics) Temporality

func (m *Metrics) Temporality(kind metric.InstrumentKind) metricdata.Temporality

type Shutdown

type Shutdown interface {
	Shutdown(context.Context) error
}

func Setup

func Setup(ctx context.Context, m collector_metrics.MetricsServiceServer, t collector_trace.TraceServiceServer) (Shutdown, error)

type Trace

type Trace struct {
	Collector collector_trace.TraceServiceServer
	// contains filtered or unexported fields
}

func (*Trace) ExportSpans

func (m *Trace) ExportSpans(ctx context.Context, spans []trace.ReadOnlySpan) error

func (Trace) ForceFlush

func (Trace) ForceFlush(context.Context) error

func (Trace) Shutdown

func (Trace) Shutdown(context.Context) error