diagnostics

Documentation

Index

• Variables
• func AppendToOutgoingGRPCContext(ctx context.Context, spanContext trace.SpanContext) context.Context
• func FromContext(ctx context.Context) trace.SpanContext
• func FromGRPCContext(ctx context.Context) (trace.SpanContext, bool)
• func FromOutgoingGRPCContext(ctx context.Context) (trace.SpanContext, bool)
• func GetDefaultSpanContext(spec config.TracingSpec) trace.SpanContext
• func GetSpanContextFromGRPC(ctx context.Context, spec config.TracingSpec) trace.SpanContext
• func GetSpanContextFromRequestContext(ctx *fasthttp.RequestCtx, spec config.TracingSpec) trace.SpanContext
• func InitMetrics(appID string) error
• func NewContext(ctx context.Context, spanContext trace.SpanContext) context.Context
• func SetTracingSpanContextFromHTTPContext(next fasthttp.RequestHandler, spec config.TracingSpec) fasthttp.RequestHandler
• func SetTracingSpanContextGRPCMiddlewareStream(spec config.TracingSpec) grpc.StreamServerInterceptor
• func SetTracingSpanContextGRPCMiddlewareUnary(spec config.TracingSpec) grpc.UnaryServerInterceptor
• func SpanContextFromRequest(req *fasthttp.Request) (sc trace.SpanContext, ok bool)
• func SpanContextFromString(h string) (sc trace.SpanContext, ok bool)
• func SpanContextToRequest(sc trace.SpanContext, req *fasthttp.Request)
• func SpanContextToString(sc trace.SpanContext) string
• func StartTracingClientSpanFromGRPCContext(ctx context.Context, method string, spec config.TracingSpec) (context.Context, *trace.Span)
• func StartTracingClientSpanFromHTTPContext(ctx context.Context, req *fasthttp.Request, method string, ...) (context.Context, *trace.Span)
• func StartTracingServerSpanFromGRPCContext(ctx context.Context, method string, spec config.TracingSpec) (context.Context, *trace.Span)
• func UpdateSpanPairStatusesFromError(span *trace.Span, err error, method string)
• func UpdateSpanStatus(span *trace.Span, spanName string, code int)
• type DaprTraceContextKey

Variables

var (
	KeyServerMethod = tag.MustNewKey("grpc_server_method")
	KeyServerStatus = tag.MustNewKey("grpc_server_status")

	KeyClientMethod = tag.MustNewKey("grpc_client_method")
	KeyClientStatus = tag.MustNewKey("grpc_client_status")
)

Tag key definitions for http requests

var (
	// DefaultReportingPeriod is the default view reporting period
	DefaultReportingPeriod = 1 * time.Minute

	// DefaultMonitoring holds service monitoring metrics definitions
	DefaultMonitoring = newServiceMetrics()
	// DefaultGRPCMonitoring holds default gRPC monitoring handlers and middleswares
	DefaultGRPCMonitoring = newGRPCMetrics()
	// DefaultHTTPMonitoring holds default HTTP monitoring handlers and middleswares
	DefaultHTTPMonitoring = newHTTPMetrics()
)

Functions

func AppendToOutgoingGRPCContext

func AppendToOutgoingGRPCContext(ctx context.Context, spanContext trace.SpanContext) context.Context

AppendToOutgoingGRPCContext appends binary serialized SpanContext to the outgoing GRPC context

func FromContext

func FromContext(ctx context.Context) trace.SpanContext

FromContext returns the SpanContext stored in a context, or nil if there isn't one.

func FromGRPCContext

func FromGRPCContext(ctx context.Context) (trace.SpanContext, bool)

FromGRPCContext returns the SpanContext stored in a context, or empty if there isn't one.

func FromOutgoingGRPCContext

func FromOutgoingGRPCContext(ctx context.Context) (trace.SpanContext, bool)

FromOutgoingGRPCContext returns the SpanContext stored in a context, or empty if there isn't one.

func GetDefaultSpanContext

func GetDefaultSpanContext(spec config.TracingSpec) trace.SpanContext

GetDefaultSpanContext returns default span context when not provided by the client

func GetSpanContextFromGRPC

func GetSpanContextFromGRPC(ctx context.Context, spec config.TracingSpec) trace.SpanContext

func GetSpanContextFromRequestContext

func GetSpanContextFromRequestContext(ctx *fasthttp.RequestCtx, spec config.TracingSpec) trace.SpanContext

func InitMetrics

func InitMetrics(appID string) error

InitMetrics initializes metrics

func NewContext

func NewContext(ctx context.Context, spanContext trace.SpanContext) context.Context

NewContext returns a new context with the given SpanContext attached.

func SetTracingSpanContextFromHTTPContext

func SetTracingSpanContextFromHTTPContext(next fasthttp.RequestHandler, spec config.TracingSpec) fasthttp.RequestHandler

SetTracingSpanContextFromHTTPContext sets the trace SpanContext in the request context

func SetTracingSpanContextGRPCMiddlewareStream

func SetTracingSpanContextGRPCMiddlewareStream(spec config.TracingSpec) grpc.StreamServerInterceptor

SetTracingSpanContextGRPCMiddlewareStream sets the trace spancontext into gRPC stream

func SetTracingSpanContextGRPCMiddlewareUnary

func SetTracingSpanContextGRPCMiddlewareUnary(spec config.TracingSpec) grpc.UnaryServerInterceptor

SetTracingSpanContextGRPCMiddlewareUnary sets the trace spancontext into gRPC unary calls

func SpanContextFromRequest

func SpanContextFromRequest(req *fasthttp.Request) (sc trace.SpanContext, ok bool)

SpanContextFromRequest extracts a span context from incoming requests.

func SpanContextFromString

func SpanContextFromString(h string) (sc trace.SpanContext, ok bool)

SpanContextFromString extracts a span context from given string which got earlier from SpanContextToString format

func SpanContextToRequest

func SpanContextToRequest(sc trace.SpanContext, req *fasthttp.Request)

SpanContextToRequest modifies the given request to include traceparent and tracestate headers.

func SpanContextToString

func SpanContextToString(sc trace.SpanContext) string

SpanContextToString returns the SpanContext string representation

func StartTracingClientSpanFromGRPCContext

func StartTracingClientSpanFromGRPCContext(ctx context.Context, method string, spec config.TracingSpec) (context.Context, *trace.Span)

StartTracingClientSpanFromGRPCContext creates a client span before invoking gRPC method call

func StartTracingClientSpanFromHTTPContext

func StartTracingClientSpanFromHTTPContext(ctx context.Context, req *fasthttp.Request, method string, spec config.TracingSpec) (context.Context, *trace.Span)

StartTracingClientSpanFromHTTPContext creates a client span before invoking http method call

func StartTracingServerSpanFromGRPCContext

func StartTracingServerSpanFromGRPCContext(ctx context.Context, method string, spec config.TracingSpec) (context.Context, *trace.Span)

StartTracingServerSpanFromGRPCContext creates a span on receiving an incoming gRPC method call from remote client

func UpdateSpanPairStatusesFromError

func UpdateSpanPairStatusesFromError(span *trace.Span, err error, method string)

UpdateSpanPairStatusesFromError updates tracer span statuses based on error object

func UpdateSpanStatus

func UpdateSpanStatus(span *trace.Span, spanName string, code int)

UpdateSpanStatus updates trace span status based on response code

Types

type DaprTraceContextKey

type DaprTraceContextKey struct{}