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

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