xray

Documentation

Index

• type XRaySegment
• type XRaySpanSink
  • func NewXRaySpanSink(daemonAddr string, stats *statsd.Client, commonTags map[string]string, ...) (*XRaySpanSink, error)
  • func (x *XRaySpanSink) Flush()
  • func (x *XRaySpanSink) Ingest(ssfSpan *ssf.SSFSpan) error
  • func (x *XRaySpanSink) Name() string
  • func (x *XRaySpanSink) Start(cl *trace.Client) error

Types

type XRaySegment

type XRaySegment struct {
	Name        string            `json:"name"`
	ID          string            `json:"id"`
	TraceID     string            `json:"trace_id"`
	ParentID    string            `json:"parent_id,omitempty"`
	StartTime   float64           `json:"start_time"`
	EndTime     float64           `json:"end_time"`
	SegmentType string            `json:"type,omitempty"`
	Annotations map[string]string `json:"annotations,omitempty"`
}

XRaySegment is a trace segment for X-Ray as defined by: https://docs.aws.amazon.com/xray/latest/devguide/xray-api-segmentdocuments.html

type XRaySpanSink

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

XRaySpanSink is a sink for spans to be sent to AWS X-Ray.

func NewXRaySpanSink

func NewXRaySpanSink(daemonAddr string, stats *statsd.Client, commonTags map[string]string, log *logrus.Logger) (*XRaySpanSink, error)

NewXRaySpanSink creates a new instance of a XRaySpanSink.

func (*XRaySpanSink) Flush

func (x *XRaySpanSink) Flush()

Flush doesn't need to do anything to us, so we emit metrics instead.

func (*XRaySpanSink) Ingest

func (x *XRaySpanSink) Ingest(ssfSpan *ssf.SSFSpan) error

Ingest takes in a span and passed it along to the X-Ray client after some sanity checks and improvements are made.

func (*XRaySpanSink) Name

func (x *XRaySpanSink) Name() string

Name returns this sink's name.

func (*XRaySpanSink) Start

func (x *XRaySpanSink) Start(cl *trace.Client) error

Start the sink