Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

xray

package

Go to main page

Versions in this module

v1

v1.0.0-rc.8

Oct 4, 2018

v1.0.0-rc.4

Apr 13, 2018

v0

v0.9.4

Sep 8, 2017

Changes in this version

+ var ErrRetrieveSegment = errors.New("unable to retrieve segment")

+ type HTTPSubsegments struct

+ func (xt *HTTPSubsegments) ConnectDone(network, addr string, err error)

+ func (xt *HTTPSubsegments) ConnectStart(network, addr string)

+ func (xt *HTTPSubsegments) DNSDone(info httptrace.DNSDoneInfo)

+ func (xt *HTTPSubsegments) DNSStart(info httptrace.DNSStartInfo)

+ func (xt *HTTPSubsegments) GetConn(hostPort string)

+ func (xt *HTTPSubsegments) GotConn(info *httptrace.GotConnInfo, err error)

+ func (xt *HTTPSubsegments) GotFirstResponseByte()

+ func (xt *HTTPSubsegments) TLSHandshakeDone(connState tls.ConnectionState, err error)

+ func (xt *HTTPSubsegments) TLSHandshakeStart()

+ func (xt *HTTPSubsegments) WroteRequest(info httptrace.WroteRequestInfo)

type Segment

+ func (seg *Segment) AddAnnotation(key string, value interface{}) error

+ func (seg *Segment) AddError(err error) error

+ func (seg *Segment) AddMetadata(key string, value interface{}) error

+ func (seg *Segment) AddMetadataToNamespace(namespace string, key string, value interface{}) error

v0.9.3

Sep 1, 2017

v0.9.2

Aug 31, 2017

v0.9.0

Aug 30, 2017

Changes in this version

+ var ContextKey = new(ContextKeytype)

+ var Header = []byte(`{"format": "json", "version": 1}` + "\n")

+ func AWS(c *client.Client)

+ func AWSWithWhitelist(c *client.Client, filename string)

+ func AddAnnotation(ctx context.Context, key string, value interface{}) error

+ func AddError(ctx context.Context, err error) error

+ func AddMetadata(ctx context.Context, key string, value interface{}) error

+ func AddMetadataToNamespace(ctx context.Context, namespace string, key string, value interface{}) error

+ func Capture(ctx context.Context, name string, fn func(context.Context) error) (err error)

+ func CaptureAsync(ctx context.Context, name string, fn func(context.Context) error)

+ func Client(c *http.Client) *http.Client

+ func Configure(c Config) error

+ func DetachContext(ctx context.Context) context.Context

+ func Handler(sn SegmentNamer, h http.Handler) http.Handler

+ func NewSegmentID() string

+ func NewTraceID() string

+ func RequestWasTraced(ctx context.Context) bool

+ func RoundTripper(rt http.RoundTripper) http.RoundTripper

+ func TraceID(ctx context.Context) string

+ type CauseData struct

+ Exceptions []exception.Exception

+ Paths []string

+ WorkingDirectory string

+ type ClientTrace struct

+ func NewClientTrace(opCtx context.Context) (ct *ClientTrace, err error)

+ type Config struct

+ ContextMissingStrategy ctxmissing.Strategy

+ DaemonAddr string

+ ExceptionFormattingStrategy exception.FormattingStrategy

+ LogFormat string

+ LogLevel string

+ SamplingStrategy sampling.Strategy

+ ServiceVersion string

+ StreamingStrategy StreamingStrategy

+ type ContextKeytype int

+ type DB struct

+ func SQL(driver, dsn string) (*DB, error)

