otel

Documentation

Index

• type OpenTelemetryPlugin
  • func NewOpenTelemetryPlugin(tracer trace.Tracer, propagators propagation.TextMapPropagator) *OpenTelemetryPlugin
  • func (p OpenTelemetryPlugin) HandleConnAccept(conn net.Conn) (net.Conn, bool)
  • func (p OpenTelemetryPlugin) PostWriteResponse(ctx context.Context, req *protocol.Message, res *protocol.Message, err error) error
  • func (p OpenTelemetryPlugin) PreHandleRequest(ctx context.Context, r *protocol.Message) error
  • func (p OpenTelemetryPlugin) Register(name string, rcvr interface{}, metadata string) error
  • func (p OpenTelemetryPlugin) RegisterFunction(serviceName, fname string, fn interface{}, metadata string) error
  • func (p OpenTelemetryPlugin) Unregister(name string) error
  • func (p *OpenTelemetryPlugin) WithMeter(meter metric.Meter) *OpenTelemetryPlugin
• type Recorder
  • func GetRecorder(meter metric.Meter) *Recorder

Types

type OpenTelemetryPlugin

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

func NewOpenTelemetryPlugin

func NewOpenTelemetryPlugin(tracer trace.Tracer, propagators propagation.TextMapPropagator) *OpenTelemetryPlugin

func (OpenTelemetryPlugin) HandleConnAccept

func (p OpenTelemetryPlugin) HandleConnAccept(conn net.Conn) (net.Conn, bool)

func (OpenTelemetryPlugin) PostWriteResponse

func (p OpenTelemetryPlugin) PostWriteResponse(ctx context.Context, req *protocol.Message, res *protocol.Message, err error) error

func (OpenTelemetryPlugin) PreHandleRequest

func (p OpenTelemetryPlugin) PreHandleRequest(ctx context.Context, r *protocol.Message) error

func (OpenTelemetryPlugin) Register

func (p OpenTelemetryPlugin) Register(name string, rcvr interface{}, metadata string) error

func (OpenTelemetryPlugin) RegisterFunction

func (p OpenTelemetryPlugin) RegisterFunction(serviceName, fname string, fn interface{}, metadata string) error

func (OpenTelemetryPlugin) Unregister

func (p OpenTelemetryPlugin) Unregister(name string) error

func (*OpenTelemetryPlugin) WithMeter

func (p *OpenTelemetryPlugin) WithMeter(meter metric.Meter) *OpenTelemetryPlugin

type Recorder

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

Recorder knows how to record and measure the metrics. This has the required methods to be used with the HTTP middlewares.

func GetRecorder

func GetRecorder(meter metric.Meter) *Recorder