middleware

Documentation

Index

• Constants
• func Addr(ctx context.Context) (addr string)
• func TracerProvider(url string, withK8SSource bool) (*traceSdk.TracerProvider, error)
• type JaegerClientMiddleware
  • func NewJaegerClientMiddleware() *JaegerClientMiddleware
  • func (jcm *JaegerClientMiddleware) StreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (grpc.ClientStream, error)
  • func (jcm *JaegerClientMiddleware) UnaryClientInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error
• type JaegerIDGenerator
  • func (gen *JaegerIDGenerator) NewIDs(ctx context.Context) (trace.TraceID, trace.SpanID)
  • func (gen *JaegerIDGenerator) NewSpanID(ctx context.Context, traceID trace.TraceID) trace.SpanID
• type JaegerMiddleOptionFunc
• type JaegerServerMiddleware
  • func NewJaegerServerMiddleware() *JaegerServerMiddleware
  • func (jsm *JaegerServerMiddleware) StreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (jsm *JaegerServerMiddleware) UnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type MetaData
• type Options
  • func DefaultOptions() Options

Constants

const (
	CurrentSpanContext = "current-span-context"
)

Functions

func Addr

func Addr(ctx context.Context) (addr string)

func TracerProvider

func TracerProvider(url string, withK8SSource bool) (*traceSdk.TracerProvider, error)

TracerProvider returns an OpenTelemetry TracerProvider configured to use the Jaeger exporter that will send spans to the provided url. The returned TracerProvider will also use a Resource configured with all the information about the application.

Types

type JaegerClientMiddleware

type JaegerClientMiddleware struct{}

func NewJaegerClientMiddleware

func NewJaegerClientMiddleware() *JaegerClientMiddleware

func (*JaegerClientMiddleware) StreamClientInterceptor

func (jcm *JaegerClientMiddleware) StreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)

func (*JaegerClientMiddleware) UnaryClientInterceptor

func (jcm *JaegerClientMiddleware) UnaryClientInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

type JaegerIDGenerator

type JaegerIDGenerator struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*JaegerIDGenerator) NewIDs

func (gen *JaegerIDGenerator) NewIDs(ctx context.Context) (trace.TraceID, trace.SpanID)

func (*JaegerIDGenerator) NewSpanID

func (gen *JaegerIDGenerator) NewSpanID(ctx context.Context, traceID trace.TraceID) trace.SpanID

type JaegerMiddleOptionFunc

type JaegerMiddleOptionFunc func(*Options)

type JaegerServerMiddleware

type JaegerServerMiddleware struct{}

func NewJaegerServerMiddleware

func NewJaegerServerMiddleware() *JaegerServerMiddleware

func (*JaegerServerMiddleware) StreamInterceptor

func (jsm *JaegerServerMiddleware) StreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (*JaegerServerMiddleware) UnaryInterceptor

func (jsm *JaegerServerMiddleware) UnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

UnaryInterceptor a service call

type MetaData

type MetaData struct {
	ClusterName string `json:"cluster_name"`
	Namespace   string `json:"namespace"`
	Deployment  string `json:"deployment"`
	PodName     string `json:"pod_name"`
	HostName    string `json:"hostname"`
	ServiceName string `json:"service_name"`
	Environment string `json:"environment"`
	TraceHeader string `json:"trace_header"`
	InputHeader string `json:"input_header"`
}

type Options

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

func DefaultOptions

func DefaultOptions() Options

DefaultOptions 优先级：自主设置->环境变量->默认设置