tracings

Documentation

Index

• Variables
• func With(ctx context.Context, trace *Tracer)
• type Config
• type Middleware
  • func (middle *Middleware) Close()
  • func (middle *Middleware) Construct(options transports.MiddlewareOptions) (err error)
  • func (middle *Middleware) Handler(next transports.Handler) transports.Handler
  • func (middle *Middleware) Name() string
• type Reporter
• type ReporterOptions
• type Span
  • func (*Span) Descriptor() ([]byte, []int)
  • func (x *Span) GetBegin() *timestamppb.Timestamp
  • func (x *Span) GetChildren() []*Span
  • func (x *Span) GetEnd() *timestamppb.Timestamp
  • func (x *Span) GetEndpoint() string
  • func (x *Span) GetFn() string
  • func (x *Span) GetId() string
  • func (x *Span) GetParent() *Span
  • func (x *Span) GetTags() map[string]string
  • func (x *Span) GetWaited() *timestamppb.Timestamp
  • func (*Span) ProtoMessage()
  • func (x *Span) ProtoReflect() protoreflect.Message
  • func (x *Span) Reset()
  • func (x *Span) String() string
• type Trace
  • func (*Trace) Descriptor() ([]byte, []int)
  • func (x *Trace) GetId() string
  • func (x *Trace) GetSpan() *Span
  • func (*Trace) ProtoMessage()
  • func (x *Trace) ProtoReflect() protoreflect.Message
  • func (x *Trace) Reset()
  • func (x *Trace) String() string
• type Tracer
  • func Load(ctx context.Context) (trace *Tracer, found bool)
  • func New(id []byte) *Tracer
  • func (trace *Tracer) Begin(pid []byte, endpoint []byte, fn []byte, tags ...string)
  • func (trace *Tracer) Finish(tags ...string)
  • func (trace *Tracer) Mount(child *Span)
  • func (trace *Tracer) Tagging(tags ...string)
  • func (trace *Tracer) Trace() (v *Trace)
  • func (trace *Tracer) Waited(tags ...string)

Variables

var File_span_proto protoreflect.FileDescriptor

Functions

func With

func With(ctx context.Context, trace *Tracer)

Types

type Config

type Config struct {
	Enable      bool            `json:"enable"`
	BatchSize   int             `json:"batchSize"`
	ChannelSize int             `json:"channelSize"`
	Reporter    json.RawMessage `json:"reporter"`
}

type Middleware

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

func (*Middleware) Close

func (middle *Middleware) Close()

func (*Middleware) Construct

func (middle *Middleware) Construct(options transports.MiddlewareOptions) (err error)

func (*Middleware) Handler

func (middle *Middleware) Handler(next transports.Handler) transports.Handler

func (*Middleware) Name

func (middle *Middleware) Name() string

type Reporter

type Reporter interface {
	Construct(options ReporterOptions) (err error)
	Report(ctx context.Context, trace *Trace)
}

type ReporterOptions

type ReporterOptions struct {
	Log    logs.Logger
	Config configures.Config
}

type Span

type Span struct {
	Id       string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Endpoint string                 `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Fn       string                 `protobuf:"bytes,3,opt,name=fn,proto3" json:"fn,omitempty"`
	Begin    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=begin,proto3" json:"begin,omitempty"`
	Waited   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=waited,proto3" json:"waited,omitempty"`
	End      *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end,proto3" json:"end,omitempty"`
	Tags     map[string]string      `` /* 149-byte string literal not displayed */
	Children []*Span                `protobuf:"bytes,8,rep,name=children,proto3" json:"children,omitempty"`
	Parent   *Span                  `protobuf:"bytes,9,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

func (*Span) Descriptor

func (*Span) Descriptor() ([]byte, []int)

Deprecated: Use Span.ProtoReflect.Descriptor instead.

func (*Span) GetBegin

func (x *Span) GetBegin() *timestamppb.Timestamp

func (*Span) GetChildren

func (x *Span) GetChildren() []*Span

func (*Span) GetEnd

func (x *Span) GetEnd() *timestamppb.Timestamp

func (*Span) GetEndpoint

func (x *Span) GetEndpoint() string

func (*Span) GetFn

func (x *Span) GetFn() string

func (*Span) GetId

func (x *Span) GetId() string

func (*Span) GetParent

func (x *Span) GetParent() *Span

func (*Span) GetTags

func (x *Span) GetTags() map[string]string

func (*Span) GetWaited

func (x *Span) GetWaited() *timestamppb.Timestamp

func (*Span) ProtoMessage

func (*Span) ProtoMessage()

func (*Span) ProtoReflect

func (x *Span) ProtoReflect() protoreflect.Message

func (*Span) Reset

func (x *Span) Reset()

func (*Span) String

func (x *Span) String() string

type Trace

type Trace struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Span *Span  `protobuf:"bytes,2,opt,name=span,proto3" json:"span,omitempty"`
	// contains filtered or unexported fields
}

func (*Trace) Descriptor

func (*Trace) Descriptor() ([]byte, []int)

Deprecated: Use Trace.ProtoReflect.Descriptor instead.

func (*Trace) GetId

func (x *Trace) GetId() string

func (*Trace) GetSpan

func (x *Trace) GetSpan() *Span

func (*Trace) ProtoMessage

func (*Trace) ProtoMessage()

func (*Trace) ProtoReflect

func (x *Trace) ProtoReflect() protoreflect.Message

func (*Trace) Reset

func (x *Trace) Reset()

func (*Trace) String

func (x *Trace) String() string

type Tracer

type Tracer struct {
	Id   string
	Span *Span
	// contains filtered or unexported fields
}

func Load

func Load(ctx context.Context) (trace *Tracer, found bool)

func New

func New(id []byte) *Tracer

func (*Tracer) Begin

func (trace *Tracer) Begin(pid []byte, endpoint []byte, fn []byte, tags ...string)

func (*Tracer) Finish

func (trace *Tracer) Finish(tags ...string)

func (*Tracer) Mount

func (trace *Tracer) Mount(child *Span)

func (*Tracer) Tagging

func (trace *Tracer) Tagging(tags ...string)

func (*Tracer) Trace

func (trace *Tracer) Trace() (v *Trace)

func (*Tracer) Waited

func (trace *Tracer) Waited(tags ...string)