package xrayserver

import "gocloud.dev/server/xrayserver"

Package xrayserver provides the diagnostic hooks for a server using ADOT collector.

Index ¶

• Variables
• func NewMeterProvider(ctx context.Context, reader sdkmetric.Reader) (*sdkmetric.MeterProvider, func(), error)
• func NewMetricsReader(ctx context.Context) (sdkmetric.Reader, error)
• func NewRequestLogger() *requestlog.NCSALogger
• func NewResource(ctx context.Context) (*resource.Resource, error)
• func NewTextMapPropagator() *xray.Propagator
• func NewTraceExporter(ctx context.Context) (sdktrace.SpanExporter, error)
• func NewTraceProvider(ctx context.Context, exp sdktrace.SpanExporter, sampler sdktrace.Sampler) (*sdktrace.TracerProvider, func(), error)
• func NewTraceSampler() sdktrace.Sampler

Variables ¶

var MetricsSet = wire.NewSet(
	NewMetricsReader,
	NewMeterProvider,
	wire.Bind(new(metric.MeterProvider), new(*sdkmetric.MeterProvider)),
)

MetricsSet is a Wire provider set that provides the open telemetry metrics provider given the exporter.

var Set = wire.NewSet(
	server.Set,
	TracesSet,
	MetricsSet,

	NewRequestLogger,
	wire.Bind(new(requestlog.Logger), new(*requestlog.NCSALogger)),
)

Set is a Wire provider set that provides the diagnostic hooks for *server.Server using aws specific formats outlined here https://aws-otel.github.io/docs/getting-started/go-sdk/manual-instr.

var TracesSet = wire.NewSet(
	NewTextMapPropagator,
	wire.Bind(new(propagation.TextMapPropagator), new(*xray.Propagator)),
	NewTraceSampler,
	NewTraceExporter,
	NewTraceProvider,
	wire.Bind(new(trace.TracerProvider), new(*sdktrace.TracerProvider)),
)

TracesSet is a Wire provider set that provides the open telemetry trace provider given the exporter.

Functions ¶

func NewMeterProvider ¶

func NewMeterProvider(ctx context.Context, reader sdkmetric.Reader) (*sdkmetric.MeterProvider, func(), error)

NewMeterProvider returns a new metric provider for our service to utilise.

The second return value is a Wire cleanup function that calls Close on the provider.

func NewMetricsReader ¶

func NewMetricsReader(ctx context.Context) (sdkmetric.Reader, error)

func NewRequestLogger ¶

func NewRequestLogger() *requestlog.NCSALogger

NewRequestLogger returns a request logger that sends entries to stdout.

func NewResource ¶

func NewResource(ctx context.Context) (*resource.Resource, error)

func NewTextMapPropagator ¶

func NewTextMapPropagator() *xray.Propagator

func NewTraceExporter ¶

func NewTraceExporter(ctx context.Context) (sdktrace.SpanExporter, error)

func NewTraceProvider ¶

func NewTraceProvider(ctx context.Context, exp sdktrace.SpanExporter, sampler sdktrace.Sampler) (*sdktrace.TracerProvider, func(), error)

NewTraceProvider returns a new trace provider for our service to utilise.

The second return value is a Wire cleanup function that calls Close on the provider.

func NewTraceSampler ¶

func NewTraceSampler() sdktrace.Sampler

NewTraceSampler returns a new OpenTelemetry trace sampler.

Source Files ¶

server.go