trace

package
v1.48.7-circular Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 30, 2025 License: MPL-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	HTTPTraceEventCode_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "GET_CONN",
		2:  "GOT_CONN",
		3:  "GOT_FIRST_RESPONSE_BYTE",
		4:  "GOT_1XX_RESPONSE",
		5:  "DNS_START",
		6:  "DNS_DONE",
		7:  "CONNECT_START",
		8:  "CONNECT_DONE",
		9:  "TLS_HANDSHAKE_START",
		10: "TLS_HANDSHAKE_DONE",
		11: "WROTE_HEADERS",
		12: "WROTE_REQUEST",
		13: "WAIT_100_CONTINUE",
	}
	HTTPTraceEventCode_value = map[string]int32{
		"UNKNOWN":                 0,
		"GET_CONN":                1,
		"GOT_CONN":                2,
		"GOT_FIRST_RESPONSE_BYTE": 3,
		"GOT_1XX_RESPONSE":        4,
		"DNS_START":               5,
		"DNS_DONE":                6,
		"CONNECT_START":           7,
		"CONNECT_DONE":            8,
		"TLS_HANDSHAKE_START":     9,
		"TLS_HANDSHAKE_DONE":      10,
		"WROTE_HEADERS":           11,
		"WROTE_REQUEST":           12,
		"WAIT_100_CONTINUE":       13,
	}
)

Enum value maps for HTTPTraceEventCode.

View Source
var (
	Request_Type_name = map[int32]string{
		0: "RPC",
		1: "AUTH",
		2: "PUBSUB_MSG",
	}
	Request_Type_value = map[string]int32{
		"RPC":        0,
		"AUTH":       1,
		"PUBSUB_MSG": 2,
	}
)

Enum value maps for Request_Type.

View Source
var (
	DBTransaction_CompletionType_name = map[int32]string{
		0: "ROLLBACK",
		1: "COMMIT",
	}
	DBTransaction_CompletionType_value = map[string]int32{
		"ROLLBACK": 0,
		"COMMIT":   1,
	}
)

Enum value maps for DBTransaction_CompletionType.

View Source
var (
	CacheOp_Result_name = map[int32]string{
		0: "UNKNOWN",
		1: "OK",
		2: "NO_SUCH_KEY",
		3: "CONFLICT",
		4: "ERR",
	}
	CacheOp_Result_value = map[string]int32{
		"UNKNOWN":     0,
		"OK":          1,
		"NO_SUCH_KEY": 2,
		"CONFLICT":    3,
		"ERR":         4,
	}
)

Enum value maps for CacheOp_Result.

View Source
var (
	LogMessage_Level_name = map[int32]string{
		0: "DEBUG",
		1: "INFO",
		2: "ERROR",
		3: "WARN",
		4: "TRACE",
	}
	LogMessage_Level_value = map[string]int32{
		"DEBUG": 0,
		"INFO":  1,
		"ERROR": 2,
		"WARN":  3,
		"TRACE": 4,
	}
)

Enum value maps for LogMessage_Level.

View Source
var File_encore_engine_trace_trace_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BodyStream

type BodyStream struct {
	IsResponse bool   `protobuf:"varint,1,opt,name=is_response,json=isResponse,proto3" json:"is_response,omitempty"`
	Overflowed bool   `protobuf:"varint,2,opt,name=overflowed,proto3" json:"overflowed,omitempty"`
	Data       []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BodyStream) Descriptor deprecated

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

Deprecated: Use BodyStream.ProtoReflect.Descriptor instead.

func (*BodyStream) GetData

func (x *BodyStream) GetData() []byte

func (*BodyStream) GetIsResponse

func (x *BodyStream) GetIsResponse() bool

func (*BodyStream) GetOverflowed

func (x *BodyStream) GetOverflowed() bool

func (*BodyStream) ProtoMessage

func (*BodyStream) ProtoMessage()

func (*BodyStream) ProtoReflect

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

func (*BodyStream) Reset

func (x *BodyStream) Reset()

func (*BodyStream) String

func (x *BodyStream) String() string

type CacheOp

type CacheOp struct {
	Goid      uint32         `protobuf:"varint,1,opt,name=goid,proto3" json:"goid,omitempty"`
	DefLoc    int32          `protobuf:"varint,2,opt,name=def_loc,json=defLoc,proto3" json:"def_loc,omitempty"`
	StartTime uint64         `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   uint64         `protobuf:"varint,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Operation string         `protobuf:"bytes,5,opt,name=operation,proto3" json:"operation,omitempty"`
	Keys      []string       `protobuf:"bytes,6,rep,name=keys,proto3" json:"keys,omitempty"`
	Inputs    [][]byte       `protobuf:"bytes,7,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs   [][]byte       `protobuf:"bytes,8,rep,name=outputs,proto3" json:"outputs,omitempty"`
	Stack     *StackTrace    `protobuf:"bytes,9,opt,name=stack,proto3" json:"stack,omitempty"` // null if unavailable
	Err       []byte         `protobuf:"bytes,10,opt,name=err,proto3" json:"err,omitempty"`    // set iff result == ERR
	Write     bool           `protobuf:"varint,11,opt,name=write,proto3" json:"write,omitempty"`
	Result    CacheOp_Result `protobuf:"varint,12,opt,name=result,proto3,enum=encore.engine.trace.CacheOp_Result" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheOp) Descriptor deprecated

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

Deprecated: Use CacheOp.ProtoReflect.Descriptor instead.

func (*CacheOp) GetDefLoc

func (x *CacheOp) GetDefLoc() int32

func (*CacheOp) GetEndTime

func (x *CacheOp) GetEndTime() uint64

func (*CacheOp) GetErr

func (x *CacheOp) GetErr() []byte

func (*CacheOp) GetGoid

func (x *CacheOp) GetGoid() uint32

func (*CacheOp) GetInputs

func (x *CacheOp) GetInputs() [][]byte

func (*CacheOp) GetKeys

func (x *CacheOp) GetKeys() []string

func (*CacheOp) GetOperation

func (x *CacheOp) GetOperation() string

func (*CacheOp) GetOutputs

func (x *CacheOp) GetOutputs() [][]byte

func (*CacheOp) GetResult

func (x *CacheOp) GetResult() CacheOp_Result

func (*CacheOp) GetStack

func (x *CacheOp) GetStack() *StackTrace

func (*CacheOp) GetStartTime

func (x *CacheOp) GetStartTime() uint64

func (*CacheOp) GetWrite

func (x *CacheOp) GetWrite() bool

func (*CacheOp) ProtoMessage

func (*CacheOp) ProtoMessage()

func (*CacheOp) ProtoReflect

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

func (*CacheOp) Reset

func (x *CacheOp) Reset()

func (*CacheOp) String

func (x *CacheOp) String() string

type CacheOp_Result

type CacheOp_Result int32
const (
	CacheOp_UNKNOWN     CacheOp_Result = 0
	CacheOp_OK          CacheOp_Result = 1
	CacheOp_NO_SUCH_KEY CacheOp_Result = 2
	CacheOp_CONFLICT    CacheOp_Result = 3
	CacheOp_ERR         CacheOp_Result = 4
)

func (CacheOp_Result) Descriptor

func (CacheOp_Result) Enum

func (x CacheOp_Result) Enum() *CacheOp_Result

