xray

package
v2.0.8+incompatible Latest Latest
Warning

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

Go to latest
Published: Nov 30, 2019 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package xray contains unary and streaming server and client interceptors that create AWS X-Ray segments from the gRPC requests and responses and send the segments to an AWS X-ray daemon.

The server interceptor works by extracting the tracing information setup by the tracing server middleware. The tracing server middleware must be chained before adding this middleware. It creates a new segment and stores the segment in the RPC's context. User code can further configure the segment for example to set a service version or record an error.

The client interceptor works by extracing the segment from the RPC's context and creates a new sub-segment. It updates the RPC context with the latest trace information.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewStreamServer

func NewStreamServer(service, daemon string) (grpc.StreamServerInterceptor, error)

NewStreamServer is similar to NewUnaryServer except it is used for streaming endpoints.

func NewUnaryServer

func NewUnaryServer(service, daemon string) (grpc.UnaryServerInterceptor, error)

NewUnaryServer returns a server middleware that sends AWS X-Ray segments to the daemon running at the given address. It stores the request segment in the context. User code can further configure the segment for example to set a service version or record an error. It extracts the trace information from the incoming unary request metadata using the tracing middleware package. The tracing middleware must be mounted on the service.

service is the name of the service reported to X-Ray. daemon is the hostname (including port) of the X-Ray daemon collecting the segments.

User code may create child segments using the Segment NewSubsegment method for tracing requests to external services. Such segments should be closed via the Close method once the request completes. The middleware takes care of closing the top level segment. Typical usage:

if s := ctx.Value(SegKey); s != nil {
  segment := s.(*xray.Segment)
}
sub := segment.NewSubsegment("external-service")
defer sub.Close()
err := client.MakeRequest()
if err != nil {
    sub.Error = xray.Wrap(err)
}
return

An X-Ray trace is limited to 500 KB of segment data (JSON) being submitted for it. See: https://aws.amazon.com/xray/pricing/

Traces running for multiple minutes may encounter additional dynamic limits, resulting in the trace being limited to less than 500 KB. The workaround is to send less data -- fewer segments, subsegments, annotations, or metadata. And perhaps split up a single large trace into several different traces.

Here are some observations of the relationship between trace duration and the number of bytes that could be sent successfully:

  • 49 seconds: 543 KB
  • 2.4 minutes: 51 KB
  • 6.8 minutes: 14 KB
  • 1.4 hours: 14 KB

Besides those varying size limitations, a trace may be open for up to 7 days.

func StreamClient

func StreamClient(host string) grpc.StreamClientInterceptor

StreamClient is the streaming endpoint middleware equivalent for UnaryClient.

func UnaryClient

func UnaryClient(host string) grpc.UnaryClientInterceptor

UnaryClient middleware creates XRay subsegments if a segment is found in the context and stores the subsegment to the context. It also sets the trace information in the context which is used by the tracing middleware. This middleware must be mounted before the tracing middleware.

Types

type GRPCSegment

type GRPCSegment struct {
	*xray.Segment
}

GRPCSegment represents an AWS X-Ray segment document for gRPC services.

func (*GRPCSegment) RecordError

func (s *GRPCSegment) RecordError(err error)

RecordError sets Throttle, Fault, Error, and HTTP.Response.

func (*GRPCSegment) RecordRequest

func (s *GRPCSegment) RecordRequest(ctx context.Context, method string, req interface{}, namespace string)

RecordRequest traces a request.

It sets Http.Request & Namespace (ex: "remote")

func (*GRPCSegment) RecordResponse

func (s *GRPCSegment) RecordResponse(resp interface{})

RecordResponse traces a response.

Jump to

Keyboard shortcuts

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