diagnostics

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 2, 2020 License: MIT Imports: 22 Imported by: 3

Documentation

Index

Constants

View Source
const (
	// CorrelationID is the header key name of correlation id for trace
	CorrelationID = "X-Correlation-ID"
)

Variables

View Source
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 DeserializeSpanContext

func DeserializeSpanContext(ctx string) trace.SpanContext

DeserializeSpanContext deserializes a span context from a string

func DeserializeSpanContextPointer

func DeserializeSpanContextPointer(ctx string) *trace.SpanContext

DeserializeSpanContextPointer deserializes a span context from a trace pointer

func InitMetrics added in v0.5.0

func InitMetrics(appID string) error

InitMetrics initializes metrics

func ProjectStatusCode added in v0.5.0

func ProjectStatusCode(code int) int32

func SerializeSpanContext

func SerializeSpanContext(ctx trace.SpanContext) string

SerializeSpanContext serializes a span context into a simple string

func TraceSpanFromFastHTTPContext

func TraceSpanFromFastHTTPContext(c *fasthttp.RequestCtx, spec config.TracingSpec) (TracerSpan, TracerSpan)

TraceSpanFromFastHTTPContext creates a tracing span form a fasthttp request context

func TraceSpanFromFastHTTPRequest added in v0.5.0

func TraceSpanFromFastHTTPRequest(r *fasthttp.Request, spec config.TracingSpec) (TracerSpan, TracerSpan)

TraceSpanFromFastHTTPRequest creates a tracing span form a fasthttp request

func TracingGRPCMiddlewareStream added in v0.5.0

func TracingGRPCMiddlewareStream(spec config.TracingSpec) grpc_go.StreamServerInterceptor

TracingGRPCMiddlewareStream plugs tracer into gRPC stream

func TracingGRPCMiddlewareUnary

func TracingGRPCMiddlewareUnary(spec config.TracingSpec) grpc_go.UnaryServerInterceptor

TracingGRPCMiddlewareUnary plugs tracer into gRPC unary calls

func TracingHTTPMiddleware

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

TracingHTTPMiddleware plugs tracer into fasthttp pipeline

func TracingSpanFromGRPCContext

func TracingSpanFromGRPCContext(c context.Context, req interface{}, method string, spec config.TracingSpec) (TracerSpan, TracerSpan)

TracingSpanFromGRPCContext creates a span from an incoming gRPC method call

func UpdateSpanPairStatusesFromError added in v0.5.0

func UpdateSpanPairStatusesFromError(span, spanc TracerSpan, err error, method string)

UpdateSpanPairStatusesFromError updates tracer span statuses based on error object

func UpdateSpanPairStatusesFromHTTPResponse added in v0.5.0

func UpdateSpanPairStatusesFromHTTPResponse(span, spanc TracerSpan, resp *fasthttp.Response)

UpdateSpanPairStatusesFromHTTPResponse updates tracer span statuses based on HTTP response

Types

type TracerSpan

type TracerSpan struct {
	Context     context.Context
	Span        *trace.Span
	SpanContext *trace.SpanContext
}

TracerSpan defines a tracing span that a tracer users to keep track of call scopes

Directories

Path Synopsis
mocks
Package mock_helloworld is a generated GoMock package.
Package mock_helloworld is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL