otel

Documentation

Index

• func TracingMiddleware(tracer trace.Tracer) subscription.Middleware
• type TracedCommandHandler
  • func TraceCommands[S any](inner command.CommandHandler[S], tracer trace.Tracer, meter metric.Meter) *TracedCommandHandler[S]
  • func (t *TracedCommandHandler[S]) Handle(ctx context.Context, cmd any) (*command.Result[S], error)

Functions

func TracingMiddleware

func TracingMiddleware(tracer trace.Tracer) subscription.Middleware

TracingMiddleware creates a subscription middleware that traces event handling.

Types

type TracedCommandHandler

type TracedCommandHandler[S any] struct {
	// contains filtered or unexported fields
}

TracedCommandHandler wraps a CommandHandler with OpenTelemetry tracing and metrics.

func TraceCommands

func TraceCommands[S any](inner command.CommandHandler[S], tracer trace.Tracer, meter metric.Meter) *TracedCommandHandler[S]

TraceCommands wraps a command handler with tracing and metrics.

func (*TracedCommandHandler[S]) Handle

func (t *TracedCommandHandler[S]) Handle(ctx context.Context, cmd any) (*command.Result[S], error)