go2sky

Apr 1, 2022

Changes in this version

+ func WithSpan(ctx context.Context, span Span) context.Context

Jan 24, 2022

Changes in this version

+ func SetGlobalTracer(tracer *Tracer)

type NoopSpan

+ func (*NoopSpan) IsValid() bool

type Span

+ func ActiveSpan(ctx context.Context) Span

+ IsValid func() bool

type Tracer

+ func GetGlobalTracer() *Tracer

Nov 20, 2021

Changes in this version

type Tag

+ const TagDBSqlParameters

Aug 8, 2021

Changes in this version

type Tracer

+ func (t *Tracer) CreateExitSpanWithContext(ctx context.Context, operationName string, peer string, ...) (s Span, nCtx context.Context, err error)

May 23, 2021

Changes in this version

+ const EmptyServiceInstanceName

+ const EmptyServiceName

+ const EmptySpanID

+ const EmptyTraceSegmentID

+ func ServiceInstanceName(ctx context.Context) string

+ func ServiceName(ctx context.Context) string

+ func SpanID(ctx context.Context) int32

+ func TraceSegmentID(ctx context.Context) string

+ type AgentConfigChangeWatcher interface

+ Key func() string

+ Notify func(eventType AgentConfigEventType, newValue string)

+ Value func() string

+ type AgentConfigEventType int32

+ const DELETED

+ const MODIFY

+ type ConfigDiscoveryService struct

+ UUID string

+ func NewConfigDiscoveryService() *ConfigDiscoveryService

+ func (s *ConfigDiscoveryService) BindWatchers(watchers []AgentConfigChangeWatcher)

+ func (s *ConfigDiscoveryService) HandleCommand(command *common.Command)

+ type DynamicSampler struct

+ func NewDynamicSampler(samplingRate float64, tracer *Tracer) *DynamicSampler

+ func (s *DynamicSampler) IsSampled(operation string) bool

+ func (s *DynamicSampler) Key() string

+ func (s *DynamicSampler) Notify(eventType AgentConfigEventType, newValue string)

+ func (s *DynamicSampler) Value() string

Apr 5, 2021

Changes in this version

+ func GetCorrelation(ctx context.Context, key string) string

+ func PutCorrelation(ctx context.Context, key, value string) bool

+ type CorrelationConfig struct

+ MaxKeyCount int

+ MaxValueSize int

type SegmentContext

+ CorrelationContext map[string]string

type TracerOption

+ func WithCorrelation(keyCount, valueSize int) TracerOption

+ func WithCustomSampler(sampler Sampler) TracerOption

Oct 25, 2020

Changes in this version

+ type ConstSampler struct

+ func NewConstSampler(sample bool) *ConstSampler

+ func (s *ConstSampler) IsSampled(operation string) bool

+ type RandomSampler struct

+ func NewRandomSampler(samplingRate float64) *RandomSampler

+ func (s *RandomSampler) IsSampled(operation string) bool

+ type Sampler interface

+ IsSampled func(operation string) (sampled bool)

type SpanOption

+ func WithOperationName(operationName string) SpanOption

type TracerOption

+ func WithSampler(samplingRate float64) TracerOption

Jul 8, 2020

Changes in this version

+ const ComponentIDHttpServer

Jun 17, 2020

Changes in this version

type Reporter

+ Boot func(service string, serviceInstance string)

Mar 14, 2020

Changes in this version

+ const EmptyTraceID

+ const Inexistence

+ const NoopTraceID

+ func TraceID(ctx context.Context) string

type NoopSpan

+ func (*NoopSpan) GetOperationName() string

+ func (*NoopSpan) IsEntry() bool

+ func (*NoopSpan) IsExit() bool

type SegmentContext

+ FirstSpan Span

+ func (ctx SegmentContext) GetReadableGlobalTraceID() string

type Span

+ GetOperationName func() string

+ IsEntry func() bool

+ IsExit func() bool

Dec 11, 2019

Changes in this version

+ type NoopSpan struct

+ func (*NoopSpan) End()

+ func (*NoopSpan) Error(time.Time, ...string)

+ func (*NoopSpan) Log(time.Time, ...string)

+ func (*NoopSpan) SetComponent(int32)

+ func (*NoopSpan) SetOperationName(string)

+ func (*NoopSpan) SetPeer(string)

+ func (*NoopSpan) SetSpanLayer(common.SpanLayer)

+ func (*NoopSpan) Tag(Tag, string)

+ type ReportedSpan interface

+ ComponentID func() int32

+ Context func() *SegmentContext

+ EndTime func() int64

+ IsError func() bool

+ Logs func() []*v2.Log

+ OperationName func() string

+ Peer func() string

+ Refs func() []*propagation.SpanContext

+ SpanLayer func() common.SpanLayer

+ SpanType func() common.SpanType

+ StartTime func() int64

+ Tags func() []*common.KeyStringValuePair

+ type Reporter interface

+ Close func()

+ Register func(service string, instance string) (int32, int32, error)

+ Send func(spans []ReportedSpan)

+ type SegmentContext struct

+ ParentSegmentID []int64

+ ParentSpanID int32

+ SegmentID []int64

+ SpanID int32

+ TraceID []int64

+ type Span interface

+ End func()

+ Error func(time.Time, ...string)

+ Log func(time.Time, ...string)

+ SetComponent func(int32)

+ SetOperationName func(string)

+ SetPeer func(string)

+ SetSpanLayer func(common.SpanLayer)

+ Tag func(Tag, string)

+ type SpanOption func(s *defaultSpan)

+ func WithContext(sc *propagation.SpanContext) SpanOption

+ func WithSpanType(spanType SpanType) SpanOption

+ type SpanType int32

+ const SpanTypeEntry

+ const SpanTypeExit

+ const SpanTypeLocal

+ type Tag string

+ const TagDBBindVariables

+ const TagDBInstance

+ const TagDBStatement

+ const TagDBType

+ const TagHTTPMethod

+ const TagMQBroker

+ const TagMQQueue

+ const TagMQTopic

+ const TagStatusCode

+ const TagURL

+ type Tracer struct

+ func NewTracer(service string, opts ...TracerOption) (tracer *Tracer, err error)

+ func (t *Tracer) CreateEntrySpan(ctx context.Context, operationName string, extractor propagation.Extractor) (s Span, nCtx context.Context, err error)

+ func (t *Tracer) CreateExitSpan(ctx context.Context, operationName string, peer string, ...) (Span, error)

+ func (t *Tracer) CreateLocalSpan(ctx context.Context, opts ...SpanOption) (s Span, c context.Context, err error)

+ func (t *Tracer) WaitUntilRegister()

+ type TracerOption func(t *Tracer)

+ func WithInstance(instance string) TracerOption

+ func WithReporter(reporter Reporter) TracerOption