trace

Nov 8, 2018

Changes in this version

+ const DefaultParallelism

+ func NeutralizeClient(client *Client)

+ func SendClientStatistics(cl *Client, stats *statsd.Client, tags []string)

+ func SetDefaultClient(client *Client)

type Client

+ func NewChannelClient(spanChan chan<- *ssf.SSFSpan, opts ...ClientParam) (*Client, error)

type ClientParam

+ func FlushChannel(ch <-chan time.Time, stop func()) ClientParam

+ func FlushInterval(interval time.Duration) ClientParam

+ func ParallelBackends(nBackends uint) ClientParam

+ func ReportStatistics(stats *statsd.Client, interval time.Duration, tags []string) ClientParam

+ type FlushError struct

+ Errors []error

+ func (fe *FlushError) Error() string

+ type FlushableClientBackend interface

+ FlushSync func(ctx context.Context) error

type Trace

+ Indicator bool

+ Samples []*ssf.SSFSample

+ func (t *Trace) Add(samples ...*ssf.SSFSample)

type Tracer

+ func (tracer Tracer) InjectHeader(t *Trace, h http.Header) error

Dec 1, 2017

Changes in this version

+ var ErrClientNotNetworked = fmt.Errorf("client is not using a network backend")

+ var HeaderFormats = []HeaderGroup

type Client

+ func NewBackendClient(b ClientBackend, opts ...ClientParam) (*Client, error)

+ type ClientBackend interface

+ FlushSync func(ctx context.Context) error

+ SendSync func(ctx context.Context, span *ssf.SSFSpan) error

+ type HeaderGroup struct

+ SpanID string

+ TraceID string

Oct 19, 2017

Changes in this version

+ const BufferSize

+ const DefaultBackoff

+ const DefaultCapacity

+ const DefaultConnectTimeout

+ const DefaultMaxBackoff

+ const DefaultVeneurAddress

+ var ErrNoClient = errors.New("client is not initialized")

+ var ErrWouldBlock = errors.New("sending span would block")

+ func Buffered(cl *Client) error

+ func Flush(cl *Client) error

+ func FlushAsync(cl *Client, ch chan<- error) error

+ func Record(cl *Client, span *ssf.SSFSpan, done chan<- error) error

+ type Client struct

+ var DefaultClient *Client

+ func NewClient(addrStr string, opts ...ClientParam) (*Client, error)

+ func (c *Client) Close() error

+ type ClientParam func(*Client) error

+ func BackoffTime(t time.Duration) ClientParam

+ func BufferedSize(size uint) ClientParam

+ func Capacity(n uint) ClientParam

+ func ConnectTimeout(t time.Duration) ClientParam

+ func MaxBackoffTime(t time.Duration) ClientParam

type Span

+ func (s *Span) ClientFinish(cl *Client)

+ func (s *Span) ClientFinishWithOptions(cl *Client, opts opentracing.FinishOptions)

type Trace

+ Sent chan<- error

+ func (t *Trace) ClientRecord(cl *Client, name string, tags map[string]string) error

Jul 13, 2017

Changes in this version

+ const NameKey

+ const ResourceKey

type Trace

+ func (t *Trace) SSFSpan() *ssf.SSFSpan

Apr 24, 2017

Changes in this version

+ const ParentIDHeader

+ const SpanIDHeader

+ const TraceIDHeader

+ func Disable()

+ func Enable()

type Trace

+ ParentID int64

+ SpanID int64

+ TraceID int64

Jan 20, 2017

Changes in this version

+ const ParentIdHeader

+ const SpanIdHeader

+ const TraceIdHeader

+ var Disabled bool = false

+ var ErrUnsupportedSpanContext = errors.New("Unsupported SpanContext")

+ var GlobalTracer = Tracer

+ var Service = ""

+ func NameTag(name string) opentracing.StartSpanOption

+ type ErrContractViolation struct

+ func (e ErrContractViolation) Error() string

+ type Span struct

+ func StartSpanFromContext(ctx context.Context, name string, opts ...opentracing.StartSpanOption) (s *Span, c context.Context)

+ func (s *Span) Attach(ctx context.Context) context.Context

+ func (s *Span) BaggageItem(restrictedKey string) string

+ func (s *Span) Context() opentracing.SpanContext

+ func (s *Span) Finish()

+ func (s *Span) FinishWithOptions(opts opentracing.FinishOptions)

+ func (s *Span) Log(data opentracing.LogData)

+ func (s *Span) LogEvent(event string)

+ func (s *Span) LogEventWithPayload(event string, payload interface{})

+ func (s *Span) LogFields(fields ...opentracinglog.Field)

+ func (s *Span) LogKV(alternatingKeyValues ...interface{})

+ func (s *Span) SetBaggageItem(restrictedKey, value string) opentracing.Span

+ func (s *Span) SetOperationName(name string) opentracing.Span

+ func (s *Span) SetTag(key string, value interface{}) opentracing.Span

+ func (s *Span) Tracer() opentracing.Tracer

+ type Trace struct

+ End time.Time

+ Name string

+ ParentId int64

+ Resource string

+ SpanId int64

+ Start time.Time

+ Status ssf.SSFSample_Status

+ Tags []*ssf.SSFTag

+ TraceId int64

+ func SpanFromContext(c context.Context) *Trace

+ func StartChildSpan(parent *Trace) *Trace

+ func StartTrace(resource string) *Trace

+ func (t *Trace) Attach(c context.Context) context.Context

+ func (t *Trace) Duration() time.Duration

+ func (t *Trace) Error(err error)

+ func (t *Trace) ProtoMarshalTo(w io.Writer) error

+ func (t *Trace) Record(name string, tags []*ssf.SSFTag) error

+ func (t *Trace) SSFSample() *ssf.SSFSample

+ func (t *Trace) SetParent(parent *Trace)

+ type Tracer struct

+ func (t Tracer) Extract(format interface{}, carrier interface{}) (ctx opentracing.SpanContext, err error)

+ func (t Tracer) Inject(sm opentracing.SpanContext, format interface{}, carrier interface{}) (err error)

+ func (t Tracer) StartSpan(operationName string, opts ...opentracing.StartSpanOption) opentracing.Span

+ func (tracer Tracer) ExtractRequestChild(resource string, req *http.Request, name string) (*Span, error)

+ func (tracer Tracer) InjectRequest(t *Trace, req *http.Request) error