opentelemetry

Documentation

Index

• func WrapWithTraces(bkt objstore.Bucket, tracer trace.Tracer) objstore.InstrumentedBucket
• type TracingBucket
  • func (t TracingBucket) Attributes(ctx context.Context, name string) (_ 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) (_ 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 WrapWithTraces

func WrapWithTraces(bkt objstore.Bucket, tracer trace.Tracer) objstore.InstrumentedBucket

Types

type TracingBucket

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

TracingBucket is a wrapper around objstore.Bucket that adds tracing to all operations using OpenTelemetry.

func (TracingBucket) Attributes

func (t TracingBucket) Attributes(ctx context.Context, name string) (_ 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) (_ 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

SupportedIterOptions returns a list of supported IterOptions by the underlying provider.

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