Documentation
¶
Index ¶
- Variables
- func With(ctx context.Context, trace *Tracer)
- type Config
- type Middleware
- type Reporter
- type ReporterOptions
- type Span
- func (*Span) Descriptor() ([]byte, []int)deprecated
- 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
- type Tracer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_span_proto protoreflect.FileDescriptor
Functions ¶
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
deprecated
added in
v1.2.0
func (*Span) GetBegin ¶ added in v1.2.0
func (x *Span) GetBegin() *timestamppb.Timestamp
func (*Span) GetChildren ¶ added in v1.2.0
func (*Span) GetEnd ¶ added in v1.2.0
func (x *Span) GetEnd() *timestamppb.Timestamp
func (*Span) GetEndpoint ¶ added in v1.2.0
func (*Span) GetWaited ¶ added in v1.2.0
func (x *Span) GetWaited() *timestamppb.Timestamp
func (*Span) ProtoMessage ¶ added in v1.2.0
func (*Span) ProtoMessage()
func (*Span) ProtoReflect ¶ added in v1.2.0
func (x *Span) ProtoReflect() protoreflect.Message
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
deprecated
added in
v1.2.0
func (*Trace) ProtoMessage ¶ added in v1.2.0
func (*Trace) ProtoMessage()
func (*Trace) ProtoReflect ¶ added in v1.2.0
func (x *Trace) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.