tracings

Documentation

Index

• 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
• type Trace
• 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)

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            `json:"id" avro:"id"`
	Endpoint string            `json:"endpoint" avro:"endpoint"`
	Fn       string            `json:"fn" avro:"fn"`
	Begin    time.Time         `json:"begin" avro:"begin"`
	Waited   time.Time         `json:"waited" avro:"waited"`
	End      time.Time         `json:"end" avro:"end"`
	Tags     map[string]string `json:"tags" avro:"tags"`
	Children []*Span           `json:"children" avro:"children"`
	// contains filtered or unexported fields
}

type Trace

type Trace struct {
	Id   string
	Span *Span
}

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)