func (CacheOp_Result) EnumDescriptor deprecated

func (CacheOp_Result) EnumDescriptor() ([]byte, []int)

Deprecated: Use CacheOp_Result.Descriptor instead.

func (CacheOp_Result) Number

func (CacheOp_Result) String

func (x CacheOp_Result) String() string

func (CacheOp_Result) Type

type DBQuery

type DBQuery struct {
	Goid      uint32      `protobuf:"varint,1,opt,name=goid,proto3" json:"goid,omitempty"`
	StartTime uint64      `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   uint64      `protobuf:"varint,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Query     []byte      `protobuf:"bytes,5,opt,name=query,proto3" json:"query,omitempty"`
	Err       []byte      `protobuf:"bytes,6,opt,name=err,proto3" json:"err,omitempty"`
	Stack     *StackTrace `protobuf:"bytes,7,opt,name=stack,proto3" json:"stack,omitempty"` // null if unavailable
	// contains filtered or unexported fields
}

func (*DBQuery) Descriptor deprecated

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

Deprecated: Use DBQuery.ProtoReflect.Descriptor instead.

func (*DBQuery) GetEndTime

func (x *DBQuery) GetEndTime() uint64

func (*DBQuery) GetErr

func (x *DBQuery) GetErr() []byte

func (*DBQuery) GetGoid

func (x *DBQuery) GetGoid() uint32

func (*DBQuery) GetQuery

func (x *DBQuery) GetQuery() []byte

func (*DBQuery) GetStack

func (x *DBQuery) GetStack() *StackTrace

func (*DBQuery) GetStartTime

func (x *DBQuery) GetStartTime() uint64

func (*DBQuery) ProtoMessage

func (*DBQuery) ProtoMessage()

func (*DBQuery) ProtoReflect

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

func (*DBQuery) Reset

func (x *DBQuery) Reset()

func (*DBQuery) String

func (x *DBQuery) String() string

type DBTransaction

type DBTransaction struct {
	Goid       uint32                       `protobuf:"varint,1,opt,name=goid,proto3" json:"goid,omitempty"`
	StartTime  uint64                       `protobuf:"varint,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime    uint64                       `protobuf:"varint,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Err        []byte                       `protobuf:"bytes,6,opt,name=err,proto3" json:"err,omitempty"`
	Completion DBTransaction_CompletionType `` /* 128-byte string literal not displayed */
	Queries    []*DBQuery                   `protobuf:"bytes,8,rep,name=queries,proto3" json:"queries,omitempty"`
	BeginStack *StackTrace                  `protobuf:"bytes,9,opt,name=begin_stack,json=beginStack,proto3" json:"begin_stack,omitempty"` // null if unavailable
	EndStack   *StackTrace                  `protobuf:"bytes,10,opt,name=end_stack,json=endStack,proto3" json:"end_stack,omitempty"`      // null if unavailable
	// contains filtered or unexported fields
}

func (*DBTransaction) Descriptor deprecated

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

Deprecated: Use DBTransaction.ProtoReflect.Descriptor instead.

func (*DBTransaction) GetBeginStack

func (x *DBTransaction) GetBeginStack() *StackTrace

func (*DBTransaction) GetCompletion

func (x *DBTransaction) GetCompletion() DBTransaction_CompletionType

func (*DBTransaction) GetEndStack

func (x *DBTransaction) GetEndStack() *StackTrace

func (*DBTransaction) GetEndTime

func (x *DBTransaction) GetEndTime() uint64

func (*DBTransaction) GetErr

func (x *DBTransaction) GetErr() []byte

func (*DBTransaction) GetGoid

func (x *DBTransaction) GetGoid() uint32

func (*DBTransaction) GetQueries

func (x *DBTransaction) GetQueries() []*DBQuery

func (*DBTransaction) GetStartTime

func (x *DBTransaction) GetStartTime() uint64

func (*DBTransaction) ProtoMessage

func (*DBTransaction) ProtoMessage()

func (*DBTransaction) ProtoReflect

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

func (*DBTransaction) Reset

func (x *DBTransaction) Reset()

func (*DBTransaction) String

func (x *DBTransaction) String() string

type DBTransaction_CompletionType

type DBTransaction_CompletionType int32
const (
	DBTransaction_ROLLBACK DBTransaction_CompletionType = 0
	DBTransaction_COMMIT   DBTransaction_CompletionType = 1
)

func (DBTransaction_CompletionType) Descriptor

func (DBTransaction_CompletionType) Enum

func (DBTransaction_CompletionType) EnumDescriptor deprecated

