tracing

Documentation

Index

• Constants
• func Step(ctx context.Context, msg string, options ...StepOption)
• func TraceID(ctx context.Context) int32
• func WithRequestTraceInfo(parent context.Context, info *RequestTraceInfo) context.Context
• type KeyValue
  • func StringKeyValue(key, val string) KeyValue
• type RequestTraceInfo
  • func New(name string) *RequestTraceInfo
  • func RequestTraceInfoFrom(ctx context.Context) (*RequestTraceInfo, bool)
  • func (t *RequestTraceInfo) End()
  • func (t *RequestTraceInfo) ID() int32
  • func (t *RequestTraceInfo) IfLong(threshold time.Duration) bool
  • func (t *RequestTraceInfo) Log()
  • func (t *RequestTraceInfo) StageLatency() map[string]time.Duration
  • func (t *RequestTraceInfo) Step(msg string, options ...StepOption)
  • func (t *RequestTraceInfo) WithAttributes(attributes ...KeyValue)
  • func (t *RequestTraceInfo) WithHttpTrace()
• type StepOption
  • func WithStepTimestamp(t time.Time) StepOption
• type Transition

Constants

const (
	StepDispatcher          = "dispatcher"
	StepTransport           = "transport"
	StepGotConn             = "got_conn"
	StepWroteRequestHeader  = "wrote_req_header"
	StepReadRequest         = "read_request"
	StepWroteRequest        = "wrote_req"
	StepFirstResponse       = "first_resp_byte"
	StepGotResponse         = "got_resp"
	StepWroteResponseHeader = "wrote_resp_header"
	StepReadResp            = "read_resp"
	StepWroteResp           = "wrote_resp"
)

const (
	MetricStageClientRead    = "client_read"
	MetricStageClientWrite   = "client_write"
	MetricStageUpstreamRead  = "upstream_read"
	MetricStageUpstreamWrite = "upstream_write"
	MetricStageHandlingDelay = "handling_delay"
)

Functions

func Step

func Step(ctx context.Context, msg string, options ...StepOption)

func TraceID

func TraceID(ctx context.Context) int32

func WithRequestTraceInfo

func WithRequestTraceInfo(parent context.Context, info *RequestTraceInfo) context.Context

WithRequestTraceInfo returns a copy of parent in which the RequestTraceInfo value is set

Types

type KeyValue

type KeyValue struct {
	Key   string
	Value string
}

func StringKeyValue

func StringKeyValue(key, val string) KeyValue

type RequestTraceInfo

type RequestTraceInfo struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(name string) *RequestTraceInfo

func RequestTraceInfoFrom

func RequestTraceInfoFrom(ctx context.Context) (*RequestTraceInfo, bool)

RequestTraceInfoFrom returns the value of the RequestTraceInfo key on the ctx

func (*RequestTraceInfo) End

func (t *RequestTraceInfo) End()

func (*RequestTraceInfo) ID

func (t *RequestTraceInfo) ID() int32

func (*RequestTraceInfo) IfLong

func (t *RequestTraceInfo) IfLong(threshold time.Duration) bool

func (*RequestTraceInfo) Log

func (t *RequestTraceInfo) Log()

func (*RequestTraceInfo) StageLatency

func (t *RequestTraceInfo) StageLatency() map[string]time.Duration

func (*RequestTraceInfo) Step

func (t *RequestTraceInfo) Step(msg string, options ...StepOption)

func (*RequestTraceInfo) WithAttributes

func (t *RequestTraceInfo) WithAttributes(attributes ...KeyValue)

func (*RequestTraceInfo) WithHttpTrace

func (t *RequestTraceInfo) WithHttpTrace()

type StepOption

type StepOption interface {
	// contains filtered or unexported methods
}

func WithStepTimestamp

func WithStepTimestamp(t time.Time) StepOption

type Transition

type Transition struct {
	From    string
	FromAlt string // alternative
	To      string
}

Transition describe transition between two phases.