+ func (db *DB) Begin(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

+ func (db *DB) Close() error

+ func (db *DB) Driver() driver.Driver

+ func (db *DB) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (db *DB) Ping(ctx context.Context) error

+ func (db *DB) Prepare(ctx context.Context, query string) (*Stmt, error)

+ func (db *DB) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (db *DB) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (db *DB) SetConnMaxLifetime(d time.Duration)

+ func (db *DB) SetMaxIdleConns(n int)

+ func (db *DB) SetMaxOpenConns(n int)

+ func (db *DB) Stats() sql.DBStats

+ type DefaultStreamingStrategy struct

+ MaxSubsegmentCount int

+ func NewDefaultStreamingStrategy() (*DefaultStreamingStrategy, error)

+ func NewDefaultStreamingStrategyWithMaxSubsegmentCount(maxSubsegmentCount int) (*DefaultStreamingStrategy, error)

+ func (dSS *DefaultStreamingStrategy) RequiresStreaming(seg *Segment) bool

+ func (dSS *DefaultStreamingStrategy) StreamCompletedSubsegments(seg *Segment) [][]byte

+ type DynamicSegmentNamer struct

+ FallbackName string

+ RecognizedHosts string

+ func NewDynamicSegmentNamer(fallback string, recognized string) *DynamicSegmentNamer

+ func (dSN *DynamicSegmentNamer) Name(host string) string

+ type FixedSegmentNamer struct

+ FixedName string

+ func NewFixedSegmentNamer(name string) *FixedSegmentNamer

+ func (fSN *FixedSegmentNamer) Name(host string) string

+ type HTTPData struct

+ Request *RequestData

+ Response *ResponseData

+ func (d *HTTPData) GetRequest() *RequestData

+ func (d *HTTPData) GetResponse() *ResponseData

+ type HttpSubsegments struct

+ func (xt *HttpSubsegments) ConnectDone(network, addr string, err error)

+ func (xt *HttpSubsegments) ConnectStart(network, addr string)

+ func (xt *HttpSubsegments) DNSDone(info httptrace.DNSDoneInfo)

+ func (xt *HttpSubsegments) DNSStart(info httptrace.DNSStartInfo)

+ func (xt *HttpSubsegments) GetConn(hostPort string)

+ func (xt *HttpSubsegments) GotConn(info *httptrace.GotConnInfo, err error)

+ func (xt *HttpSubsegments) GotFirstResponseByte()

+ func (xt *HttpSubsegments) TLSHandshakeDone(connState tls.ConnectionState, err error)

+ func (xt *HttpSubsegments) TLSHandshakeStart()

+ func (xt *HttpSubsegments) WroteRequest(info httptrace.WroteRequestInfo)

+ type RequestData struct

+ ClientIP string

+ Method string

+ Traced bool

+ URL string

+ UserAgent string

+ XForwardedFor bool

+ type ResponseData struct

+ ContentLength int

+ Status int

+ type SQLData struct

+ ConnectionString string

+ DatabaseType string

+ DatabaseVersion string

+ DriverVersion string

+ Preparation string

+ SanitizedQuery string

+ URL string

+ User string

+ type Segment struct

+ AWS map[string]interface{}

+ Annotations map[string]interface{}

+ Cause *CauseData

+ ContextDone bool

+ Emitted bool

+ EndTime float64

+ Error bool

+ Fault bool

+ HTTP *HTTPData

+ ID string

+ InProgress bool

+ IncomingHeader *header.Header

+ Metadata map[string]map[string]interface{}

+ Name string

+ Namespace string

+ Origin string

+ ParentID string

+ ParentSegment *Segment

+ PrecursorIDs []string

+ RequestWasTraced bool

+ ResourceARN string

+ SQL *SQLData

+ Sampled bool

+ Service *ServiceData

+ StartTime float64

+ Subsegments []json.RawMessage

+ Throttle bool

+ TraceID string

+ Type string

+ User string

+ func BeginSegment(ctx context.Context, name string) (context.Context, *Segment)

+ func BeginSubsegment(ctx context.Context, name string) (context.Context, *Segment)

+ func GetSegment(ctx context.Context) *Segment

+ func NewSegmentFromHeader(ctx context.Context, name string, h *header.Header) (context.Context, *Segment)

+ func (s *Segment) DownstreamHeader() *header.Header

+ func (s *Segment) GetAWS() map[string]interface{}

+ func (s *Segment) GetCause() *CauseData

+ func (s *Segment) GetHTTP() *HTTPData

+ func (s *Segment) GetSQL() *SQLData

+ func (s *Segment) GetService() *ServiceData

+ func (seg *Segment) Close(err error)

+ func (seg *Segment) RemoveSubsegment(remove *Segment) bool

+ type SegmentNamer interface

+ Name func(host string) string

+ type ServiceData struct

+ Version string

+ type Stmt struct

+ func (stmt *Stmt) Close() error

+ func (stmt *Stmt) Exec(ctx context.Context, args ...interface{}) (sql.Result, error)

+ func (stmt *Stmt) Query(ctx context.Context, args ...interface{}) (*sql.Rows, error)

+ func (stmt *Stmt) QueryRow(ctx context.Context, args ...interface{}) *sql.Row

+ type StreamingStrategy interface

+ RequiresStreaming func(seg *Segment) bool

+ StreamCompletedSubsegments func(seg *Segment) [][]byte

+ type Tx struct

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (tx *Tx) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (tx *Tx) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (tx *Tx) Rollback() error

+ func (tx *Tx) Stmt(ctx context.Context, stmt *Stmt) *Stmt