opentracing

Documentation

Index

• func ContextWithTracer(ctx context.Context, tracer opentracing.Tracer) context.Context
• func TracerFromContext(ctx context.Context) opentracing.Tracer
• func WrapWithTraces(bkt objstore.Bucket) objstore.InstrumentedBucket
• type Span
• type Tag
• type Tags
• type Tracer
• type TracingBucket
  • func (t TracingBucket) Attributes(ctx context.Context, name string) (attrs objstore.ObjectAttributes, err error)
  • func (t TracingBucket) Close() error
  • func (t TracingBucket) Delete(ctx context.Context, name string) (err error)
  • func (t TracingBucket) Exists(ctx context.Context, name string) (exists bool, err error)
  • func (t TracingBucket) Get(ctx context.Context, name string) (io.ReadCloser, error)
  • func (t TracingBucket) GetRange(ctx context.Context, name string, off, length int64) (io.ReadCloser, error)
  • func (t TracingBucket) IsAccessDeniedErr(err error) bool
  • func (t TracingBucket) IsObjNotFoundErr(err error) bool
  • func (t TracingBucket) Iter(ctx context.Context, dir string, f func(string) error, ...) (err error)
  • func (t TracingBucket) IterWithAttributes(ctx context.Context, dir string, ...) (err error)
  • func (t TracingBucket) Name() string
  • func (t TracingBucket) Provider() objstore.ObjProvider
  • func (t TracingBucket) ReaderWithExpectedErrs(expectedFunc objstore.IsOpFailureExpectedFunc) objstore.BucketReader
  • func (t TracingBucket) SupportedIterOptions() []objstore.IterOptionType
  • func (t TracingBucket) Upload(ctx context.Context, name string, r io.Reader) (err error)
  • func (t TracingBucket) WithExpectedErrs(expectedFunc objstore.IsOpFailureExpectedFunc) objstore.Bucket

Functions

func ContextWithTracer

func ContextWithTracer(ctx context.Context, tracer opentracing.Tracer) context.Context

ContextWithTracer returns a new `context.Context` that holds a reference to given opentracing.Tracer.

func TracerFromContext

func TracerFromContext(ctx context.Context) opentracing.Tracer

TracerFromContext extracts opentracing.Tracer from the given context.

func WrapWithTraces

func WrapWithTraces(bkt objstore.Bucket) objstore.InstrumentedBucket

Types

type Span

type Span = opentracing.Span

type Tag

type Tag = opentracing.Tag

Aliases to avoid spreading opentracing package to Thanos code.

type Tags

type Tags = opentracing.Tags

type Tracer

type Tracer interface {
	GetTraceIDFromSpanContext(ctx opentracing.SpanContext) (string, bool)
}

Tracer interface to provide GetTraceIDFromSpanContext method.

type TracingBucket

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

TracingBucket includes bucket operations in the traces.

func (TracingBucket) Attributes

func (t TracingBucket) Attributes(ctx context.Context, name string) (attrs objstore.ObjectAttributes, err error)

func (TracingBucket) Close

func (t TracingBucket) Close() error

func (TracingBucket) Delete

func (t TracingBucket) Delete(ctx context.Context, name string) (err error)

func (TracingBucket) Exists

func (t TracingBucket) Exists(ctx context.Context, name string) (exists bool, err error)

func (TracingBucket) Get

func (t TracingBucket) Get(ctx context.Context, name string) (io.ReadCloser, error)

func (TracingBucket) GetRange

func (t TracingBucket) GetRange(ctx context.Context, name string, off, length int64) (io.ReadCloser, error)

func (TracingBucket) IsAccessDeniedErr

func (t TracingBucket) IsAccessDeniedErr(err error) bool

func (TracingBucket) IsObjNotFoundErr

func (t TracingBucket) IsObjNotFoundErr(err error) bool

func (TracingBucket) Iter

func (t TracingBucket) Iter(ctx context.Context, dir string, f func(string) error, options ...objstore.IterOption) (err error)

func (TracingBucket) IterWithAttributes

func (t TracingBucket) IterWithAttributes(ctx context.Context, dir string, f func(attrs objstore.IterObjectAttributes) error, options ...objstore.IterOption) (err error)

func (TracingBucket) Name

func (t TracingBucket) Name() string

func (TracingBucket) Provider

func (t TracingBucket) Provider() objstore.ObjProvider

func (TracingBucket) ReaderWithExpectedErrs

func (t TracingBucket) ReaderWithExpectedErrs(expectedFunc objstore.IsOpFailureExpectedFunc) objstore.BucketReader

func (TracingBucket) SupportedIterOptions

func (t TracingBucket) SupportedIterOptions() []objstore.IterOptionType

func (TracingBucket) Upload

func (t TracingBucket) Upload(ctx context.Context, name string, r io.Reader) (err error)

func (TracingBucket) WithExpectedErrs

func (t TracingBucket) WithExpectedErrs(expectedFunc objstore.IsOpFailureExpectedFunc) objstore.Bucket