kitex

Documentation

Index

• func BuildKitexClientInstrumenter() instrumenter.Instrumenter[rpcinfo.RPCInfo, rpcinfo.RPCInfo]
• func BuildKitexServerInstrumenter() instrumenter.Instrumenter[rpcinfo.RPCInfo, rpcinfo.RPCInfo]
• func CGIVariableToHTTPHeaderMetadata(metadata map[string]string) map[string]string
• func ClientMiddleware() endpoint.Middleware
• func Extract(ctx context.Context, metadata map[string]string) context.Context
• func Inject(ctx context.Context, metadata map[string]string)
• func ServerMiddleware() endpoint.Middleware
• func WithTraceCarrier(ctx context.Context, tc *TraceCarrier) context.Context
• type TraceCarrier
  • func TraceCarrierFromContext(ctx context.Context) *TraceCarrier
  • func (t *TraceCarrier) SetSpan(span oteltrace.Span)
  • func (t *TraceCarrier) SetTracer(tracer oteltrace.Tracer)
  • func (t *TraceCarrier) Span() oteltrace.Span
  • func (t *TraceCarrier) Tracer() oteltrace.Tracer

Functions

func BuildKitexClientInstrumenter

func BuildKitexClientInstrumenter() instrumenter.Instrumenter[rpcinfo.RPCInfo, rpcinfo.RPCInfo]

func BuildKitexServerInstrumenter

func BuildKitexServerInstrumenter() instrumenter.Instrumenter[rpcinfo.RPCInfo, rpcinfo.RPCInfo]

func CGIVariableToHTTPHeaderMetadata

func CGIVariableToHTTPHeaderMetadata(metadata map[string]string) map[string]string

func ClientMiddleware

func ClientMiddleware() endpoint.Middleware

func Extract

func Extract(ctx context.Context, metadata map[string]string) context.Context

func Inject

func Inject(ctx context.Context, metadata map[string]string)

func ServerMiddleware

func ServerMiddleware() endpoint.Middleware

func WithTraceCarrier

func WithTraceCarrier(ctx context.Context, tc *TraceCarrier) context.Context

Types

type TraceCarrier

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

func TraceCarrierFromContext

func TraceCarrierFromContext(ctx context.Context) *TraceCarrier

func (*TraceCarrier) SetSpan

func (t *TraceCarrier) SetSpan(span oteltrace.Span)

func (*TraceCarrier) SetTracer

func (t *TraceCarrier) SetTracer(tracer oteltrace.Tracer)

func (*TraceCarrier) Span

func (t *TraceCarrier) Span() oteltrace.Span

func (*TraceCarrier) Tracer

func (t *TraceCarrier) Tracer() oteltrace.Tracer