func (DBTransaction_CompletionType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DBTransaction_CompletionType.Descriptor instead.

func (DBTransaction_CompletionType) Number

func (DBTransaction_CompletionType) String

func (DBTransaction_CompletionType) Type

type DNSAddr

type DNSAddr struct {
	Ip []byte `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

func (*DNSAddr) Descriptor deprecated

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

Deprecated: Use DNSAddr.ProtoReflect.Descriptor instead.

func (*DNSAddr) GetIp

func (x *DNSAddr) GetIp() []byte

func (*DNSAddr) ProtoMessage

func (*DNSAddr) ProtoMessage()

func (*DNSAddr) ProtoReflect

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

func (*DNSAddr) Reset

func (x *DNSAddr) Reset()

func (*DNSAddr) String

func (x *DNSAddr) String() string

type ErrWithStack

type ErrWithStack struct {
	Error string      `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Stack *StackTrace `protobuf:"bytes,2,opt,name=stack,proto3" json:"stack,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrWithStack) Descriptor deprecated

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

Deprecated: Use ErrWithStack.ProtoReflect.Descriptor instead.

func (*ErrWithStack) GetError

func (x *ErrWithStack) GetError() string

func (*ErrWithStack) GetStack

func (x *ErrWithStack) GetStack() *StackTrace

func (*ErrWithStack) ProtoMessage

func (*ErrWithStack) ProtoMessage()

func (*ErrWithStack) ProtoReflect

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

func (*ErrWithStack) Reset

func (x *ErrWithStack) Reset()

func (*ErrWithStack) String

func (x *ErrWithStack) String() string

type Event

type Event struct {

	// Types that are assignable to Data:
	//
	//	*Event_Rpc
	//	*Event_Tx
	//	*Event_Query
	//	*Event_Goroutine
	//	*Event_Http
	//	*Event_Log
	//	*Event_PublishedMsg
	//	*Event_ServiceInit
	//	*Event_Cache
	//	*Event_BodyStream
	Data isEvent_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetBodyStream

func (x *Event) GetBodyStream() *BodyStream

func (*Event) GetCache

func (x *Event) GetCache() *CacheOp

func (*Event) GetData

func (m *Event) GetData() isEvent_Data

func (*Event) GetGoroutine

func (x *Event) GetGoroutine() *Goroutine

func (*Event) GetHttp

func (x *Event) GetHttp() *HTTPCall

func (*Event) GetLog

func (x *Event) GetLog() *LogMessage

func (*Event) GetPublishedMsg

func (x *Event) GetPublishedMsg() *PubsubMsgPublished

func (*Event) GetQuery

func (x *Event) GetQuery() *DBQuery

func (*Event) GetRpc

func (x *Event) GetRpc() *RPCCall

func (*Event) GetServiceInit

func (x *Event) GetServiceInit() *ServiceInit

func (*Event) GetTx

func (x *Event) GetTx() *DBTransaction

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type Event_BodyStream

type Event_BodyStream struct {
	BodyStream *BodyStream `protobuf:"bytes,10,opt,name=body_stream,json=bodyStream,proto3,oneof"`
}

type Event_Cache

type Event_Cache struct {
	Cache *CacheOp `protobuf:"bytes,9,opt,name=cache,proto3,oneof"`
}

type Event_Goroutine

type Event_Goroutine struct {
	Goroutine *Goroutine `protobuf:"bytes,4,opt,name=goroutine,proto3,oneof"`
}

type Event_Http

type Event_Http struct {
	Http *HTTPCall `protobuf:"bytes,5,opt,name=http,proto3,oneof"`
}

type Event_Log

type Event_Log struct {
	Log *LogMessage `protobuf:"bytes,6,opt,name=log,proto3,oneof"`
}

type Event_PublishedMsg

type Event_PublishedMsg struct {
	PublishedMsg *PubsubMsgPublished `protobuf:"bytes,7,opt,name=publishedMsg,proto3,oneof"`
}

type Event_Query

type Event_Query struct {
	Query *DBQuery `protobuf:"bytes,3,opt,name=query,proto3,oneof"`
}

type Event_Rpc

type Event_Rpc struct {
	Rpc *RPCCall `protobuf:"bytes,1,opt,name=rpc,proto3,oneof"`
}

type Event_ServiceInit

type Event_ServiceInit struct {
	ServiceInit *ServiceInit `protobuf:"bytes,8,opt,name=service_init,json=serviceInit,proto3,oneof"`
}

type Event_Tx

type Event_Tx struct {
	Tx *DBTransaction `protobuf:"bytes,2,opt,name=tx,proto3,oneof"`
}

type Goroutine

type Goroutine struct {
	Goid      uint32 `protobuf:"varint,1,opt,name=goid,proto3" json:"goid,omitempty"`
	StartTime uint64 `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   uint64 `protobuf:"varint,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Goroutine) Descriptor deprecated

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

Deprecated: Use Goroutine.ProtoReflect.Descriptor instead.

func (*Goroutine) GetEndTime

func (x *Goroutine) GetEndTime() uint64

func (*Goroutine) GetGoid

func (x *Goroutine) GetGoid() uint32

func (*Goroutine) GetStartTime

func (x *Goroutine) GetStartTime() uint64

func (*Goroutine) ProtoMessage

func (*Goroutine) ProtoMessage()

func (*Goroutine) ProtoReflect

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

func (*Goroutine) Reset

func (x *Goroutine) Reset()

func (*Goroutine) String

func (x *Goroutine) String() string

type HTTPCall

type HTTPCall struct {
	SpanId         uint64            `protobuf:"varint,1,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	Goid           uint32            `protobuf:"varint,2,opt,name=goid,proto3" json:"goid,omitempty"`
	StartTime      uint64            `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime        uint64            `protobuf:"varint,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Method         string            `protobuf:"bytes,5,opt,name=method,proto3" json:"method,omitempty"`
	Url            string            `protobuf:"bytes,6,opt,name=url,proto3" json:"url,omitempty"`
	StatusCode     uint32            `protobuf:"varint,7,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Err            []byte            `protobuf:"bytes,8,opt,name=err,proto3" json:"err,omitempty"`
	BodyClosedTime uint64            `protobuf:"varint,9,opt,name=body_closed_time,json=bodyClosedTime,proto3" json:"body_closed_time,omitempty"`
	Events         []*HTTPTraceEvent `protobuf:"bytes,10,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPCall) Descriptor deprecated

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

Deprecated: Use HTTPCall.ProtoReflect.Descriptor instead.

func (*HTTPCall) GetBodyClosedTime

func (x *HTTPCall) GetBodyClosedTime() uint64

func (*HTTPCall) GetEndTime

func (x *HTTPCall) GetEndTime() uint64

func (*HTTPCall) GetErr

func (x *HTTPCall) GetErr() []byte

func (*HTTPCall) GetEvents

func (x *HTTPCall) GetEvents() []*HTTPTraceEvent

func (*HTTPCall) GetGoid

func (x *HTTPCall) GetGoid() uint32

func (*HTTPCall) GetMethod

func (x *HTTPCall) GetMethod() string

func (*HTTPCall) GetSpanId

func (x *HTTPCall) GetSpanId() uint64

func (*HTTPCall) GetStartTime

func (x *HTTPCall) GetStartTime() uint64

func (*HTTPCall) GetStatusCode

func (x *HTTPCall) GetStatusCode() uint32

func (*HTTPCall) GetUrl

func (x *HTTPCall) GetUrl() string

func (*HTTPCall) ProtoMessage

func (*HTTPCall) ProtoMessage()

func (*HTTPCall) ProtoReflect

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

func (*HTTPCall) Reset

func (x *HTTPCall) Reset()

func (*HTTPCall) String

func (x *HTTPCall) String() string

type HTTPConnectDoneData

type HTTPConnectDoneData struct {
	Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	Addr    string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Err     []byte `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPConnectDoneData) Descriptor deprecated

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

Deprecated: Use HTTPConnectDoneData.ProtoReflect.Descriptor instead.

func (*HTTPConnectDoneData) GetAddr

func (x *HTTPConnectDoneData) GetAddr() string

func (*HTTPConnectDoneData) GetErr

func (x *HTTPConnectDoneData) GetErr() []byte

func (*HTTPConnectDoneData) GetNetwork

func (x *HTTPConnectDoneData) GetNetwork() string

func (*HTTPConnectDoneData) ProtoMessage

func (*HTTPConnectDoneData) ProtoMessage()

func (*HTTPConnectDoneData) ProtoReflect

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

func (*HTTPConnectDoneData) Reset

func (x *HTTPConnectDoneData) Reset()

func (*HTTPConnectDoneData) String

func (x *HTTPConnectDoneData) String() string

type HTTPConnectStartData

type HTTPConnectStartData struct {
	Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	Addr    string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPConnectStartData) Descriptor deprecated

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

Deprecated: Use HTTPConnectStartData.ProtoReflect.Descriptor instead.

func (*HTTPConnectStartData) GetAddr

func (x *HTTPConnectStartData) GetAddr() string

func (*HTTPConnectStartData) GetNetwork

func (x *HTTPConnectStartData) GetNetwork() string

func (*HTTPConnectStartData) ProtoMessage

func (*HTTPConnectStartData) ProtoMessage()

func (*HTTPConnectStartData) ProtoReflect

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

func (*HTTPConnectStartData) Reset

func (x *HTTPConnectStartData) Reset()

func (*HTTPConnectStartData) String

func (x *HTTPConnectStartData) String() string

type HTTPDNSDoneData

type HTTPDNSDoneData struct {
	Err   []byte     `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Addrs []*DNSAddr `protobuf:"bytes,2,rep,name=addrs,proto3" json:"addrs,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPDNSDoneData) Descriptor deprecated

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

Deprecated: Use HTTPDNSDoneData.ProtoReflect.Descriptor instead.

func (*HTTPDNSDoneData) GetAddrs

func (x *HTTPDNSDoneData) GetAddrs() []*DNSAddr

func (*HTTPDNSDoneData) GetErr

func (x *HTTPDNSDoneData) GetErr() []byte

func (*HTTPDNSDoneData) ProtoMessage

func (*HTTPDNSDoneData) ProtoMessage()

func (*HTTPDNSDoneData) ProtoReflect

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

func (*HTTPDNSDoneData) Reset

func (x *HTTPDNSDoneData) Reset()

func (*HTTPDNSDoneData) String

func (x *HTTPDNSDoneData) String() string

type HTTPDNSStartData

type HTTPDNSStartData struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPDNSStartData) Descriptor deprecated

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

Deprecated: Use HTTPDNSStartData.ProtoReflect.Descriptor instead.

func (*HTTPDNSStartData) GetHost

func (x *HTTPDNSStartData) GetHost() string

func (*HTTPDNSStartData) ProtoMessage

func (*HTTPDNSStartData) ProtoMessage()

func (*HTTPDNSStartData) ProtoReflect

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

func (*HTTPDNSStartData) Reset

func (x *HTTPDNSStartData) Reset()

func (*HTTPDNSStartData) String

func (x *HTTPDNSStartData) String() string

type HTTPGetConnData

type HTTPGetConnData struct {
	HostPort string `protobuf:"bytes,1,opt,name=host_port,json=hostPort,proto3" json:"host_port,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPGetConnData) Descriptor deprecated

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

Deprecated: Use HTTPGetConnData.ProtoReflect.Descriptor instead.

func (*HTTPGetConnData) GetHostPort

func (x *HTTPGetConnData) GetHostPort() string

func (*HTTPGetConnData) ProtoMessage

func (*HTTPGetConnData) ProtoMessage()

func (*HTTPGetConnData) ProtoReflect

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

func (*HTTPGetConnData) Reset

func (x *HTTPGetConnData) Reset()

func (*HTTPGetConnData) String

func (x *HTTPGetConnData) String() string

type HTTPGot1XxResponseData

type HTTPGot1XxResponseData struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPGot1XxResponseData) Descriptor deprecated

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

Deprecated: Use HTTPGot1XxResponseData.ProtoReflect.Descriptor instead.

func (*HTTPGot1XxResponseData) GetCode

func (x *HTTPGot1XxResponseData) GetCode() int32

func (*HTTPGot1XxResponseData) ProtoMessage

func (*HTTPGot1XxResponseData) ProtoMessage()

func (*HTTPGot1XxResponseData) ProtoReflect

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

func (*HTTPGot1XxResponseData) Reset

func (x *HTTPGot1XxResponseData) Reset()

func (*HTTPGot1XxResponseData) String

func (x *HTTPGot1XxResponseData) String() string

type HTTPGotConnData

type HTTPGotConnData struct {
	Reused         bool  `protobuf:"varint,1,opt,name=reused,proto3" json:"reused,omitempty"`
	WasIdle        bool  `protobuf:"varint,2,opt,name=was_idle,json=wasIdle,proto3" json:"was_idle,omitempty"`
	IdleDurationNs int64 `protobuf:"varint,3,opt,name=idle_duration_ns,json=idleDurationNs,proto3" json:"idle_duration_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPGotConnData) Descriptor deprecated

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

Deprecated: Use HTTPGotConnData.ProtoReflect.Descriptor instead.

func (*HTTPGotConnData) GetIdleDurationNs

func (x *HTTPGotConnData) GetIdleDurationNs() int64

func (*HTTPGotConnData) GetReused

func (x *HTTPGotConnData) GetReused() bool

func (*HTTPGotConnData) GetWasIdle

func (x *HTTPGotConnData) GetWasIdle() bool

func (*HTTPGotConnData) ProtoMessage

func (*HTTPGotConnData) ProtoMessage()

func (*HTTPGotConnData) ProtoReflect

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

func (*HTTPGotConnData) Reset

func (x *HTTPGotConnData) Reset()

func (*HTTPGotConnData) String

func (x *HTTPGotConnData) String() string

type HTTPTLSHandshakeDoneData

type HTTPTLSHandshakeDoneData struct {
	Err                []byte `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	TlsVersion         uint32 `protobuf:"varint,2,opt,name=tls_version,json=tlsVersion,proto3" json:"tls_version,omitempty"`
	CipherSuite        uint32 `protobuf:"varint,3,opt,name=cipher_suite,json=cipherSuite,proto3" json:"cipher_suite,omitempty"`
	ServerName         string `protobuf:"bytes,4,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
	NegotiatedProtocol string `protobuf:"bytes,5,opt,name=negotiated_protocol,json=negotiatedProtocol,proto3" json:"negotiated_protocol,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPTLSHandshakeDoneData) Descriptor deprecated

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

Deprecated: Use HTTPTLSHandshakeDoneData.ProtoReflect.Descriptor instead.

func (*HTTPTLSHandshakeDoneData) GetCipherSuite

func (x *HTTPTLSHandshakeDoneData) GetCipherSuite() uint32

func (*HTTPTLSHandshakeDoneData) GetErr

func (x *HTTPTLSHandshakeDoneData) GetErr() []byte

func (*HTTPTLSHandshakeDoneData) GetNegotiatedProtocol

func (x *HTTPTLSHandshakeDoneData) GetNegotiatedProtocol() string

func (*HTTPTLSHandshakeDoneData) GetServerName

func (x *HTTPTLSHandshakeDoneData) GetServerName() string

func (*HTTPTLSHandshakeDoneData) GetTlsVersion

func (x *HTTPTLSHandshakeDoneData) GetTlsVersion() uint32

func (*HTTPTLSHandshakeDoneData) ProtoMessage

func (*HTTPTLSHandshakeDoneData) ProtoMessage()

func (*HTTPTLSHandshakeDoneData) ProtoReflect

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

func (*HTTPTLSHandshakeDoneData) Reset

func (x *HTTPTLSHandshakeDoneData) Reset()

func (*HTTPTLSHandshakeDoneData) String

func (x *HTTPTLSHandshakeDoneData) String() string

type HTTPTraceEvent

type HTTPTraceEvent struct {
	Code HTTPTraceEventCode `protobuf:"varint,1,opt,name=code,proto3,enum=encore.engine.trace.HTTPTraceEventCode" json:"code,omitempty"`
	Time uint64             `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	// Types that are assignable to Data:
	//
	//	*HTTPTraceEvent_GetConn
	//	*HTTPTraceEvent_GotConn
	//	*HTTPTraceEvent_Got_1XxResponse
	//	*HTTPTraceEvent_DnsStart
	//	*HTTPTraceEvent_DnsDone
	//	*HTTPTraceEvent_ConnectStart
	//	*HTTPTraceEvent_ConnectDone
	//	*HTTPTraceEvent_TlsHandshakeDone
	//	*HTTPTraceEvent_WroteRequest
	Data isHTTPTraceEvent_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*HTTPTraceEvent) Descriptor deprecated

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

Deprecated: Use HTTPTraceEvent.ProtoReflect.Descriptor instead.

func (*HTTPTraceEvent) GetCode

func (x *HTTPTraceEvent) GetCode() HTTPTraceEventCode

func (*HTTPTraceEvent) GetConnectDone

func (x *HTTPTraceEvent) GetConnectDone() *HTTPConnectDoneData

func (*HTTPTraceEvent) GetConnectStart

func (x *HTTPTraceEvent) GetConnectStart() *HTTPConnectStartData

func (*HTTPTraceEvent) GetData

func (m *HTTPTraceEvent) GetData() isHTTPTraceEvent_Data

func (*HTTPTraceEvent) GetDnsDone

func (x *HTTPTraceEvent) GetDnsDone() *HTTPDNSDoneData

func (*HTTPTraceEvent) GetDnsStart

func (x *HTTPTraceEvent) GetDnsStart() *HTTPDNSStartData

func (*HTTPTraceEvent) GetGetConn

func (x *HTTPTraceEvent) GetGetConn() *HTTPGetConnData

func (*HTTPTraceEvent) GetGotConn

func (x *HTTPTraceEvent) GetGotConn() *HTTPGotConnData

func (*HTTPTraceEvent) GetGot_1XxResponse

func (x *HTTPTraceEvent) GetGot_1XxResponse() *HTTPGot1XxResponseData

func (*HTTPTraceEvent) GetTime

func (x *HTTPTraceEvent) GetTime() uint64

func (*HTTPTraceEvent) GetTlsHandshakeDone

func (x *HTTPTraceEvent) GetTlsHandshakeDone() *HTTPTLSHandshakeDoneData

func (*HTTPTraceEvent) GetWroteRequest

func (x *HTTPTraceEvent) GetWroteRequest() *HTTPWroteRequestData

func (*HTTPTraceEvent) ProtoMessage

func (*HTTPTraceEvent) ProtoMessage()

func (*HTTPTraceEvent) ProtoReflect

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

func (*HTTPTraceEvent) Reset

func (x *HTTPTraceEvent) Reset()

func (*HTTPTraceEvent) String

func (x *HTTPTraceEvent) String() string

type HTTPTraceEventCode

type HTTPTraceEventCode int32
const (
	HTTPTraceEventCode_UNKNOWN                 HTTPTraceEventCode = 0
	HTTPTraceEventCode_GET_CONN                HTTPTraceEventCode = 1
	HTTPTraceEventCode_GOT_CONN                HTTPTraceEventCode = 2
	HTTPTraceEventCode_GOT_FIRST_RESPONSE_BYTE HTTPTraceEventCode = 3
	HTTPTraceEventCode_GOT_1XX_RESPONSE        HTTPTraceEventCode = 4
	HTTPTraceEventCode_DNS_START               HTTPTraceEventCode = 5
	HTTPTraceEventCode_DNS_DONE                HTTPTraceEventCode = 6
	HTTPTraceEventCode_CONNECT_START           HTTPTraceEventCode = 7
	HTTPTraceEventCode_CONNECT_DONE            HTTPTraceEventCode = 8
	HTTPTraceEventCode_TLS_HANDSHAKE_START     HTTPTraceEventCode = 9
	HTTPTraceEventCode_TLS_HANDSHAKE_DONE      HTTPTraceEventCode = 10
	HTTPTraceEventCode_WROTE_HEADERS           HTTPTraceEventCode = 11
	HTTPTraceEventCode_WROTE_REQUEST           HTTPTraceEventCode = 12
	HTTPTraceEventCode_WAIT_100_CONTINUE       HTTPTraceEventCode = 13
)

func (HTTPTraceEventCode) Descriptor

func (HTTPTraceEventCode) Enum

func (HTTPTraceEventCode) EnumDescriptor deprecated

func (HTTPTraceEventCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use HTTPTraceEventCode.Descriptor instead.

func (HTTPTraceEventCode) Number

func (HTTPTraceEventCode) String

func (x HTTPTraceEventCode) String() string

func (HTTPTraceEventCode) Type

type HTTPTraceEvent_ConnectDone

type HTTPTraceEvent_ConnectDone struct {
	ConnectDone *HTTPConnectDoneData `protobuf:"bytes,9,opt,name=connect_done,json=connectDone,proto3,oneof"`
}

type HTTPTraceEvent_ConnectStart

type HTTPTraceEvent_ConnectStart struct {
	ConnectStart *HTTPConnectStartData `protobuf:"bytes,8,opt,name=connect_start,json=connectStart,proto3,oneof"`
}

type HTTPTraceEvent_DnsDone

type HTTPTraceEvent_DnsDone struct {
	DnsDone *HTTPDNSDoneData `protobuf:"bytes,7,opt,name=dns_done,json=dnsDone,proto3,oneof"`
}

type HTTPTraceEvent_DnsStart

type HTTPTraceEvent_DnsStart struct {
	DnsStart *HTTPDNSStartData `protobuf:"bytes,6,opt,name=dns_start,json=dnsStart,proto3,oneof"`
}

type HTTPTraceEvent_GetConn

type HTTPTraceEvent_GetConn struct {
	GetConn *HTTPGetConnData `protobuf:"bytes,3,opt,name=get_conn,json=getConn,proto3,oneof"`
}

type HTTPTraceEvent_GotConn

type HTTPTraceEvent_GotConn struct {
	GotConn *HTTPGotConnData `protobuf:"bytes,4,opt,name=got_conn,json=gotConn,proto3,oneof"`
}

type HTTPTraceEvent_Got_1XxResponse

type HTTPTraceEvent_Got_1XxResponse struct {
	Got_1XxResponse *HTTPGot1XxResponseData `protobuf:"bytes,5,opt,name=got_1xx_response,json=got1xxResponse,proto3,oneof"`
}

type HTTPTraceEvent_TlsHandshakeDone

type HTTPTraceEvent_TlsHandshakeDone struct {
	TlsHandshakeDone *HTTPTLSHandshakeDoneData `protobuf:"bytes,10,opt,name=tls_handshake_done,json=tlsHandshakeDone,proto3,oneof"`
}

type HTTPTraceEvent_WroteRequest

type HTTPTraceEvent_WroteRequest struct {
	WroteRequest *HTTPWroteRequestData `protobuf:"bytes,11,opt,name=wrote_request,json=wroteRequest,proto3,oneof"`
}

type HTTPWroteRequestData

type HTTPWroteRequestData struct {
	Err []byte `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPWroteRequestData) Descriptor deprecated

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

Deprecated: Use HTTPWroteRequestData.ProtoReflect.Descriptor instead.

func (*HTTPWroteRequestData) GetErr

func (x *HTTPWroteRequestData) GetErr() []byte

func (*HTTPWroteRequestData) ProtoMessage

func (*HTTPWroteRequestData) ProtoMessage()

func (*HTTPWroteRequestData) ProtoReflect

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

func (*HTTPWroteRequestData) Reset

func (x *HTTPWroteRequestData) Reset()

func (*HTTPWroteRequestData) String

func (x *HTTPWroteRequestData) String() string

type LogField

type LogField struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Value:
	//
	//	*LogField_ErrorWithoutStack
	//	*LogField_ErrorWithStack
	//	*LogField_Str
	//	*LogField_Bool
	//	*LogField_Time
	//	*LogField_Dur
	//	*LogField_Uuid
	//	*LogField_Json
	//	*LogField_Int
	//	*LogField_Uint
	//	*LogField_Float32
	//	*LogField_Float64
	Value isLogField_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*LogField) Descriptor deprecated

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

Deprecated: Use LogField.ProtoReflect.Descriptor instead.

func (*LogField) GetBool

func (x *LogField) GetBool() bool

func (*LogField) GetDur

func (x *LogField) GetDur() int64

func (*LogField) GetErrorWithStack

func (x *LogField) GetErrorWithStack() *ErrWithStack

func (*LogField) GetErrorWithoutStack

func (x *LogField) GetErrorWithoutStack() string

func (*LogField) GetFloat32

func (x *LogField) GetFloat32() float32

func (*LogField) GetFloat64

func (x *LogField) GetFloat64() float64

func (*LogField) GetInt

func (x *LogField) GetInt() int64

func (*LogField) GetJson

func (x *LogField) GetJson() []byte

func (*LogField) GetKey

func (x *LogField) GetKey() string

func (*LogField) GetStr

func (x *LogField) GetStr() string

func (*LogField) GetTime

func (x *LogField) GetTime() *timestamppb.Timestamp

func (*LogField) GetUint

func (x *LogField) GetUint() uint64

func (*LogField) GetUuid

func (x *LogField) GetUuid() []byte

func (*LogField) GetValue

func (m *LogField) GetValue() isLogField_Value

func (*LogField) ProtoMessage

func (*LogField) ProtoMessage()

func (*LogField) ProtoReflect

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

func (*LogField) Reset

func (x *LogField) Reset()

func (*LogField) String

func (x *LogField) String() string

type LogField_Bool

type LogField_Bool struct {
	Bool bool `protobuf:"varint,4,opt,name=bool,proto3,oneof"`
}

type LogField_Dur

type LogField_Dur struct {
	Dur int64 `protobuf:"varint,6,opt,name=dur,proto3,oneof"`
}

type LogField_ErrorWithStack

type LogField_ErrorWithStack struct {
	ErrorWithStack *ErrWithStack `protobuf:"bytes,13,opt,name=error_with_stack,json=errorWithStack,proto3,oneof"`
}

type LogField_ErrorWithoutStack

type LogField_ErrorWithoutStack struct {
	ErrorWithoutStack string `protobuf:"bytes,2,opt,name=error_without_stack,json=errorWithoutStack,proto3,oneof"` // deprecated: use error_with_stack
}

type LogField_Float32

type LogField_Float32 struct {
	Float32 float32 `protobuf:"fixed32,11,opt,name=float32,proto3,oneof"`
}

type LogField_Float64

type LogField_Float64 struct {
	Float64 float64 `protobuf:"fixed64,12,opt,name=float64,proto3,oneof"`
}

type LogField_Int

type LogField_Int struct {
	Int int64 `protobuf:"varint,9,opt,name=int,proto3,oneof"`
}

type LogField_Json

type LogField_Json struct {
	Json []byte `protobuf:"bytes,8,opt,name=json,proto3,oneof"`
}

type LogField_Str

type LogField_Str struct {
	Str string `protobuf:"bytes,3,opt,name=str,proto3,oneof"`
}

type LogField_Time

type LogField_Time struct {
	Time *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=time,proto3,oneof"`
}

type LogField_Uint

type LogField_Uint struct {
	Uint uint64 `protobuf:"varint,10,opt,name=uint,proto3,oneof"`
}

type LogField_Uuid

type LogField_Uuid struct {
	Uuid []byte `protobuf:"bytes,7,opt,name=uuid,proto3,oneof"`
}

type LogMessage

type LogMessage struct {
	SpanId uint64           `protobuf:"varint,1,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	Goid   uint32           `protobuf:"varint,2,opt,name=goid,proto3" json:"goid,omitempty"`
	Time   uint64           `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	Level  LogMessage_Level `protobuf:"varint,4,opt,name=level,proto3,enum=encore.engine.trace.LogMessage_Level" json:"level,omitempty"`
	Msg    string           `protobuf:"bytes,5,opt,name=msg,proto3" json:"msg,omitempty"`
	Fields []*LogField      `protobuf:"bytes,6,rep,name=fields,proto3" json:"fields,omitempty"`
	Stack  *StackTrace      `protobuf:"bytes,7,opt,name=stack,proto3" json:"stack,omitempty"` // null if unavailable
	// contains filtered or unexported fields
}

func (*LogMessage) Descriptor deprecated

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

Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.

func (*LogMessage) GetFields

func (x *LogMessage) GetFields() []*LogField

func (*LogMessage) GetGoid

func (x *LogMessage) GetGoid() uint32

func (*LogMessage) GetLevel

func (x *LogMessage) GetLevel() LogMessage_Level

func (*LogMessage) GetMsg

func (x *LogMessage) GetMsg() string

func (*LogMessage) GetSpanId

func (x *LogMessage) GetSpanId() uint64

func (*LogMessage) GetStack

func (x *LogMessage) GetStack() *StackTrace

func (*LogMessage) GetTime

func (x *LogMessage) GetTime() uint64

func (*LogMessage) ProtoMessage

func (*LogMessage) ProtoMessage()

func (*LogMessage) ProtoReflect

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

func (*LogMessage) Reset

func (x *LogMessage) Reset()

func (*LogMessage) String

func (x *LogMessage) String() string

type LogMessage_Level

type LogMessage_Level int32

Note: These values don't match the values used by the binary trace protocol, as these values are stored in persisted traces and therefore must maintain backwards compatibility. The binary trace protocol is versioned and doesn't have the same limitations.

const (
	LogMessage_DEBUG LogMessage_Level = 0
	LogMessage_INFO  LogMessage_Level = 1
	LogMessage_ERROR LogMessage_Level = 2
	LogMessage_WARN  LogMessage_Level = 3
	LogMessage_TRACE LogMessage_Level = 4
)

func (LogMessage_Level) Descriptor

func (LogMessage_Level) Enum

func (LogMessage_Level) EnumDescriptor deprecated

func (LogMessage_Level) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogMessage_Level.Descriptor instead.

func (LogMessage_Level) Number

func (LogMessage_Level) String

func (x LogMessage_Level) String() string

func (LogMessage_Level) Type

type PubsubMsgPublished

type PubsubMsgPublished struct {
	Goid      uint64      `protobuf:"varint,1,opt,name=goid,proto3" json:"goid,omitempty"`
	StartTime uint64      `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   uint64      `protobuf:"varint,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Topic     string      `protobuf:"bytes,5,opt,name=topic,proto3" json:"topic,omitempty"`
	Message   []byte      `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	MessageId string      `protobuf:"bytes,7,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Err       []byte      `protobuf:"bytes,8,opt,name=err,proto3" json:"err,omitempty"`
	Stack     *StackTrace `protobuf:"bytes,9,opt,name=stack,proto3" json:"stack,omitempty"`
	// contains filtered or unexported fields
}

func (*PubsubMsgPublished) Descriptor deprecated

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

Deprecated: Use PubsubMsgPublished.ProtoReflect.Descriptor instead.

func (*PubsubMsgPublished) GetEndTime

func (x *PubsubMsgPublished) GetEndTime() uint64

func (*PubsubMsgPublished) GetErr

func (x *PubsubMsgPublished) GetErr() []byte

func (*PubsubMsgPublished) GetGoid

func (x *PubsubMsgPublished) GetGoid() uint64

func (*PubsubMsgPublished) GetMessage

func (x *PubsubMsgPublished) GetMessage() []byte

func (*PubsubMsgPublished) GetMessageId

func (x *PubsubMsgPublished) GetMessageId() string

func (*PubsubMsgPublished) GetStack

func (x *PubsubMsgPublished) GetStack() *StackTrace

func (*PubsubMsgPublished) GetStartTime

func (x *PubsubMsgPublished) GetStartTime() uint64

func (*PubsubMsgPublished) GetTopic

func (x *PubsubMsgPublished) GetTopic() string

func (*PubsubMsgPublished) ProtoMessage

func (*PubsubMsgPublished) ProtoMessage()

func (*PubsubMsgPublished) ProtoReflect

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

func (*PubsubMsgPublished) Reset

func (x *PubsubMsgPublished) Reset()

func (*PubsubMsgPublished) String

func (x *PubsubMsgPublished) String() string

type RPCCall

type RPCCall struct {
	SpanId    uint64      `protobuf:"varint,1,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	Goid      uint32      `protobuf:"varint,2,opt,name=goid,proto3" json:"goid,omitempty"`
	DefLoc    int32       `protobuf:"varint,4,opt,name=def_loc,json=defLoc,proto3" json:"def_loc,omitempty"`
	StartTime uint64      `protobuf:"varint,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   uint64      `protobuf:"varint,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Err       []byte      `protobuf:"bytes,7,opt,name=err,proto3" json:"err,omitempty"`
	Stack     *StackTrace `protobuf:"bytes,8,opt,name=stack,proto3" json:"stack,omitempty"` // where it was called (null if unavailable)
	// contains filtered or unexported fields
}

func (*RPCCall) Descriptor deprecated

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

Deprecated: Use RPCCall.ProtoReflect.Descriptor instead.

func (*RPCCall) GetDefLoc

func (x *RPCCall) GetDefLoc() int32

func (*RPCCall) GetEndTime

func (x *RPCCall) GetEndTime() uint64

func (*RPCCall) GetErr

func (x *RPCCall) GetErr() []byte

func (*RPCCall) GetGoid

func (x *RPCCall) GetGoid() uint32

func (*RPCCall) GetSpanId

func (x *RPCCall) GetSpanId() uint64

func (*RPCCall) GetStack

func (x *RPCCall) GetStack() *StackTrace

func (*RPCCall) GetStartTime

func (x *RPCCall) GetStartTime() uint64

func (*RPCCall) ProtoMessage

func (*RPCCall) ProtoMessage()

func (*RPCCall) ProtoReflect

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

func (*RPCCall) Reset

func (x *RPCCall) Reset()

func (*RPCCall) String

func (x *RPCCall) String() string

type Request

type Request struct {
	TraceId       *TraceID     `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	SpanId        uint64       `protobuf:"varint,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	ParentSpanId  uint64       `protobuf:"varint,3,opt,name=parent_span_id,json=parentSpanId,proto3" json:"parent_span_id,omitempty"`
	ParentTraceId *TraceID     `protobuf:"bytes,32,opt,name=parent_trace_id,json=parentTraceId,proto3" json:"parent_trace_id,omitempty"`
	Goid          uint32       `protobuf:"varint,4,opt,name=goid,proto3" json:"goid,omitempty"`
	StartTime     uint64       `protobuf:"varint,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime       uint64       `protobuf:"varint,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	DefLoc        int32        `protobuf:"varint,8,opt,name=def_loc,json=defLoc,proto3" json:"def_loc,omitempty"`
	Err           []byte       `protobuf:"bytes,11,opt,name=err,proto3" json:"err,omitempty"`
	Events        []*Event     `protobuf:"bytes,12,rep,name=events,proto3" json:"events,omitempty"`
	Type          Request_Type `protobuf:"varint,14,opt,name=type,proto3,enum=encore.engine.trace.Request_Type" json:"type,omitempty"`
	ErrStack      *StackTrace  `protobuf:"bytes,15,opt,name=err_stack,json=errStack,proto3" json:"err_stack,omitempty"`       // null if unavailable
	PanicStack    *StackTrace  `protobuf:"bytes,34,opt,name=panic_stack,json=panicStack,proto3" json:"panic_stack,omitempty"` // null if unavailable
	// abs_start_time is the absolute unix timestamp
	// (in nanosecond resolution) of when the request started.
	AbsStartTime uint64 `protobuf:"varint,16,opt,name=abs_start_time,json=absStartTime,proto3" json:"abs_start_time,omitempty"`
	ServiceName  string `protobuf:"bytes,17,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	EndpointName string `protobuf:"bytes,18,opt,name=endpoint_name,json=endpointName,proto3" json:"endpoint_name,omitempty"`
	// Fields set if Type == PUBSUB_MSG
	TopicName        string `protobuf:"bytes,19,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	SubscriptionName string `protobuf:"bytes,20,opt,name=subscription_name,json=subscriptionName,proto3" json:"subscription_name,omitempty"`
	MessageId        string `protobuf:"bytes,21,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Attempt          uint32 `protobuf:"varint,22,opt,name=attempt,proto3" json:"attempt,omitempty"`
	PublishTime      uint64 `protobuf:"varint,23,opt,name=publish_time,json=publishTime,proto3" json:"publish_time,omitempty"`
	// Fields set if Type == RPC or AUTH
	Inputs             [][]byte          `protobuf:"bytes,9,rep,name=inputs,proto3" json:"inputs,omitempty"`    // Deprecated: use request_payload and path_params
	Outputs            [][]byte          `protobuf:"bytes,10,rep,name=outputs,proto3" json:"outputs,omitempty"` // Deprecated: use response_payload and uid
	Uid                string            `protobuf:"bytes,13,opt,name=uid,proto3" json:"uid,omitempty"`
	HttpMethod         string            `protobuf:"bytes,24,opt,name=http_method,json=httpMethod,proto3" json:"http_method,omitempty"`
	Path               string            `protobuf:"bytes,25,opt,name=path,proto3" json:"path,omitempty"`
	PathParams         []string          `protobuf:"bytes,26,rep,name=path_params,json=pathParams,proto3" json:"path_params,omitempty"`
	RequestPayload     []byte            `protobuf:"bytes,27,opt,name=request_payload,json=requestPayload,proto3" json:"request_payload,omitempty"`
	ResponsePayload    []byte            `protobuf:"bytes,28,opt,name=response_payload,json=responsePayload,proto3" json:"response_payload,omitempty"`
	RawRequestHeaders  map[string]string `` /* 203-byte string literal not displayed */
	RawResponseHeaders map[string]string `` /* 206-byte string literal not displayed */
	// external_request_id is the value of the X-Request-ID header.
	ExternalRequestId     string `protobuf:"bytes,31,opt,name=external_request_id,json=externalRequestId,proto3" json:"external_request_id,omitempty"`
	ExternalCorrelationId string `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetAbsStartTime

func (x *Request) GetAbsStartTime() uint64

func (*Request) GetAttempt

func (x *Request) GetAttempt() uint32

func (*Request) GetDefLoc

func (x *Request) GetDefLoc() int32

func (*Request) GetEndTime

func (x *Request) GetEndTime() uint64

func (*Request) GetEndpointName

func (x *Request) GetEndpointName() string

func (*Request) GetErr

func (x *Request) GetErr() []byte

func (*Request) GetErrStack

func (x *Request) GetErrStack() *StackTrace

func (*Request) GetEvents

func (x *Request) GetEvents() []*Event

func (*Request) GetExternalCorrelationId

func (x *Request) GetExternalCorrelationId() string

func (*Request) GetExternalRequestId

func (x *Request) GetExternalRequestId() string

func (*Request) GetGoid

func (x *Request) GetGoid() uint32

func (*Request) GetHttpMethod

func (x *Request) GetHttpMethod() string

func (*Request) GetInputs

func (x *Request) GetInputs() [][]byte

func (*Request) GetMessageId

func (x *Request) GetMessageId() string

func (*Request) GetOutputs

func (x *Request) GetOutputs() [][]byte

func (*Request) GetPanicStack

func (x *Request) GetPanicStack() *StackTrace

func (*Request) GetParentSpanId

func (x *Request) GetParentSpanId() uint64

func (*Request) GetParentTraceId

func (x *Request) GetParentTraceId() *TraceID

func (*Request) GetPath

func (x *Request) GetPath() string

func (*Request) GetPathParams

func (x *Request) GetPathParams() []string

func (*Request) GetPublishTime

func (x *Request) GetPublishTime() uint64

func (*Request) GetRawRequestHeaders

func (x *Request) GetRawRequestHeaders() map[string]string

func (*Request) GetRawResponseHeaders

func (x *Request) GetRawResponseHeaders() map[string]string

func (*Request) GetRequestPayload

func (x *Request) GetRequestPayload() []byte

func (*Request) GetResponsePayload

func (x *Request) GetResponsePayload() []byte

func (*Request) GetServiceName

func (x *Request) GetServiceName() string

func (*Request) GetSpanId

func (x *Request) GetSpanId() uint64

func (*Request) GetStartTime

func (x *Request) GetStartTime() uint64

func (*Request) GetSubscriptionName

func (x *Request) GetSubscriptionName() string

func (*Request) GetTopicName

func (x *Request) GetTopicName() string

func (*Request) GetTraceId

func (x *Request) GetTraceId() *TraceID

func (*Request) GetType

func (x *Request) GetType() Request_Type

func (*Request) GetUid

func (x *Request) GetUid() string

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

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

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type Request_Type

type Request_Type int32
const (
	Request_RPC        Request_Type = 0
	Request_AUTH       Request_Type = 1
	Request_PUBSUB_MSG Request_Type = 2
)

func (Request_Type) Descriptor

func (Request_Type) Enum

func (x Request_Type) Enum() *Request_Type

func (Request_Type) EnumDescriptor deprecated

func (Request_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Request_Type.Descriptor instead.

func (Request_Type) Number

func (Request_Type) String

func (x Request_Type) String() string

func (Request_Type) Type

type ServiceInit

type ServiceInit struct {
	Goid      uint64      `protobuf:"varint,1,opt,name=goid,proto3" json:"goid,omitempty"`
	DefLoc    int32       `protobuf:"varint,2,opt,name=def_loc,json=defLoc,proto3" json:"def_loc,omitempty"`
	StartTime uint64      `protobuf:"varint,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   uint64      `protobuf:"varint,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Service   string      `protobuf:"bytes,5,opt,name=service,proto3" json:"service,omitempty"`
	Err       []byte      `protobuf:"bytes,6,opt,name=err,proto3" json:"err,omitempty"`
	ErrStack  *StackTrace `protobuf:"bytes,7,opt,name=err_stack,json=errStack,proto3" json:"err_stack,omitempty"` // null if not an error
	// contains filtered or unexported fields
}

func (*ServiceInit) Descriptor deprecated

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

Deprecated: Use ServiceInit.ProtoReflect.Descriptor instead.

func (*ServiceInit) GetDefLoc

func (x *ServiceInit) GetDefLoc() int32

func (*ServiceInit) GetEndTime

func (x *ServiceInit) GetEndTime() uint64

func (*ServiceInit) GetErr

func (x *ServiceInit) GetErr() []byte

func (*ServiceInit) GetErrStack

func (x *ServiceInit) GetErrStack() *StackTrace

func (*ServiceInit) GetGoid

func (x *ServiceInit) GetGoid() uint64

func (*ServiceInit) GetService

func (x *ServiceInit) GetService() string

func (*ServiceInit) GetStartTime

func (x *ServiceInit) GetStartTime() uint64

func (*ServiceInit) ProtoMessage

func (*ServiceInit) ProtoMessage()

func (*ServiceInit) ProtoReflect

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

func (*ServiceInit) Reset

func (x *ServiceInit) Reset()

func (*ServiceInit) String

func (x *ServiceInit) String() string

type StackFrame

type StackFrame struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Func     string `protobuf:"bytes,2,opt,name=func,proto3" json:"func,omitempty"`
	Line     int32  `protobuf:"varint,3,opt,name=line,proto3" json:"line,omitempty"`
	// contains filtered or unexported fields
}

func (*StackFrame) Descriptor deprecated

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

Deprecated: Use StackFrame.ProtoReflect.Descriptor instead.

func (*StackFrame) GetFilename

func (x *StackFrame) GetFilename() string

func (*StackFrame) GetFunc

func (x *StackFrame) GetFunc() string

func (*StackFrame) GetLine

func (x *StackFrame) GetLine() int32

func (*StackFrame) ProtoMessage

func (*StackFrame) ProtoMessage()

func (*StackFrame) ProtoReflect

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

func (*StackFrame) Reset

func (x *StackFrame) Reset()

func (*StackFrame) String

func (x *StackFrame) String() string

type StackTrace

type StackTrace struct {
	Pcs    []int64       `protobuf:"varint,1,rep,packed,name=pcs,proto3" json:"pcs,omitempty"`
	Frames []*StackFrame `protobuf:"bytes,2,rep,name=frames,proto3" json:"frames,omitempty"`
	// contains filtered or unexported fields
}

func (*StackTrace) Descriptor deprecated

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

Deprecated: Use StackTrace.ProtoReflect.Descriptor instead.

func (*StackTrace) GetFrames

func (x *StackTrace) GetFrames() []*StackFrame

func (*StackTrace) GetPcs

func (x *StackTrace) GetPcs() []int64

func (*StackTrace) ProtoMessage

func (*StackTrace) ProtoMessage()

func (*StackTrace) ProtoReflect

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

func (*StackTrace) Reset

func (x *StackTrace) Reset()

func (*StackTrace) String

func (x *StackTrace) String() string

type TraceID

type TraceID struct {
	High uint64 `protobuf:"varint,1,opt,name=high,proto3" json:"high,omitempty"`
	Low  uint64 `protobuf:"varint,2,opt,name=low,proto3" json:"low,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceID) Descriptor deprecated

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

Deprecated: Use TraceID.ProtoReflect.Descriptor instead.

func (*TraceID) GetHigh

func (x *TraceID) GetHigh() uint64

func (*TraceID) GetLow

func (x *TraceID) GetLow() uint64

func (*TraceID) IsZero

func (id *TraceID) IsZero() bool

func (*TraceID) ProtoMessage

func (*TraceID) ProtoMessage()

func (*TraceID) ProtoReflect

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

func (*TraceID) Reset

func (x *TraceID) Reset()

func (*TraceID) String

func (x *TraceID) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL