trace

Documentation

Overview

github.com/whatap/go-api/trace

github.com/whatap/go-api/trace

Index

• Constants
• Variables
• func AddGIDTraceCtx(GID int64, traceCtx *TraceCtx)
• func CloseTraceContext(ctx *TraceCtx)
• func DISABLE() bool
• func End(ctx context.Context, err error) error
• func Error(ctx context.Context, err error) error
• func Func(handler func(http.ResponseWriter, *http.Request)) func(http.ResponseWriter, *http.Request)
• func GetAgentTraceContext(tCtx *TraceCtx) *agenttrace.TraceContext
• func GetClientId(r *http.Request, remoteIP string) string
• func GetGID() int64
• func GetMTrace(ctx context.Context) http.Header
• func GetRemoteIP(remoteAddr string, header map[string][]string) string
• func GetTxid(ctx context.Context) int64
• func GetWhatapCookie(r *http.Request) (cookie *http.Cookie, exists bool)
• func HandlerFunc(handler func(http.ResponseWriter, *http.Request)) http.HandlerFunc
• func Init(m map[string]string)
• func ParseHeader(m map[string][]string) string
• func ParseParameter(m map[string][]string) string
• func RemoveGIDTraceCtx(GID int64)
• func SetHeader(ctx context.Context, m map[string][]string)
• func SetParameter(ctx context.Context, m map[string][]string)
• func SetWhatapCookie(w http.ResponseWriter, cookie *http.Cookie)
• func Shutdown()
• func Start(ctx context.Context, name string) (context.Context, error)
• func StartWithContext(ctx context.Context, name string) (context.Context, error)
• func StartWithRequest(r *http.Request) (context.Context, error)
• func Step(ctx context.Context, title, message string, elapsed, value int) error
• func UpdateMtrace(traceCtx *TraceCtx, header http.Header)
• func UpdateMtraceWithContext(ctx context.Context, header http.Header)
• type TraceContextManager
  • func GetTraceContextManager() *TraceContextManager
  • func (tcm *TraceContextManager) Clear()
• type TraceCtx
  • func GetGIDTraceCtx(GID int64) *TraceCtx
  • func GetTraceContext(ctx context.Context) (context.Context, *TraceCtx)
  • func NewTraceContext(ctx context.Context) (context.Context, *TraceCtx)
  • func NewTraceCtx() *TraceCtx
  • func PoolTraceContext() *TraceCtx
  • func (this *TraceCtx) Clear()
  • func (this *TraceCtx) GetElapsedTime() int
• type WrapResponseWriter
  • func (l *WrapResponseWriter) WriteHeader(status int)

Constants

const (
	STAT_METHOD = 0
	STAT_SQL    = 1
	STAT_HTTPC  = 2
	STAT_DBC    = 3
	STAT_SOCKET = 4
)

const (
	UDP_READ_MAX                    = 64 * 1024
	UDP_PACKET_BUFFER               = 64 * 1024
	UDP_PACKET_BUFFER_CHUNKED_LIMIT = 48 * 1024
	UDP_PACKET_CHANNEL_MAX          = 2048
	UDP_PACKET_FLUSH_TIMEOUT        = 10 * 1000

	UDP_PACKET_HEADER_SIZE = 9
	// typ pos 0
	UDP_PACKET_HEADER_TYPE_POS = 0
	// ver pos 1
	UDP_PACKET_HEADER_VER_POS = 1
	// len pos 5
	UDP_PACKET_HEADER_LEN_POS = 5

	UDP_PACKET_SQL_MAX_SIZE = 32768
)

Variables

var (
	WHATAP_COOKIE_NAME = "WHATAP"
)

Functions

func AddGIDTraceCtx

func AddGIDTraceCtx(GID int64, traceCtx *TraceCtx)

func CloseTraceContext

func CloseTraceContext(ctx *TraceCtx)

func DISABLE

func DISABLE() bool

func End

func End(ctx context.Context, err error) error

func Error

func Error(ctx context.Context, err error) error

func Func

func Func(handler func(http.ResponseWriter, *http.Request)) func(http.ResponseWriter, *http.Request)

wrapping handler function, example : http.HandleFunc(func(http.ResponseWriter, *http.Request))

func GetAgentTraceContext

func GetAgentTraceContext(tCtx *TraceCtx) *agenttrace.TraceContext

func GetClientId

func GetClientId(r *http.Request, remoteIP string) string

func GetGID

func GetGID() int64

func GetMTrace

func GetMTrace(ctx context.Context) http.Header

func GetRemoteIP

func GetRemoteIP(remoteAddr string, header map[string][]string) string

func GetTxid

func GetTxid(ctx context.Context) int64

func GetWhatapCookie

func GetWhatapCookie(r *http.Request) (cookie *http.Cookie, exists bool)

func HandlerFunc

func HandlerFunc(handler func(http.ResponseWriter, *http.Request)) http.HandlerFunc

wrapping type of http.HanderFunc, example : http.Handle(pattern, http.HandlerFunc)

func Init

func Init(m map[string]string)

func ParseHeader

func ParseHeader(m map[string][]string) string

func ParseParameter

func ParseParameter(m map[string][]string) string

func RemoveGIDTraceCtx

func RemoveGIDTraceCtx(GID int64)

func SetHeader

func SetHeader(ctx context.Context, m map[string][]string)

func SetParameter

func SetParameter(ctx context.Context, m map[string][]string)

func SetWhatapCookie

func SetWhatapCookie(w http.ResponseWriter, cookie *http.Cookie)

func Shutdown

func Shutdown()

func Start

func Start(ctx context.Context, name string) (context.Context, error)

func StartWithContext

func StartWithContext(ctx context.Context, name string) (context.Context, error)

func StartWithRequest

func StartWithRequest(r *http.Request) (context.Context, error)

func Step

func Step(ctx context.Context, title, message string, elapsed, value int) error

func UpdateMtrace

func UpdateMtrace(traceCtx *TraceCtx, header http.Header)

func UpdateMtraceWithContext

func UpdateMtraceWithContext(ctx context.Context, header http.Header)

Types

type TraceContextManager

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

func GetTraceContextManager

func GetTraceContextManager() *TraceContextManager

func (*TraceContextManager) Clear

func (tcm *TraceContextManager) Clear()

type TraceCtx

type TraceCtx struct {
	Txid int64
	GID  int64

	Name      string
	StartTime int64

	Ctx *agenttrace.TraceContext

	// Pack
	Host             string
	Uri              string
	Ipaddr           string
	UAgent           string
	Ref              string
	WClientId        string
	HttpMethod       string
	IsStaticContents string
	Status           int32

	MTid        int64
	MDepth      int32
	MStepId     int64
	MCallerTxid int64

	MCallee     int64
	MCallerSpec string
	MCallerUrl  string

	MCallerPoidKey string

	MCallerStepId int64
	// traceparent traceid
	MCallerTraceId string

	TraceMtraceCallerValue      string
	TraceMtracePoidValue        string
	TraceMtraceSpecValue        string
	TraceMtraceMcallee          int64
	TraceMtraceTraceparentValue string
}

func GetGIDTraceCtx

func GetGIDTraceCtx(GID int64) *TraceCtx

func GetTraceContext

func GetTraceContext(ctx context.Context) (context.Context, *TraceCtx)

func NewTraceContext

func NewTraceContext(ctx context.Context) (context.Context, *TraceCtx)

func NewTraceCtx

func NewTraceCtx() *TraceCtx

func PoolTraceContext

func PoolTraceContext() *TraceCtx

func (*TraceCtx) Clear

func (this *TraceCtx) Clear()

func (*TraceCtx) GetElapsedTime

func (this *TraceCtx) GetElapsedTime() int

type WrapResponseWriter

type WrapResponseWriter struct {
	http.ResponseWriter
	Status int
}

func (*WrapResponseWriter) WriteHeader

func (l *WrapResponseWriter) WriteHeader(status int)