Documentation
¶
Index ¶
- Variables
- func RegisterStreamExporterServer(s *grpc.Server, srv StreamExporterServer)
- func RegisterUnaryExporterServer(s *grpc.Server, srv UnaryExporterServer)
- type AttributeValue
- func (*AttributeValue) Descriptor() ([]byte, []int)
- func (m *AttributeValue) GetBoolValue() bool
- func (m *AttributeValue) GetDoubleValue() float64
- func (m *AttributeValue) GetIntValue() int64
- func (m *AttributeValue) GetStringValue() string
- func (m *AttributeValue) GetValue() isAttributeValue_Value
- func (*AttributeValue) ProtoMessage()
- func (m *AttributeValue) Reset()
- func (m *AttributeValue) String() string
- func (m *AttributeValue) XXX_DiscardUnknown()
- func (m *AttributeValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AttributeValue) XXX_Merge(src proto.Message)
- func (*AttributeValue) XXX_OneofWrappers() []interface{}
- func (m *AttributeValue) XXX_Size() int
- func (m *AttributeValue) XXX_Unmarshal(b []byte) error
- type AttributeValue_BoolValue
- type AttributeValue_DoubleValue
- type AttributeValue_IntValue
- type AttributeValue_StringValue
- type Capabilities
- type CompressionMethod
- type ExportRequest
- func (*ExportRequest) Descriptor() ([]byte, []int)
- func (m *ExportRequest) GetId() uint64
- func (m *ExportRequest) GetMetricBatch() []*MetricBatch
- func (m *ExportRequest) GetSpanBatch() []*SpanBatch
- func (*ExportRequest) ProtoMessage()
- func (m *ExportRequest) Reset()
- func (m *ExportRequest) String() string
- func (m *ExportRequest) XXX_DiscardUnknown()
- func (m *ExportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExportRequest) XXX_Merge(src proto.Message)
- func (m *ExportRequest) XXX_Size() int
- func (m *ExportRequest) XXX_Unmarshal(b []byte) error
- type ExportResponse
- func (*ExportResponse) Descriptor() ([]byte, []int)
- func (m *ExportResponse) GetId() uint64
- func (m *ExportResponse) GetResultCode() ExportResponse_ResultCode
- func (*ExportResponse) ProtoMessage()
- func (m *ExportResponse) Reset()
- func (m *ExportResponse) String() string
- func (m *ExportResponse) XXX_DiscardUnknown()
- func (m *ExportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExportResponse) XXX_Merge(src proto.Message)
- func (m *ExportResponse) XXX_Size() int
- func (m *ExportResponse) XXX_Unmarshal(b []byte) error
- type ExportResponse_ResultCode
- type Generator
- type HelloRequest
- func (*HelloRequest) Descriptor() ([]byte, []int)
- func (*HelloRequest) ProtoMessage()
- func (m *HelloRequest) Reset()
- func (m *HelloRequest) String() string
- func (m *HelloRequest) XXX_DiscardUnknown()
- func (m *HelloRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HelloRequest) XXX_Merge(src proto.Message)
- func (m *HelloRequest) XXX_Size() int
- func (m *HelloRequest) XXX_Unmarshal(b []byte) error
- type HelloResponse
- func (*HelloResponse) Descriptor() ([]byte, []int)
- func (*HelloResponse) ProtoMessage()
- func (m *HelloResponse) Reset()
- func (m *HelloResponse) String() string
- func (m *HelloResponse) XXX_DiscardUnknown()
- func (m *HelloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HelloResponse) XXX_Merge(src proto.Message)
- func (m *HelloResponse) XXX_Size() int
- func (m *HelloResponse) XXX_Unmarshal(b []byte) error
- type LibraryInfo
- func (*LibraryInfo) Descriptor() ([]byte, []int)
- func (m *LibraryInfo) GetCoreLibraryVersion() string
- func (m *LibraryInfo) GetExporterVersion() string
- func (m *LibraryInfo) GetLanguage() LibraryInfo_Language
- func (*LibraryInfo) ProtoMessage()
- func (m *LibraryInfo) Reset()
- func (m *LibraryInfo) String() string
- func (m *LibraryInfo) XXX_DiscardUnknown()
- func (m *LibraryInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LibraryInfo) XXX_Merge(src proto.Message)
- func (m *LibraryInfo) XXX_Size() int
- func (m *LibraryInfo) XXX_Unmarshal(b []byte) error
- type LibraryInfo_Language
- type Metric
- func (*Metric) Descriptor() ([]byte, []int)
- func (*Metric) ProtoMessage()
- func (m *Metric) Reset()
- func (m *Metric) String() string
- func (m *Metric) XXX_DiscardUnknown()
- func (m *Metric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Metric) XXX_Merge(src proto.Message)
- func (m *Metric) XXX_Size() int
- func (m *Metric) XXX_Unmarshal(b []byte) error
- type MetricBatch
- func (*MetricBatch) Descriptor() ([]byte, []int)
- func (m *MetricBatch) GetMetrics() []*Metric
- func (m *MetricBatch) GetResource() *Resource
- func (*MetricBatch) ProtoMessage()
- func (m *MetricBatch) Reset()
- func (m *MetricBatch) String() string
- func (m *MetricBatch) XXX_DiscardUnknown()
- func (m *MetricBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MetricBatch) XXX_Merge(src proto.Message)
- func (m *MetricBatch) XXX_Size() int
- func (m *MetricBatch) XXX_Unmarshal(b []byte) error
- type Module
- func (*Module) Descriptor() ([]byte, []int)
- func (m *Module) GetBuildId() string
- func (m *Module) GetModule() string
- func (*Module) ProtoMessage()
- func (m *Module) Reset()
- func (m *Module) String() string
- func (m *Module) XXX_DiscardUnknown()
- func (m *Module) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Module) XXX_Merge(src proto.Message)
- func (m *Module) XXX_Size() int
- func (m *Module) XXX_Unmarshal(b []byte) error
- type Node
- func (*Node) Descriptor() ([]byte, []int)
- func (m *Node) GetAttributes() map[string]*AttributeValue
- func (m *Node) GetIdentifier() *ProcessIdentifier
- func (m *Node) GetLibraryInfo() *LibraryInfo
- func (m *Node) GetServiceInfo() *ServiceInfo
- func (*Node) ProtoMessage()
- func (m *Node) Reset()
- func (m *Node) String() string
- func (m *Node) XXX_DiscardUnknown()
- func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Node) XXX_Merge(src proto.Message)
- func (m *Node) XXX_Size() int
- func (m *Node) XXX_Unmarshal(b []byte) error
- type ProcessIdentifier
- func (*ProcessIdentifier) Descriptor() ([]byte, []int)
- func (m *ProcessIdentifier) GetHostName() string
- func (m *ProcessIdentifier) GetPid() uint32
- func (m *ProcessIdentifier) GetStartTimeUnixnano() int64
- func (*ProcessIdentifier) ProtoMessage()
- func (m *ProcessIdentifier) Reset()
- func (m *ProcessIdentifier) String() string
- func (m *ProcessIdentifier) XXX_DiscardUnknown()
- func (m *ProcessIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessIdentifier) XXX_Merge(src proto.Message)
- func (m *ProcessIdentifier) XXX_Size() int
- func (m *ProcessIdentifier) XXX_Unmarshal(b []byte) error
- type RequestBody
- func (*RequestBody) Descriptor() ([]byte, []int)
- func (m *RequestBody) GetBody() isRequestBody_Body
- func (m *RequestBody) GetExport() *ExportRequest
- func (m *RequestBody) GetHello() *HelloRequest
- func (*RequestBody) ProtoMessage()
- func (m *RequestBody) Reset()
- func (m *RequestBody) String() string
- func (m *RequestBody) XXX_DiscardUnknown()
- func (m *RequestBody) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestBody) XXX_Merge(src proto.Message)
- func (*RequestBody) XXX_OneofWrappers() []interface{}
- func (m *RequestBody) XXX_Size() int
- func (m *RequestBody) XXX_Unmarshal(b []byte) error
- type RequestBody_Export
- type RequestBody_Hello
- type RequestHeader
- func (*RequestHeader) Descriptor() ([]byte, []int)
- func (m *RequestHeader) GetCompression() CompressionMethod
- func (m *RequestHeader) GetCompressionLevel() int32
- func (*RequestHeader) ProtoMessage()
- func (m *RequestHeader) Reset()
- func (m *RequestHeader) String() string
- func (m *RequestHeader) XXX_DiscardUnknown()
- func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestHeader) XXX_Merge(src proto.Message)
- func (m *RequestHeader) XXX_Size() int
- func (m *RequestHeader) XXX_Unmarshal(b []byte) error
- type Resource
- func (*Resource) Descriptor() ([]byte, []int)
- func (m *Resource) GetAttributes() map[string]*AttributeValue
- func (m *Resource) GetIdentifier() *ProcessIdentifier
- func (m *Resource) GetServiceInfo() *ServiceInfo
- func (*Resource) ProtoMessage()
- func (m *Resource) Reset()
- func (m *Resource) String() string
- func (m *Resource) XXX_DiscardUnknown()
- func (m *Resource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Resource) XXX_Merge(src proto.Message)
- func (m *Resource) XXX_Size() int
- func (m *Resource) XXX_Unmarshal(b []byte) error
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetBody() isResponse_Body
- func (m *Response) GetExport() *ExportResponse
- func (m *Response) GetHello() *HelloResponse
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) String() string
- func (m *Response) XXX_DiscardUnknown()
- func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response) XXX_Merge(src proto.Message)
- func (*Response) XXX_OneofWrappers() []interface{}
- func (m *Response) XXX_Size() int
- func (m *Response) XXX_Unmarshal(b []byte) error
- type Response_Export
- type Response_Hello
- type ServiceInfo
- func (*ServiceInfo) Descriptor() ([]byte, []int)
- func (m *ServiceInfo) GetName() string
- func (*ServiceInfo) ProtoMessage()
- func (m *ServiceInfo) Reset()
- func (m *ServiceInfo) String() string
- func (m *ServiceInfo) XXX_DiscardUnknown()
- func (m *ServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceInfo) XXX_Merge(src proto.Message)
- func (m *ServiceInfo) XXX_Size() int
- func (m *ServiceInfo) XXX_Unmarshal(b []byte) error
- type Span
- func (*Span) Descriptor() ([]byte, []int)
- func (m *Span) GetAttributes() map[string]*AttributeValue
- func (m *Span) GetChildSpanCount() *wrappers.UInt32Value
- func (m *Span) GetEndTimeUnixnano() int64
- func (m *Span) GetKind() Span_SpanKind
- func (m *Span) GetLinks() *Span_Links
- func (m *Span) GetName() string
- func (m *Span) GetParentSpanId() []byte
- func (m *Span) GetResource() *Resource
- func (m *Span) GetSameProcessAsParentSpan() *wrappers.BoolValue
- func (m *Span) GetSpanId() []byte
- func (m *Span) GetStackTrace() *StackTrace
- func (m *Span) GetStartTimeUnixnano() int64
- func (m *Span) GetStatus() *Status
- func (m *Span) GetTimeEvents() *Span_TimeEvents
- func (m *Span) GetTraceId() []byte
- func (m *Span) GetTracestate() *Span_Tracestate
- func (*Span) ProtoMessage()
- func (m *Span) Reset()
- func (m *Span) String() string
- func (m *Span) XXX_DiscardUnknown()
- func (m *Span) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Span) XXX_Merge(src proto.Message)
- func (m *Span) XXX_Size() int
- func (m *Span) XXX_Unmarshal(b []byte) error
- type SpanBatch
- func (*SpanBatch) Descriptor() ([]byte, []int)
- func (m *SpanBatch) GetResource() *Resource
- func (m *SpanBatch) GetSpans() []*Span
- func (*SpanBatch) ProtoMessage()
- func (m *SpanBatch) Reset()
- func (m *SpanBatch) String() string
- func (m *SpanBatch) XXX_DiscardUnknown()
- func (m *SpanBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SpanBatch) XXX_Merge(src proto.Message)
- func (m *SpanBatch) XXX_Size() int
- func (m *SpanBatch) XXX_Unmarshal(b []byte) error
- type Span_Link
- func (*Span_Link) Descriptor() ([]byte, []int)
- func (m *Span_Link) GetAttributes() map[string]*AttributeValue
- func (m *Span_Link) GetSpanId() []byte
- func (m *Span_Link) GetTraceId() []byte
- func (m *Span_Link) GetTracestate() *Span_Tracestate
- func (m *Span_Link) GetType() Span_Link_Type
- func (*Span_Link) ProtoMessage()
- func (m *Span_Link) Reset()
- func (m *Span_Link) String() string
- func (m *Span_Link) XXX_DiscardUnknown()
- func (m *Span_Link) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Span_Link) XXX_Merge(src proto.Message)
- func (m *Span_Link) XXX_Size() int
- func (m *Span_Link) XXX_Unmarshal(b []byte) error
- type Span_Link_Type
- type Span_Links
- func (*Span_Links) Descriptor() ([]byte, []int)
- func (m *Span_Links) GetDroppedLinksCount() int32
- func (m *Span_Links) GetLink() []*Span_Link
- func (*Span_Links) ProtoMessage()
- func (m *Span_Links) Reset()
- func (m *Span_Links) String() string
- func (m *Span_Links) XXX_DiscardUnknown()
- func (m *Span_Links) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Span_Links) XXX_Merge(src proto.Message)
- func (m *Span_Links) XXX_Size() int
- func (m *Span_Links) XXX_Unmarshal(b []byte) error
- type Span_SpanKind
- type Span_TimeEvent
- func (*Span_TimeEvent) Descriptor() ([]byte, []int)
- func (m *Span_TimeEvent) GetAnnotation() *Span_TimeEvent_Annotation
- func (m *Span_TimeEvent) GetMessageEvent() *Span_TimeEvent_MessageEvent
- func (m *Span_TimeEvent) GetTimeUnixnano() int64
- func (m *Span_TimeEvent) GetValue() isSpan_TimeEvent_Value
- func (*Span_TimeEvent) ProtoMessage()
- func (m *Span_TimeEvent) Reset()
- func (m *Span_TimeEvent) String() string
- func (m *Span_TimeEvent) XXX_DiscardUnknown()
- func (m *Span_TimeEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Span_TimeEvent) XXX_Merge(src proto.Message)
- func (*Span_TimeEvent) XXX_OneofWrappers() []interface{}
- func (m *Span_TimeEvent) XXX_Size() int
- func (m *Span_TimeEvent) XXX_Unmarshal(b []byte) error
- type Span_TimeEvent_Annotation
- func (*Span_TimeEvent_Annotation) Descriptor() ([]byte, []int)
- func (m *Span_TimeEvent_Annotation) GetAttributes() map[string]*AttributeValue
- func (m *Span_TimeEvent_Annotation) GetDescription() string
- func (*Span_TimeEvent_Annotation) ProtoMessage()
- func (m *Span_TimeEvent_Annotation) Reset()
- func (m *Span_TimeEvent_Annotation) String() string
- func (m *Span_TimeEvent_Annotation) XXX_DiscardUnknown()
- func (m *Span_TimeEvent_Annotation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Span_TimeEvent_Annotation) XXX_Merge(src proto.Message)
- func (m *Span_TimeEvent_Annotation) XXX_Size() int
- func (m *Span_TimeEvent_Annotation) XXX_Unmarshal(b []byte) error
- type Span_TimeEvent_Annotation_
- type Span_TimeEvent_MessageEvent
- func (*Span_TimeEvent_MessageEvent) Descriptor() ([]byte, []int)
- func (m *Span_TimeEvent_MessageEvent) GetCompressedSize() uint64
- func (m *Span_TimeEvent_MessageEvent) GetId() uint64
- func (m *Span_TimeEvent_MessageEvent) GetType() Span_TimeEvent_MessageEvent_Type
- func (m *Span_TimeEvent_MessageEvent) GetUncompressedSize() uint64
- func (*Span_TimeEvent_MessageEvent) ProtoMessage()
- func (m *Span_TimeEvent_MessageEvent) Reset()
- func (m *Span_TimeEvent_MessageEvent) String() string
- func (m *Span_TimeEvent_MessageEvent) XXX_DiscardUnknown()
- func (m *Span_TimeEvent_MessageEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Span_TimeEvent_MessageEvent) XXX_Merge(src proto.Message)
- func (m *Span_TimeEvent_MessageEvent) XXX_Size() int
- func (m *Span_TimeEvent_MessageEvent) XXX_Unmarshal(b []byte) error
- type Span_TimeEvent_MessageEvent_
- type Span_TimeEvent_MessageEvent_Type
- type Span_TimeEvents
- func (*Span_TimeEvents) Descriptor() ([]byte, []int)
- func (m *Span_TimeEvents) GetDroppedAnnotationsCount() int32
- func (m *Span_TimeEvents) GetDroppedMessageEventsCount() int32
- func (m *Span_TimeEvents) GetTimeEvent() []*Span_TimeEvent
- func (*Span_TimeEvents) ProtoMessage()
- func (m *Span_TimeEvents) Reset()
- func (m *Span_TimeEvents) String() string
- func (m *Span_TimeEvents) XXX_DiscardUnknown()
- func (m *Span_TimeEvents) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Span_TimeEvents) XXX_Merge(src proto.Message)
- func (m *Span_TimeEvents) XXX_Size() int
- func (m *Span_TimeEvents) XXX_Unmarshal(b []byte) error
- type Span_Tracestate
- func (*Span_Tracestate) Descriptor() ([]byte, []int)
- func (m *Span_Tracestate) GetEntries() []*Span_Tracestate_Entry
- func (*Span_Tracestate) ProtoMessage()
- func (m *Span_Tracestate) Reset()
- func (m *Span_Tracestate) String() string
- func (m *Span_Tracestate) XXX_DiscardUnknown()
- func (m *Span_Tracestate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Span_Tracestate) XXX_Merge(src proto.Message)
- func (m *Span_Tracestate) XXX_Size() int
- func (m *Span_Tracestate) XXX_Unmarshal(b []byte) error
- type Span_Tracestate_Entry
- func (*Span_Tracestate_Entry) Descriptor() ([]byte, []int)
- func (m *Span_Tracestate_Entry) GetKey() string
- func (m *Span_Tracestate_Entry) GetValue() string
- func (*Span_Tracestate_Entry) ProtoMessage()
- func (m *Span_Tracestate_Entry) Reset()
- func (m *Span_Tracestate_Entry) String() string
- func (m *Span_Tracestate_Entry) XXX_DiscardUnknown()
- func (m *Span_Tracestate_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Span_Tracestate_Entry) XXX_Merge(src proto.Message)
- func (m *Span_Tracestate_Entry) XXX_Size() int
- func (m *Span_Tracestate_Entry) XXX_Unmarshal(b []byte) error
- type StackTrace
- func (*StackTrace) Descriptor() ([]byte, []int)
- func (m *StackTrace) GetStackFrames() *StackTrace_StackFrames
- func (m *StackTrace) GetStackTraceHashId() uint64
- func (*StackTrace) ProtoMessage()
- func (m *StackTrace) Reset()
- func (m *StackTrace) String() string
- func (m *StackTrace) XXX_DiscardUnknown()
- func (m *StackTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StackTrace) XXX_Merge(src proto.Message)
- func (m *StackTrace) XXX_Size() int
- func (m *StackTrace) XXX_Unmarshal(b []byte) error
- type StackTrace_StackFrame
- func (*StackTrace_StackFrame) Descriptor() ([]byte, []int)
- func (m *StackTrace_StackFrame) GetColumnNumber() int64
- func (m *StackTrace_StackFrame) GetFileName() string
- func (m *StackTrace_StackFrame) GetFunctionName() string
- func (m *StackTrace_StackFrame) GetLineNumber() int64
- func (m *StackTrace_StackFrame) GetLoadModule() *Module
- func (m *StackTrace_StackFrame) GetOriginalFunctionName() string
- func (m *StackTrace_StackFrame) GetSourceVersion() string
- func (*StackTrace_StackFrame) ProtoMessage()
- func (m *StackTrace_StackFrame) Reset()
- func (m *StackTrace_StackFrame) String() string
- func (m *StackTrace_StackFrame) XXX_DiscardUnknown()
- func (m *StackTrace_StackFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StackTrace_StackFrame) XXX_Merge(src proto.Message)
- func (m *StackTrace_StackFrame) XXX_Size() int
- func (m *StackTrace_StackFrame) XXX_Unmarshal(b []byte) error
- type StackTrace_StackFrames
- func (*StackTrace_StackFrames) Descriptor() ([]byte, []int)
- func (m *StackTrace_StackFrames) GetDroppedFramesCount() int32
- func (m *StackTrace_StackFrames) GetFrame() []*StackTrace_StackFrame
- func (*StackTrace_StackFrames) ProtoMessage()
- func (m *StackTrace_StackFrames) Reset()
- func (m *StackTrace_StackFrames) String() string
- func (m *StackTrace_StackFrames) XXX_DiscardUnknown()
- func (m *StackTrace_StackFrames) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StackTrace_StackFrames) XXX_Merge(src proto.Message)
- func (m *StackTrace_StackFrames) XXX_Size() int
- func (m *StackTrace_StackFrames) XXX_Unmarshal(b []byte) error
- type Status
- func (*Status) Descriptor() ([]byte, []int)
- func (m *Status) GetCode() int32
- func (m *Status) GetMessage() string
- func (*Status) ProtoMessage()
- func (m *Status) Reset()
- func (m *Status) String() string
- func (m *Status) XXX_DiscardUnknown()
- func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Status) XXX_Merge(src proto.Message)
- func (m *Status) XXX_Size() int
- func (m *Status) XXX_Unmarshal(b []byte) error
- type StreamExporterClient
- type StreamExporterServer
- type StreamExporter_ExportClient
- type StreamExporter_ExportServer
- type UnaryExporterClient
- type UnaryExporterServer
- type UnimplementedStreamExporterServer
- type UnimplementedUnaryExporterServer
Constants ¶
This section is empty.
Variables ¶
var Capabilities_name = map[int32]string{
0: "SKIP",
1: "ZLIB_COMPRESSION",
2: "LZ4_COMPRESSION",
}
var Capabilities_value = map[string]int32{
"SKIP": 0,
"ZLIB_COMPRESSION": 1,
"LZ4_COMPRESSION": 2,
}
var CompressionMethod_name = map[int32]string{
0: "NONE",
1: "LZ4",
2: "ZLIB",
}
var CompressionMethod_value = map[string]int32{
"NONE": 0,
"LZ4": 1,
"ZLIB": 2,
}
var ExportResponse_ResultCode_name = map[int32]string{
0: "Success",
1: "FailedNoneRetryable",
2: "FailedRetryable",
}
var ExportResponse_ResultCode_value = map[string]int32{
"Success": 0,
"FailedNoneRetryable": 1,
"FailedRetryable": 2,
}
var LibraryInfo_Language_name = map[int32]string{
0: "LANGUAGE_UNSPECIFIED",
1: "CPP",
2: "C_SHARP",
3: "ERLANG",
4: "GO_LANG",
5: "JAVA",
6: "NODE_JS",
7: "PHP",
8: "PYTHON",
9: "RUBY",
10: "WEB_JS",
}
var LibraryInfo_Language_value = map[string]int32{
"LANGUAGE_UNSPECIFIED": 0,
"CPP": 1,
"C_SHARP": 2,
"ERLANG": 3,
"GO_LANG": 4,
"JAVA": 5,
"NODE_JS": 6,
"PHP": 7,
"PYTHON": 8,
"RUBY": 9,
"WEB_JS": 10,
}
var Span_Link_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "CHILD_LINKED_SPAN",
2: "PARENT_LINKED_SPAN",
}
var Span_Link_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"CHILD_LINKED_SPAN": 1,
"PARENT_LINKED_SPAN": 2,
}
var Span_SpanKind_name = map[int32]string{
0: "SPAN_KIND_UNSPECIFIED",
1: "SERVER",
2: "CLIENT",
}
var Span_SpanKind_value = map[string]int32{
"SPAN_KIND_UNSPECIFIED": 0,
"SERVER": 1,
"CLIENT": 2,
}
var Span_TimeEvent_MessageEvent_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "SENT",
2: "RECEIVED",
}
var Span_TimeEvent_MessageEvent_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"SENT": 1,
"RECEIVED": 2,
}
Functions ¶
func RegisterStreamExporterServer ¶
func RegisterStreamExporterServer(s *grpc.Server, srv StreamExporterServer)
func RegisterUnaryExporterServer ¶
func RegisterUnaryExporterServer(s *grpc.Server, srv UnaryExporterServer)
Types ¶
type AttributeValue ¶
type AttributeValue struct { // The type of the value. // // Types that are valid to be assigned to Value: // *AttributeValue_StringValue // *AttributeValue_IntValue // *AttributeValue_BoolValue // *AttributeValue_DoubleValue Value isAttributeValue_Value `protobuf_oneof:"value"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The value of an Attribute.
func (*AttributeValue) Descriptor ¶
func (*AttributeValue) Descriptor() ([]byte, []int)
func (*AttributeValue) GetBoolValue ¶
func (m *AttributeValue) GetBoolValue() bool
func (*AttributeValue) GetDoubleValue ¶
func (m *AttributeValue) GetDoubleValue() float64
func (*AttributeValue) GetIntValue ¶
func (m *AttributeValue) GetIntValue() int64
func (*AttributeValue) GetStringValue ¶
func (m *AttributeValue) GetStringValue() string
func (*AttributeValue) GetValue ¶
func (m *AttributeValue) GetValue() isAttributeValue_Value
func (*AttributeValue) ProtoMessage ¶
func (*AttributeValue) ProtoMessage()
func (*AttributeValue) Reset ¶
func (m *AttributeValue) Reset()
func (*AttributeValue) String ¶
func (m *AttributeValue) String() string
func (*AttributeValue) XXX_DiscardUnknown ¶
func (m *AttributeValue) XXX_DiscardUnknown()
func (*AttributeValue) XXX_Marshal ¶
func (m *AttributeValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AttributeValue) XXX_Merge ¶
func (m *AttributeValue) XXX_Merge(src proto.Message)
func (*AttributeValue) XXX_OneofWrappers ¶
func (*AttributeValue) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*AttributeValue) XXX_Size ¶
func (m *AttributeValue) XXX_Size() int
func (*AttributeValue) XXX_Unmarshal ¶
func (m *AttributeValue) XXX_Unmarshal(b []byte) error
type AttributeValue_BoolValue ¶
type AttributeValue_BoolValue struct {
BoolValue bool `protobuf:"varint,3,opt,name=bool_value,json=boolValue,proto3,oneof"`
}
type AttributeValue_DoubleValue ¶
type AttributeValue_DoubleValue struct {
DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}
type AttributeValue_IntValue ¶
type AttributeValue_IntValue struct {
IntValue int64 `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof"`
}
type AttributeValue_StringValue ¶
type AttributeValue_StringValue struct {
StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}
type Capabilities ¶
type Capabilities int32
const ( Capabilities_SKIP Capabilities = 0 Capabilities_ZLIB_COMPRESSION Capabilities = 1 Capabilities_LZ4_COMPRESSION Capabilities = 2 )
func (Capabilities) EnumDescriptor ¶
func (Capabilities) EnumDescriptor() ([]byte, []int)
func (Capabilities) String ¶
func (x Capabilities) String() string
type CompressionMethod ¶
type CompressionMethod int32
const ( CompressionMethod_NONE CompressionMethod = 0 CompressionMethod_LZ4 CompressionMethod = 1 CompressionMethod_ZLIB CompressionMethod = 2 )
func (CompressionMethod) EnumDescriptor ¶
func (CompressionMethod) EnumDescriptor() ([]byte, []int)
func (CompressionMethod) String ¶
func (x CompressionMethod) String() string
type ExportRequest ¶
type ExportRequest struct { // Unique sequential ID generated by the client. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // Telemetry data. SpanBatch []*SpanBatch `protobuf:"bytes,2,rep,name=spanBatch,proto3" json:"spanBatch,omitempty"` MetricBatch []*MetricBatch `protobuf:"bytes,3,rep,name=metricBatch,proto3" json:"metricBatch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A request from client to server containing telemetry data to export.
func (*ExportRequest) Descriptor ¶
func (*ExportRequest) Descriptor() ([]byte, []int)
func (*ExportRequest) GetId ¶
func (m *ExportRequest) GetId() uint64
func (*ExportRequest) GetMetricBatch ¶
func (m *ExportRequest) GetMetricBatch() []*MetricBatch
func (*ExportRequest) GetSpanBatch ¶
func (m *ExportRequest) GetSpanBatch() []*SpanBatch
func (*ExportRequest) ProtoMessage ¶
func (*ExportRequest) ProtoMessage()
func (*ExportRequest) Reset ¶
func (m *ExportRequest) Reset()
func (*ExportRequest) String ¶
func (m *ExportRequest) String() string
func (*ExportRequest) XXX_DiscardUnknown ¶
func (m *ExportRequest) XXX_DiscardUnknown()
func (*ExportRequest) XXX_Marshal ¶
func (m *ExportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExportRequest) XXX_Merge ¶
func (m *ExportRequest) XXX_Merge(src proto.Message)
func (*ExportRequest) XXX_Size ¶
func (m *ExportRequest) XXX_Size() int
func (*ExportRequest) XXX_Unmarshal ¶
func (m *ExportRequest) XXX_Unmarshal(b []byte) error
type ExportResponse ¶
type ExportResponse struct { // ID of a response that the server acknowledges. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` ResultCode ExportResponse_ResultCode `` /* 138-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A response to ExportRequest.
func (*ExportResponse) Descriptor ¶
func (*ExportResponse) Descriptor() ([]byte, []int)
func (*ExportResponse) GetId ¶
func (m *ExportResponse) GetId() uint64
func (*ExportResponse) GetResultCode ¶
func (m *ExportResponse) GetResultCode() ExportResponse_ResultCode
func (*ExportResponse) ProtoMessage ¶
func (*ExportResponse) ProtoMessage()
func (*ExportResponse) Reset ¶
func (m *ExportResponse) Reset()
func (*ExportResponse) String ¶
func (m *ExportResponse) String() string
func (*ExportResponse) XXX_DiscardUnknown ¶
func (m *ExportResponse) XXX_DiscardUnknown()
func (*ExportResponse) XXX_Marshal ¶
func (m *ExportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExportResponse) XXX_Merge ¶
func (m *ExportResponse) XXX_Merge(src proto.Message)
func (*ExportResponse) XXX_Size ¶
func (m *ExportResponse) XXX_Size() int
func (*ExportResponse) XXX_Unmarshal ¶
func (m *ExportResponse) XXX_Unmarshal(b []byte) error
type ExportResponse_ResultCode ¶
type ExportResponse_ResultCode int32
const ( // Telemetry data is successfully processed by the server. ExportResponse_Success ExportResponse_ResultCode = 0 // processing of telemetry data failed. The client MUST NOT retry // sending the same telemetry data. The telemetry data MUST be dropped. // This for example can happen when the request contains bad data and // cannot be deserialized or otherwise processed by the server. ExportResponse_FailedNoneRetryable ExportResponse_ResultCode = 1 // Processing of telemetry data failed. The client SHOULD record the // error and MAY retry exporting the same data after some time. This // for example can happen when the server is overloaded. ExportResponse_FailedRetryable ExportResponse_ResultCode = 2 )
func (ExportResponse_ResultCode) EnumDescriptor ¶
func (ExportResponse_ResultCode) EnumDescriptor() ([]byte, []int)
func (ExportResponse_ResultCode) String ¶
func (x ExportResponse_ResultCode) String() string
type Generator ¶
type Generator struct {
// contains filtered or unexported fields
}
Generator allows to generate a ExportRequest.
func NewGenerator ¶
func NewGenerator() *Generator
func (*Generator) GenerateBatch ¶
func (g *Generator) GenerateBatch(spansPerBatch int, attrsPerSpan int) core.ExportRequest
type HelloRequest ¶
type HelloRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Hello is the first request from client to server.
func (*HelloRequest) Descriptor ¶
func (*HelloRequest) Descriptor() ([]byte, []int)
func (*HelloRequest) ProtoMessage ¶
func (*HelloRequest) ProtoMessage()
func (*HelloRequest) Reset ¶
func (m *HelloRequest) Reset()
func (*HelloRequest) String ¶
func (m *HelloRequest) String() string
func (*HelloRequest) XXX_DiscardUnknown ¶
func (m *HelloRequest) XXX_DiscardUnknown()
func (*HelloRequest) XXX_Marshal ¶
func (m *HelloRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HelloRequest) XXX_Merge ¶
func (m *HelloRequest) XXX_Merge(src proto.Message)
func (*HelloRequest) XXX_Size ¶
func (m *HelloRequest) XXX_Size() int
func (*HelloRequest) XXX_Unmarshal ¶
func (m *HelloRequest) XXX_Unmarshal(b []byte) error
type HelloResponse ¶
type HelloResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Response to Hello request.
func (*HelloResponse) Descriptor ¶
func (*HelloResponse) Descriptor() ([]byte, []int)
func (*HelloResponse) ProtoMessage ¶
func (*HelloResponse) ProtoMessage()
func (*HelloResponse) Reset ¶
func (m *HelloResponse) Reset()
func (*HelloResponse) String ¶
func (m *HelloResponse) String() string
func (*HelloResponse) XXX_DiscardUnknown ¶
func (m *HelloResponse) XXX_DiscardUnknown()
func (*HelloResponse) XXX_Marshal ¶
func (m *HelloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HelloResponse) XXX_Merge ¶
func (m *HelloResponse) XXX_Merge(src proto.Message)
func (*HelloResponse) XXX_Size ¶
func (m *HelloResponse) XXX_Size() int
func (*HelloResponse) XXX_Unmarshal ¶
func (m *HelloResponse) XXX_Unmarshal(b []byte) error
type LibraryInfo ¶
type LibraryInfo struct { // Language of OpenCensus Library. Language LibraryInfo_Language `protobuf:"varint,1,opt,name=language,proto3,enum=traceprotobufb.LibraryInfo_Language" json:"language,omitempty"` // Version of Agent exporter of Library. ExporterVersion string `protobuf:"bytes,2,opt,name=exporter_version,json=exporterVersion,proto3" json:"exporter_version,omitempty"` // Version of OpenCensus Library. CoreLibraryVersion string `protobuf:"bytes,3,opt,name=core_library_version,json=coreLibraryVersion,proto3" json:"core_library_version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Information on OpenCensus Library.
func (*LibraryInfo) Descriptor ¶
func (*LibraryInfo) Descriptor() ([]byte, []int)
func (*LibraryInfo) GetCoreLibraryVersion ¶
func (m *LibraryInfo) GetCoreLibraryVersion() string
func (*LibraryInfo) GetExporterVersion ¶
func (m *LibraryInfo) GetExporterVersion() string
func (*LibraryInfo) GetLanguage ¶
func (m *LibraryInfo) GetLanguage() LibraryInfo_Language
func (*LibraryInfo) ProtoMessage ¶
func (*LibraryInfo) ProtoMessage()
func (*LibraryInfo) Reset ¶
func (m *LibraryInfo) Reset()
func (*LibraryInfo) String ¶
func (m *LibraryInfo) String() string
func (*LibraryInfo) XXX_DiscardUnknown ¶
func (m *LibraryInfo) XXX_DiscardUnknown()
func (*LibraryInfo) XXX_Marshal ¶
func (m *LibraryInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LibraryInfo) XXX_Merge ¶
func (m *LibraryInfo) XXX_Merge(src proto.Message)
func (*LibraryInfo) XXX_Size ¶
func (m *LibraryInfo) XXX_Size() int
func (*LibraryInfo) XXX_Unmarshal ¶
func (m *LibraryInfo) XXX_Unmarshal(b []byte) error
type LibraryInfo_Language ¶
type LibraryInfo_Language int32
const ( LibraryInfo_LANGUAGE_UNSPECIFIED LibraryInfo_Language = 0 LibraryInfo_CPP LibraryInfo_Language = 1 LibraryInfo_C_SHARP LibraryInfo_Language = 2 LibraryInfo_ERLANG LibraryInfo_Language = 3 LibraryInfo_GO_LANG LibraryInfo_Language = 4 LibraryInfo_JAVA LibraryInfo_Language = 5 LibraryInfo_NODE_JS LibraryInfo_Language = 6 LibraryInfo_PHP LibraryInfo_Language = 7 LibraryInfo_PYTHON LibraryInfo_Language = 8 LibraryInfo_RUBY LibraryInfo_Language = 9 LibraryInfo_WEB_JS LibraryInfo_Language = 10 )
func (LibraryInfo_Language) EnumDescriptor ¶
func (LibraryInfo_Language) EnumDescriptor() ([]byte, []int)
func (LibraryInfo_Language) String ¶
func (x LibraryInfo_Language) String() string
type Metric ¶
type Metric struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Metric) Descriptor ¶
func (*Metric) ProtoMessage ¶
func (*Metric) ProtoMessage()
func (*Metric) XXX_DiscardUnknown ¶
func (m *Metric) XXX_DiscardUnknown()
func (*Metric) XXX_Marshal ¶
func (*Metric) XXX_Unmarshal ¶
type MetricBatch ¶
type MetricBatch struct { Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` Metrics []*Metric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A list of metrics from a Node.
func (*MetricBatch) Descriptor ¶
func (*MetricBatch) Descriptor() ([]byte, []int)
func (*MetricBatch) GetMetrics ¶
func (m *MetricBatch) GetMetrics() []*Metric
func (*MetricBatch) GetResource ¶
func (m *MetricBatch) GetResource() *Resource
func (*MetricBatch) ProtoMessage ¶
func (*MetricBatch) ProtoMessage()
func (*MetricBatch) Reset ¶
func (m *MetricBatch) Reset()
func (*MetricBatch) String ¶
func (m *MetricBatch) String() string
func (*MetricBatch) XXX_DiscardUnknown ¶
func (m *MetricBatch) XXX_DiscardUnknown()
func (*MetricBatch) XXX_Marshal ¶
func (m *MetricBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MetricBatch) XXX_Merge ¶
func (m *MetricBatch) XXX_Merge(src proto.Message)
func (*MetricBatch) XXX_Size ¶
func (m *MetricBatch) XXX_Size() int
func (*MetricBatch) XXX_Unmarshal ¶
func (m *MetricBatch) XXX_Unmarshal(b []byte) error
type Module ¶
type Module struct { // TODO: document the meaning of this field. // For example: main binary, kernel modules, and dynamic libraries // such as libc.so, sharedlib.so. Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"` // A unique identifier for the module, usually a hash of its // contents. BuildId string `protobuf:"bytes,2,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A description of a binary module.
func (*Module) Descriptor ¶
func (*Module) GetBuildId ¶
func (*Module) ProtoMessage ¶
func (*Module) ProtoMessage()
func (*Module) XXX_DiscardUnknown ¶
func (m *Module) XXX_DiscardUnknown()
func (*Module) XXX_Marshal ¶
func (*Module) XXX_Unmarshal ¶
type Node ¶
type Node struct { // Identifier that uniquely identifies a process within a VM/container. Identifier *ProcessIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` // Information on the OpenCensus Library that initiates the stream. LibraryInfo *LibraryInfo `protobuf:"bytes,2,opt,name=library_info,json=libraryInfo,proto3" json:"library_info,omitempty"` // Additional information on service. ServiceInfo *ServiceInfo `protobuf:"bytes,3,opt,name=service_info,json=serviceInfo,proto3" json:"service_info,omitempty"` // Additional attributes. Attributes map[string]*AttributeValue `` /* 161-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Identifier metadata of the Node that produces the span or tracing data. Note, this is not the metadata about the Node or service that is described by associated spans. In the future we plan to extend the identifier proto definition to support additional information (e.g cloud id, etc.)
func (*Node) Descriptor ¶
func (*Node) GetAttributes ¶
func (m *Node) GetAttributes() map[string]*AttributeValue
func (*Node) GetIdentifier ¶
func (m *Node) GetIdentifier() *ProcessIdentifier
func (*Node) GetLibraryInfo ¶
func (m *Node) GetLibraryInfo() *LibraryInfo
func (*Node) GetServiceInfo ¶
func (m *Node) GetServiceInfo() *ServiceInfo
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) XXX_DiscardUnknown ¶
func (m *Node) XXX_DiscardUnknown()
func (*Node) XXX_Unmarshal ¶
type ProcessIdentifier ¶
type ProcessIdentifier struct { // The host name. Usually refers to the machine/container name. // For example: os.Hostname() in Go, socket.gethostname() in Python. HostName string `protobuf:"bytes,1,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` // Process id. Pid uint32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"` // Start time of this ProcessIdentifier. Represented in epoch time. StartTimeUnixnano int64 `protobuf:"varint,3,opt,name=start_time_unixnano,json=startTimeUnixnano,proto3" json:"start_time_unixnano,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Identifier that uniquely identifies a process within a VM/container.
func (*ProcessIdentifier) Descriptor ¶
func (*ProcessIdentifier) Descriptor() ([]byte, []int)
func (*ProcessIdentifier) GetHostName ¶
func (m *ProcessIdentifier) GetHostName() string
func (*ProcessIdentifier) GetPid ¶
func (m *ProcessIdentifier) GetPid() uint32
func (*ProcessIdentifier) GetStartTimeUnixnano ¶
func (m *ProcessIdentifier) GetStartTimeUnixnano() int64
func (*ProcessIdentifier) ProtoMessage ¶
func (*ProcessIdentifier) ProtoMessage()
func (*ProcessIdentifier) Reset ¶
func (m *ProcessIdentifier) Reset()
func (*ProcessIdentifier) String ¶
func (m *ProcessIdentifier) String() string
func (*ProcessIdentifier) XXX_DiscardUnknown ¶
func (m *ProcessIdentifier) XXX_DiscardUnknown()
func (*ProcessIdentifier) XXX_Marshal ¶
func (m *ProcessIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessIdentifier) XXX_Merge ¶
func (m *ProcessIdentifier) XXX_Merge(src proto.Message)
func (*ProcessIdentifier) XXX_Size ¶
func (m *ProcessIdentifier) XXX_Size() int
func (*ProcessIdentifier) XXX_Unmarshal ¶
func (m *ProcessIdentifier) XXX_Unmarshal(b []byte) error
type RequestBody ¶
type RequestBody struct { // Types that are valid to be assigned to Body: // *RequestBody_Hello // *RequestBody_Export Body isRequestBody_Body `protobuf_oneof:"body"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RequestBody is used by transports that unlike gRPC don't have built-in message type multiplexing such as WebSocket.
func (*RequestBody) Descriptor ¶
func (*RequestBody) Descriptor() ([]byte, []int)
func (*RequestBody) GetBody ¶
func (m *RequestBody) GetBody() isRequestBody_Body
func (*RequestBody) GetExport ¶
func (m *RequestBody) GetExport() *ExportRequest
func (*RequestBody) GetHello ¶
func (m *RequestBody) GetHello() *HelloRequest
func (*RequestBody) ProtoMessage ¶
func (*RequestBody) ProtoMessage()
func (*RequestBody) Reset ¶
func (m *RequestBody) Reset()
func (*RequestBody) String ¶
func (m *RequestBody) String() string
func (*RequestBody) XXX_DiscardUnknown ¶
func (m *RequestBody) XXX_DiscardUnknown()
func (*RequestBody) XXX_Marshal ¶
func (m *RequestBody) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestBody) XXX_Merge ¶
func (m *RequestBody) XXX_Merge(src proto.Message)
func (*RequestBody) XXX_OneofWrappers ¶
func (*RequestBody) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*RequestBody) XXX_Size ¶
func (m *RequestBody) XXX_Size() int
func (*RequestBody) XXX_Unmarshal ¶
func (m *RequestBody) XXX_Unmarshal(b []byte) error
type RequestBody_Export ¶
type RequestBody_Export struct {
Export *ExportRequest `protobuf:"bytes,2,opt,name=export,proto3,oneof"`
}
type RequestBody_Hello ¶
type RequestBody_Hello struct {
Hello *HelloRequest `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}
type RequestHeader ¶
type RequestHeader struct { // Compression method used for body. Compression CompressionMethod `protobuf:"varint,1,opt,name=compression,proto3,enum=traceprotobufb.CompressionMethod" json:"compression,omitempty"` // Compression level as defined by the compression method. CompressionLevel int32 `protobuf:"varint,2,opt,name=compression_level,json=compressionLevel,proto3" json:"compression_level,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RequestHeader is used by transports that unlike gRPC don't have built-in request compression such as WebSocket. Request body typically follows the header.
func (*RequestHeader) Descriptor ¶
func (*RequestHeader) Descriptor() ([]byte, []int)
func (*RequestHeader) GetCompression ¶
func (m *RequestHeader) GetCompression() CompressionMethod
func (*RequestHeader) GetCompressionLevel ¶
func (m *RequestHeader) GetCompressionLevel() int32
func (*RequestHeader) ProtoMessage ¶
func (*RequestHeader) ProtoMessage()
func (*RequestHeader) Reset ¶
func (m *RequestHeader) Reset()
func (*RequestHeader) String ¶
func (m *RequestHeader) String() string
func (*RequestHeader) XXX_DiscardUnknown ¶
func (m *RequestHeader) XXX_DiscardUnknown()
func (*RequestHeader) XXX_Marshal ¶
func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestHeader) XXX_Merge ¶
func (m *RequestHeader) XXX_Merge(src proto.Message)
func (*RequestHeader) XXX_Size ¶
func (m *RequestHeader) XXX_Size() int
func (*RequestHeader) XXX_Unmarshal ¶
func (m *RequestHeader) XXX_Unmarshal(b []byte) error
type Resource ¶
type Resource struct { // Identifier that uniquely identifies a process within a VM/container. Identifier *ProcessIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` // Additional information on service. ServiceInfo *ServiceInfo `protobuf:"bytes,3,opt,name=service_info,json=serviceInfo,proto3" json:"service_info,omitempty"` // Set of labels that describe the resource. Attributes map[string]*AttributeValue `` /* 161-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Resource information.
func (*Resource) Descriptor ¶
func (*Resource) GetAttributes ¶
func (m *Resource) GetAttributes() map[string]*AttributeValue
func (*Resource) GetIdentifier ¶
func (m *Resource) GetIdentifier() *ProcessIdentifier
func (*Resource) GetServiceInfo ¶
func (m *Resource) GetServiceInfo() *ServiceInfo
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) XXX_DiscardUnknown ¶
func (m *Resource) XXX_DiscardUnknown()
func (*Resource) XXX_Marshal ¶
func (*Resource) XXX_Unmarshal ¶
type Response ¶
type Response struct { // Types that are valid to be assigned to Body: // *Response_Hello // *Response_Export Body isResponse_Body `protobuf_oneof:"body"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Response is used by transports that unlike gRPC don't have built-in message type multiplexing such as WebSocket.
func (*Response) Descriptor ¶
func (*Response) GetExport ¶
func (m *Response) GetExport() *ExportResponse
func (*Response) GetHello ¶
func (m *Response) GetHello() *HelloResponse
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) XXX_DiscardUnknown ¶
func (m *Response) XXX_DiscardUnknown()
func (*Response) XXX_Marshal ¶
func (*Response) XXX_OneofWrappers ¶
func (*Response) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Response) XXX_Unmarshal ¶
type Response_Export ¶
type Response_Export struct {
Export *ExportResponse `protobuf:"bytes,2,opt,name=export,proto3,oneof"`
}
type Response_Hello ¶
type Response_Hello struct {
Hello *HelloResponse `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}
type ServiceInfo ¶
type ServiceInfo struct { // Name of the service. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Additional service information.
func (*ServiceInfo) Descriptor ¶
func (*ServiceInfo) Descriptor() ([]byte, []int)
func (*ServiceInfo) GetName ¶
func (m *ServiceInfo) GetName() string
func (*ServiceInfo) ProtoMessage ¶
func (*ServiceInfo) ProtoMessage()
func (*ServiceInfo) Reset ¶
func (m *ServiceInfo) Reset()
func (*ServiceInfo) String ¶
func (m *ServiceInfo) String() string
func (*ServiceInfo) XXX_DiscardUnknown ¶
func (m *ServiceInfo) XXX_DiscardUnknown()
func (*ServiceInfo) XXX_Marshal ¶
func (m *ServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceInfo) XXX_Merge ¶
func (m *ServiceInfo) XXX_Merge(src proto.Message)
func (*ServiceInfo) XXX_Size ¶
func (m *ServiceInfo) XXX_Size() int
func (*ServiceInfo) XXX_Unmarshal ¶
func (m *ServiceInfo) XXX_Unmarshal(b []byte) error
type Span ¶
type Span struct { // A unique identifier for a trace. All spans from the same trace share // the same `trace_id`. The ID is a 16-byte array. An ID with all zeroes // is considered invalid. // // This field is semantically required. Receiver should generate new // random trace_id if empty or invalid trace_id was received. // // This field is required. TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // A unique identifier for a span within a trace, assigned when the span // is created. The ID is an 8-byte array. An ID with all zeroes is considered // invalid. // // This field is semantically required. Receiver should generate new // random span_id if empty or invalid span_id was received. // // This field is required. SpanId []byte `protobuf:"bytes,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"` // The Tracestate on the span. Tracestate *Span_Tracestate `protobuf:"bytes,15,opt,name=tracestate,proto3" json:"tracestate,omitempty"` // The `span_id` of this span's parent span. If this is a root span, then this // field must be empty. The ID is an 8-byte array. ParentSpanId []byte `protobuf:"bytes,3,opt,name=parent_span_id,json=parentSpanId,proto3" json:"parent_span_id,omitempty"` // A description of the span's operation. // // For example, the name can be a qualified method name or a file name // and a line number where the operation is called. A best practice is to use // the same display name at the same call point in an application. // This makes it easier to correlate spans in different traces. // // This field is semantically required to be set to non-empty string. // When null or empty string received - receiver may use string "name" // as a replacement. There might be smarted algorithms implemented by // receiver to fix the empty span name. // // This field is required. Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` // Distinguishes between spans generated in a particular context. For example, // two spans with the same name may be distinguished using `CLIENT` (caller) // and `SERVER` (callee) to identify queueing latency associated with the span. Kind Span_SpanKind `protobuf:"varint,14,opt,name=kind,proto3,enum=traceprotobufb.Span_SpanKind" json:"kind,omitempty"` // The start time of the span. On the client side, this is the time kept by // the local machine where the span execution starts. On the server side, this // is the time when the server's application handler starts running. // // This field is semantically required. When not set on receive - // receiver should set it to the value of end_time field if it was // set. Or to the current time if neither was set. It is important to // keep end_time > start_time for consistency. // // This field is required. StartTimeUnixnano int64 `protobuf:"varint,5,opt,name=start_time_unixnano,json=startTimeUnixnano,proto3" json:"start_time_unixnano,omitempty"` // The end time of the span. On the client side, this is the time kept by // the local machine where the span execution ends. On the server side, this // is the time when the server application handler stops running. // // This field is semantically required. When not set on receive - // receiver should set it to start_time value. It is important to // keep end_time > start_time for consistency. // // This field is required. EndTimeUnixnano int64 `protobuf:"varint,6,opt,name=end_time_unixnano,json=endTimeUnixnano,proto3" json:"end_time_unixnano,omitempty"` // The set of attributes. The value can be a string, an integer, a double // or the Boolean values `true` or `false`. Note, global attributes like // server name can be set as tags using resource API. Examples of attributes: // // "/http/user_agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_2) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/71.0.3578.98 Safari/537.36" // "/http/server_latency": 300 // "abc.com/myattribute": true // "abc.com/score": 10.239 Attributes map[string]*AttributeValue `` /* 161-byte string literal not displayed */ // A stack trace captured at the start of the span. StackTrace *StackTrace `protobuf:"bytes,8,opt,name=stack_trace,json=stackTrace,proto3" json:"stack_trace,omitempty"` // The included time events. TimeEvents *Span_TimeEvents `protobuf:"bytes,9,opt,name=time_events,json=timeEvents,proto3" json:"time_events,omitempty"` // The included links. Links *Span_Links `protobuf:"bytes,10,opt,name=links,proto3" json:"links,omitempty"` // An optional final status for this span. Semantically when Status // wasn't set it is means span ended without errors and assume // Status.Ok (code = 0). Status *Status `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"` // An optional resource that is associated with this span. If not set, this span // should be part of a batch that does include the resource information, unless resource // information is unknown. Resource *Resource `protobuf:"bytes,16,opt,name=resource,proto3" json:"resource,omitempty"` // A highly recommended but not required flag that identifies when a // trace crosses a process boundary. True when the parent_span belongs // to the same process as the current span. This flag is most commonly // used to indicate the need to adjust time as clocks in different // processes may not be synchronized. SameProcessAsParentSpan *wrappers.BoolValue `` /* 137-byte string literal not displayed */ // An optional number of child spans that were generated while this span // was active. If set, allows an implementation to detect missing child spans. ChildSpanCount *wrappers.UInt32Value `protobuf:"bytes,13,opt,name=child_span_count,json=childSpanCount,proto3" json:"child_span_count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A span represents a single operation within a trace. Spans can be nested to form a trace tree. Spans may also be linked to other spans from the same or different trace. And form graphs. Often, a trace contains a root span that describes the end-to-end latency, and one or more subspans for its sub-operations. A trace can also contain multiple root spans, or none at all. Spans do not need to be contiguous - there may be gaps or overlaps between spans in a trace.
The next id is 17. TODO(bdrutu): Add an example.
func (*Span) Descriptor ¶
func (*Span) GetAttributes ¶
func (m *Span) GetAttributes() map[string]*AttributeValue
func (*Span) GetChildSpanCount ¶
func (m *Span) GetChildSpanCount() *wrappers.UInt32Value
func (*Span) GetEndTimeUnixnano ¶
func (*Span) GetKind ¶
func (m *Span) GetKind() Span_SpanKind
func (*Span) GetLinks ¶
func (m *Span) GetLinks() *Span_Links
func (*Span) GetParentSpanId ¶
func (*Span) GetResource ¶
func (*Span) GetSameProcessAsParentSpan ¶
func (*Span) GetStackTrace ¶
func (m *Span) GetStackTrace() *StackTrace
func (*Span) GetStartTimeUnixnano ¶
func (*Span) GetTimeEvents ¶
func (m *Span) GetTimeEvents() *Span_TimeEvents
func (*Span) GetTraceId ¶
func (*Span) GetTracestate ¶
func (m *Span) GetTracestate() *Span_Tracestate
func (*Span) ProtoMessage ¶
func (*Span) ProtoMessage()
func (*Span) XXX_DiscardUnknown ¶
func (m *Span) XXX_DiscardUnknown()
func (*Span) XXX_Unmarshal ¶
type SpanBatch ¶
type SpanBatch struct { Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` Spans []*Span `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A list of spans from a Node.
func (*SpanBatch) Descriptor ¶
func (*SpanBatch) GetResource ¶
func (*SpanBatch) ProtoMessage ¶
func (*SpanBatch) ProtoMessage()
func (*SpanBatch) XXX_DiscardUnknown ¶
func (m *SpanBatch) XXX_DiscardUnknown()
func (*SpanBatch) XXX_Marshal ¶
func (*SpanBatch) XXX_Unmarshal ¶
type Span_Link ¶
type Span_Link struct { // A unique identifier of a trace that this linked span is part of. The ID is a // 16-byte array. TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // A unique identifier for the linked span. The ID is an 8-byte array. SpanId []byte `protobuf:"bytes,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"` // The relationship of the current span relative to the linked span. Type Span_Link_Type `protobuf:"varint,3,opt,name=type,proto3,enum=traceprotobufb.Span_Link_Type" json:"type,omitempty"` // A set of attributes on the link. Attributes map[string]*AttributeValue `` /* 161-byte string literal not displayed */ // The Tracestate associated with the link. Tracestate *Span_Tracestate `protobuf:"bytes,5,opt,name=tracestate,proto3" json:"tracestate,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A pointer from the current span to another span in the same trace or in a different trace. For example, this can be used in batching operations, where a single batch handler processes multiple requests from different traces or when the handler receives a request from a different project.
func (*Span_Link) Descriptor ¶
func (*Span_Link) GetAttributes ¶
func (m *Span_Link) GetAttributes() map[string]*AttributeValue
func (*Span_Link) GetTraceId ¶
func (*Span_Link) GetTracestate ¶
func (m *Span_Link) GetTracestate() *Span_Tracestate
func (*Span_Link) GetType ¶
func (m *Span_Link) GetType() Span_Link_Type
func (*Span_Link) ProtoMessage ¶
func (*Span_Link) ProtoMessage()
func (*Span_Link) XXX_DiscardUnknown ¶
func (m *Span_Link) XXX_DiscardUnknown()
func (*Span_Link) XXX_Marshal ¶
func (*Span_Link) XXX_Unmarshal ¶
type Span_Link_Type ¶
type Span_Link_Type int32
The relationship of the current span relative to the linked span: child, parent, or unspecified.
const ( // The relationship of the two spans is unknown, or known but other // than parent-child. Span_Link_TYPE_UNSPECIFIED Span_Link_Type = 0 // The linked span is a child of the current span. Span_Link_CHILD_LINKED_SPAN Span_Link_Type = 1 // The linked span is a parent of the current span. Span_Link_PARENT_LINKED_SPAN Span_Link_Type = 2 )
func (Span_Link_Type) EnumDescriptor ¶
func (Span_Link_Type) EnumDescriptor() ([]byte, []int)
func (Span_Link_Type) String ¶
func (x Span_Link_Type) String() string
type Span_Links ¶
type Span_Links struct { // A collection of links. Link []*Span_Link `protobuf:"bytes,1,rep,name=link,proto3" json:"link,omitempty"` // The number of dropped links after the maximum size was enforced. If // this value is 0, then no links were dropped. DroppedLinksCount int32 `protobuf:"varint,2,opt,name=dropped_links_count,json=droppedLinksCount,proto3" json:"dropped_links_count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A collection of links, which are references from this span to a span in the same or different trace.
func (*Span_Links) Descriptor ¶
func (*Span_Links) Descriptor() ([]byte, []int)
func (*Span_Links) GetDroppedLinksCount ¶
func (m *Span_Links) GetDroppedLinksCount() int32
func (*Span_Links) GetLink ¶
func (m *Span_Links) GetLink() []*Span_Link
func (*Span_Links) ProtoMessage ¶
func (*Span_Links) ProtoMessage()
func (*Span_Links) Reset ¶
func (m *Span_Links) Reset()
func (*Span_Links) String ¶
func (m *Span_Links) String() string
func (*Span_Links) XXX_DiscardUnknown ¶
func (m *Span_Links) XXX_DiscardUnknown()
func (*Span_Links) XXX_Marshal ¶
func (m *Span_Links) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Span_Links) XXX_Merge ¶
func (m *Span_Links) XXX_Merge(src proto.Message)
func (*Span_Links) XXX_Size ¶
func (m *Span_Links) XXX_Size() int
func (*Span_Links) XXX_Unmarshal ¶
func (m *Span_Links) XXX_Unmarshal(b []byte) error
type Span_SpanKind ¶
type Span_SpanKind int32
Type of span. Can be used to specify additional relationships between spans in addition to a parent/child relationship.
const ( // Unspecified. Span_SPAN_KIND_UNSPECIFIED Span_SpanKind = 0 // Indicates that the span covers server-side handling of an RPC or other // remote network request. Span_SERVER Span_SpanKind = 1 // Indicates that the span covers the client-side wrapper around an RPC or // other remote request. Span_CLIENT Span_SpanKind = 2 )
func (Span_SpanKind) EnumDescriptor ¶
func (Span_SpanKind) EnumDescriptor() ([]byte, []int)
func (Span_SpanKind) String ¶
func (x Span_SpanKind) String() string
type Span_TimeEvent ¶
type Span_TimeEvent struct { // The time the event occurred. TimeUnixnano int64 `protobuf:"varint,1,opt,name=time_unixnano,json=timeUnixnano,proto3" json:"time_unixnano,omitempty"` // A `TimeEvent` can contain either an `Annotation` object or a // `MessageEvent` object, but not both. // // Types that are valid to be assigned to Value: // *Span_TimeEvent_Annotation_ // *Span_TimeEvent_MessageEvent_ Value isSpan_TimeEvent_Value `protobuf_oneof:"value"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A time-stamped annotation or message event in the Span.
func (*Span_TimeEvent) Descriptor ¶
func (*Span_TimeEvent) Descriptor() ([]byte, []int)
func (*Span_TimeEvent) GetAnnotation ¶
func (m *Span_TimeEvent) GetAnnotation() *Span_TimeEvent_Annotation
func (*Span_TimeEvent) GetMessageEvent ¶
func (m *Span_TimeEvent) GetMessageEvent() *Span_TimeEvent_MessageEvent
func (*Span_TimeEvent) GetTimeUnixnano ¶
func (m *Span_TimeEvent) GetTimeUnixnano() int64
func (*Span_TimeEvent) GetValue ¶
func (m *Span_TimeEvent) GetValue() isSpan_TimeEvent_Value
func (*Span_TimeEvent) ProtoMessage ¶
func (*Span_TimeEvent) ProtoMessage()
func (*Span_TimeEvent) Reset ¶
func (m *Span_TimeEvent) Reset()
func (*Span_TimeEvent) String ¶
func (m *Span_TimeEvent) String() string
func (*Span_TimeEvent) XXX_DiscardUnknown ¶
func (m *Span_TimeEvent) XXX_DiscardUnknown()
func (*Span_TimeEvent) XXX_Marshal ¶
func (m *Span_TimeEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Span_TimeEvent) XXX_Merge ¶
func (m *Span_TimeEvent) XXX_Merge(src proto.Message)
func (*Span_TimeEvent) XXX_OneofWrappers ¶
func (*Span_TimeEvent) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Span_TimeEvent) XXX_Size ¶
func (m *Span_TimeEvent) XXX_Size() int
func (*Span_TimeEvent) XXX_Unmarshal ¶
func (m *Span_TimeEvent) XXX_Unmarshal(b []byte) error
type Span_TimeEvent_Annotation ¶
type Span_TimeEvent_Annotation struct { // A user-supplied message describing the event. Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"` // A set of attributes on the annotation. Attributes map[string]*AttributeValue `` /* 161-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A text annotation with a set of attributes.
func (*Span_TimeEvent_Annotation) Descriptor ¶
func (*Span_TimeEvent_Annotation) Descriptor() ([]byte, []int)
func (*Span_TimeEvent_Annotation) GetAttributes ¶
func (m *Span_TimeEvent_Annotation) GetAttributes() map[string]*AttributeValue
func (*Span_TimeEvent_Annotation) GetDescription ¶
func (m *Span_TimeEvent_Annotation) GetDescription() string
func (*Span_TimeEvent_Annotation) ProtoMessage ¶
func (*Span_TimeEvent_Annotation) ProtoMessage()
func (*Span_TimeEvent_Annotation) Reset ¶
func (m *Span_TimeEvent_Annotation) Reset()
func (*Span_TimeEvent_Annotation) String ¶
func (m *Span_TimeEvent_Annotation) String() string
func (*Span_TimeEvent_Annotation) XXX_DiscardUnknown ¶
func (m *Span_TimeEvent_Annotation) XXX_DiscardUnknown()
func (*Span_TimeEvent_Annotation) XXX_Marshal ¶
func (m *Span_TimeEvent_Annotation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Span_TimeEvent_Annotation) XXX_Merge ¶
func (m *Span_TimeEvent_Annotation) XXX_Merge(src proto.Message)
func (*Span_TimeEvent_Annotation) XXX_Size ¶
func (m *Span_TimeEvent_Annotation) XXX_Size() int
func (*Span_TimeEvent_Annotation) XXX_Unmarshal ¶
func (m *Span_TimeEvent_Annotation) XXX_Unmarshal(b []byte) error
type Span_TimeEvent_Annotation_ ¶
type Span_TimeEvent_Annotation_ struct {
Annotation *Span_TimeEvent_Annotation `protobuf:"bytes,2,opt,name=annotation,proto3,oneof"`
}
type Span_TimeEvent_MessageEvent ¶
type Span_TimeEvent_MessageEvent struct { // The type of MessageEvent. Indicates whether the message was sent or // received. Type Span_TimeEvent_MessageEvent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=traceprotobufb.Span_TimeEvent_MessageEvent_Type" json:"type,omitempty"` // An identifier for the MessageEvent's message that can be used to match // SENT and RECEIVED MessageEvents. For example, this field could // represent a sequence ID for a streaming RPC. It is recommended to be // unique within a Span. Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` // The number of uncompressed bytes sent or received. UncompressedSize uint64 `protobuf:"varint,3,opt,name=uncompressed_size,json=uncompressedSize,proto3" json:"uncompressed_size,omitempty"` // The number of compressed bytes sent or received. If zero, assumed to // be the same size as uncompressed. CompressedSize uint64 `protobuf:"varint,4,opt,name=compressed_size,json=compressedSize,proto3" json:"compressed_size,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
An event describing a message sent/received between Spans.
func (*Span_TimeEvent_MessageEvent) Descriptor ¶
func (*Span_TimeEvent_MessageEvent) Descriptor() ([]byte, []int)
func (*Span_TimeEvent_MessageEvent) GetCompressedSize ¶
func (m *Span_TimeEvent_MessageEvent) GetCompressedSize() uint64
func (*Span_TimeEvent_MessageEvent) GetId ¶
func (m *Span_TimeEvent_MessageEvent) GetId() uint64
func (*Span_TimeEvent_MessageEvent) GetType ¶
func (m *Span_TimeEvent_MessageEvent) GetType() Span_TimeEvent_MessageEvent_Type
func (*Span_TimeEvent_MessageEvent) GetUncompressedSize ¶
func (m *Span_TimeEvent_MessageEvent) GetUncompressedSize() uint64
func (*Span_TimeEvent_MessageEvent) ProtoMessage ¶
func (*Span_TimeEvent_MessageEvent) ProtoMessage()
func (*Span_TimeEvent_MessageEvent) Reset ¶
func (m *Span_TimeEvent_MessageEvent) Reset()
func (*Span_TimeEvent_MessageEvent) String ¶
func (m *Span_TimeEvent_MessageEvent) String() string
func (*Span_TimeEvent_MessageEvent) XXX_DiscardUnknown ¶
func (m *Span_TimeEvent_MessageEvent) XXX_DiscardUnknown()
func (*Span_TimeEvent_MessageEvent) XXX_Marshal ¶
func (m *Span_TimeEvent_MessageEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Span_TimeEvent_MessageEvent) XXX_Merge ¶
func (m *Span_TimeEvent_MessageEvent) XXX_Merge(src proto.Message)
func (*Span_TimeEvent_MessageEvent) XXX_Size ¶
func (m *Span_TimeEvent_MessageEvent) XXX_Size() int
func (*Span_TimeEvent_MessageEvent) XXX_Unmarshal ¶
func (m *Span_TimeEvent_MessageEvent) XXX_Unmarshal(b []byte) error
type Span_TimeEvent_MessageEvent_ ¶
type Span_TimeEvent_MessageEvent_ struct {
MessageEvent *Span_TimeEvent_MessageEvent `protobuf:"bytes,3,opt,name=message_event,json=messageEvent,proto3,oneof"`
}
type Span_TimeEvent_MessageEvent_Type ¶
type Span_TimeEvent_MessageEvent_Type int32
Indicates whether the message was sent or received.
const ( // Unknown event type. Span_TimeEvent_MessageEvent_TYPE_UNSPECIFIED Span_TimeEvent_MessageEvent_Type = 0 // Indicates a sent message. Span_TimeEvent_MessageEvent_SENT Span_TimeEvent_MessageEvent_Type = 1 // Indicates a received message. Span_TimeEvent_MessageEvent_RECEIVED Span_TimeEvent_MessageEvent_Type = 2 )
func (Span_TimeEvent_MessageEvent_Type) EnumDescriptor ¶
func (Span_TimeEvent_MessageEvent_Type) EnumDescriptor() ([]byte, []int)
func (Span_TimeEvent_MessageEvent_Type) String ¶
func (x Span_TimeEvent_MessageEvent_Type) String() string
type Span_TimeEvents ¶
type Span_TimeEvents struct { // A collection of `TimeEvent`s. TimeEvent []*Span_TimeEvent `protobuf:"bytes,1,rep,name=time_event,json=timeEvent,proto3" json:"time_event,omitempty"` // The number of dropped annotations in all the included time events. // If the value is 0, then no annotations were dropped. DroppedAnnotationsCount int32 `` /* 133-byte string literal not displayed */ // The number of dropped message events in all the included time events. // If the value is 0, then no message events were dropped. DroppedMessageEventsCount int32 `` /* 141-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A collection of `TimeEvent`s. A `TimeEvent` is a time-stamped annotation on the span, consisting of either user-supplied key-value pairs, or details of a message sent/received between Spans.
func (*Span_TimeEvents) Descriptor ¶
func (*Span_TimeEvents) Descriptor() ([]byte, []int)
func (*Span_TimeEvents) GetDroppedAnnotationsCount ¶
func (m *Span_TimeEvents) GetDroppedAnnotationsCount() int32
func (*Span_TimeEvents) GetDroppedMessageEventsCount ¶
func (m *Span_TimeEvents) GetDroppedMessageEventsCount() int32
func (*Span_TimeEvents) GetTimeEvent ¶
func (m *Span_TimeEvents) GetTimeEvent() []*Span_TimeEvent
func (*Span_TimeEvents) ProtoMessage ¶
func (*Span_TimeEvents) ProtoMessage()
func (*Span_TimeEvents) Reset ¶
func (m *Span_TimeEvents) Reset()
func (*Span_TimeEvents) String ¶
func (m *Span_TimeEvents) String() string
func (*Span_TimeEvents) XXX_DiscardUnknown ¶
func (m *Span_TimeEvents) XXX_DiscardUnknown()
func (*Span_TimeEvents) XXX_Marshal ¶
func (m *Span_TimeEvents) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Span_TimeEvents) XXX_Merge ¶
func (m *Span_TimeEvents) XXX_Merge(src proto.Message)
func (*Span_TimeEvents) XXX_Size ¶
func (m *Span_TimeEvents) XXX_Size() int
func (*Span_TimeEvents) XXX_Unmarshal ¶
func (m *Span_TimeEvents) XXX_Unmarshal(b []byte) error
type Span_Tracestate ¶
type Span_Tracestate struct { // A list of entries that represent the Tracestate. Entries []*Span_Tracestate_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
This field conveys information about request position in multiple distributed tracing graphs. It is a list of Tracestate.Entry with a maximum of 32 members in the list.
See the https://github.com/w3c/distributed-tracing for more details about this field.
func (*Span_Tracestate) Descriptor ¶
func (*Span_Tracestate) Descriptor() ([]byte, []int)
func (*Span_Tracestate) GetEntries ¶
func (m *Span_Tracestate) GetEntries() []*Span_Tracestate_Entry
func (*Span_Tracestate) ProtoMessage ¶
func (*Span_Tracestate) ProtoMessage()
func (*Span_Tracestate) Reset ¶
func (m *Span_Tracestate) Reset()
func (*Span_Tracestate) String ¶
func (m *Span_Tracestate) String() string
func (*Span_Tracestate) XXX_DiscardUnknown ¶
func (m *Span_Tracestate) XXX_DiscardUnknown()
func (*Span_Tracestate) XXX_Marshal ¶
func (m *Span_Tracestate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Span_Tracestate) XXX_Merge ¶
func (m *Span_Tracestate) XXX_Merge(src proto.Message)
func (*Span_Tracestate) XXX_Size ¶
func (m *Span_Tracestate) XXX_Size() int
func (*Span_Tracestate) XXX_Unmarshal ¶
func (m *Span_Tracestate) XXX_Unmarshal(b []byte) error
type Span_Tracestate_Entry ¶
type Span_Tracestate_Entry struct { // The key must begin with a lowercase letter, and can only contain // lowercase letters 'a'-'z', digits '0'-'9', underscores '_', dashes // '-', asterisks '*', and forward slashes '/'. Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // The value is opaque string up to 256 characters printable ASCII // RFC0020 characters (i.e., the range 0x20 to 0x7E) except ',' and '='. // Note that this also excludes tabs, newlines, carriage returns, etc. Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Span_Tracestate_Entry) Descriptor ¶
func (*Span_Tracestate_Entry) Descriptor() ([]byte, []int)
func (*Span_Tracestate_Entry) GetKey ¶
func (m *Span_Tracestate_Entry) GetKey() string
func (*Span_Tracestate_Entry) GetValue ¶
func (m *Span_Tracestate_Entry) GetValue() string
func (*Span_Tracestate_Entry) ProtoMessage ¶
func (*Span_Tracestate_Entry) ProtoMessage()
func (*Span_Tracestate_Entry) Reset ¶
func (m *Span_Tracestate_Entry) Reset()
func (*Span_Tracestate_Entry) String ¶
func (m *Span_Tracestate_Entry) String() string
func (*Span_Tracestate_Entry) XXX_DiscardUnknown ¶
func (m *Span_Tracestate_Entry) XXX_DiscardUnknown()
func (*Span_Tracestate_Entry) XXX_Marshal ¶
func (m *Span_Tracestate_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Span_Tracestate_Entry) XXX_Merge ¶
func (m *Span_Tracestate_Entry) XXX_Merge(src proto.Message)
func (*Span_Tracestate_Entry) XXX_Size ¶
func (m *Span_Tracestate_Entry) XXX_Size() int
func (*Span_Tracestate_Entry) XXX_Unmarshal ¶
func (m *Span_Tracestate_Entry) XXX_Unmarshal(b []byte) error
type StackTrace ¶
type StackTrace struct { // Stack frames in this stack trace. StackFrames *StackTrace_StackFrames `protobuf:"bytes,1,opt,name=stack_frames,json=stackFrames,proto3" json:"stack_frames,omitempty"` // The hash ID is used to conserve network bandwidth for duplicate // stack traces within a single trace. // // Often multiple spans will have identical stack traces. // The first occurrence of a stack trace should contain both // `stack_frames` and a value in `stack_trace_hash_id`. // // Subsequent spans within the same request can refer // to that stack trace by setting only `stack_trace_hash_id`. // // TODO: describe how to deal with the case where stack_trace_hash_id is // zero because it was not set. StackTraceHashId uint64 `protobuf:"varint,2,opt,name=stack_trace_hash_id,json=stackTraceHashId,proto3" json:"stack_trace_hash_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The call stack which originated this span.
func (*StackTrace) Descriptor ¶
func (*StackTrace) Descriptor() ([]byte, []int)
func (*StackTrace) GetStackFrames ¶
func (m *StackTrace) GetStackFrames() *StackTrace_StackFrames
func (*StackTrace) GetStackTraceHashId ¶
func (m *StackTrace) GetStackTraceHashId() uint64
func (*StackTrace) ProtoMessage ¶
func (*StackTrace) ProtoMessage()
func (*StackTrace) Reset ¶
func (m *StackTrace) Reset()
func (*StackTrace) String ¶
func (m *StackTrace) String() string
func (*StackTrace) XXX_DiscardUnknown ¶
func (m *StackTrace) XXX_DiscardUnknown()
func (*StackTrace) XXX_Marshal ¶
func (m *StackTrace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StackTrace) XXX_Merge ¶
func (m *StackTrace) XXX_Merge(src proto.Message)
func (*StackTrace) XXX_Size ¶
func (m *StackTrace) XXX_Size() int
func (*StackTrace) XXX_Unmarshal ¶
func (m *StackTrace) XXX_Unmarshal(b []byte) error
type StackTrace_StackFrame ¶
type StackTrace_StackFrame struct { // The fully-qualified name that uniquely identifies the function or // method that is active in this frame. FunctionName string `protobuf:"bytes,1,opt,name=function_name,json=functionName,proto3" json:"function_name,omitempty"` // An un-mangled function name, if `function_name` is // [mangled](http://www.avabodh.com/cxxin/namemangling.html). The name can // be fully qualified. OriginalFunctionName string `protobuf:"bytes,2,opt,name=original_function_name,json=originalFunctionName,proto3" json:"original_function_name,omitempty"` // The name of the source file where the function call appears. FileName string `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"` // The line number in `file_name` where the function call appears. LineNumber int64 `protobuf:"varint,4,opt,name=line_number,json=lineNumber,proto3" json:"line_number,omitempty"` // The column number where the function call appears, if available. // This is important in JavaScript because of its anonymous functions. ColumnNumber int64 `protobuf:"varint,5,opt,name=column_number,json=columnNumber,proto3" json:"column_number,omitempty"` // The binary module from where the code was loaded. LoadModule *Module `protobuf:"bytes,6,opt,name=load_module,json=loadModule,proto3" json:"load_module,omitempty"` // The version of the deployed source code. SourceVersion string `protobuf:"bytes,7,opt,name=source_version,json=sourceVersion,proto3" json:"source_version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A single stack frame in a stack trace.
func (*StackTrace_StackFrame) Descriptor ¶
func (*StackTrace_StackFrame) Descriptor() ([]byte, []int)
func (*StackTrace_StackFrame) GetColumnNumber ¶
func (m *StackTrace_StackFrame) GetColumnNumber() int64
func (*StackTrace_StackFrame) GetFileName ¶
func (m *StackTrace_StackFrame) GetFileName() string
func (*StackTrace_StackFrame) GetFunctionName ¶
func (m *StackTrace_StackFrame) GetFunctionName() string
func (*StackTrace_StackFrame) GetLineNumber ¶
func (m *StackTrace_StackFrame) GetLineNumber() int64
func (*StackTrace_StackFrame) GetLoadModule ¶
func (m *StackTrace_StackFrame) GetLoadModule() *Module
func (*StackTrace_StackFrame) GetOriginalFunctionName ¶
func (m *StackTrace_StackFrame) GetOriginalFunctionName() string
func (*StackTrace_StackFrame) GetSourceVersion ¶
func (m *StackTrace_StackFrame) GetSourceVersion() string
func (*StackTrace_StackFrame) ProtoMessage ¶
func (*StackTrace_StackFrame) ProtoMessage()
func (*StackTrace_StackFrame) Reset ¶
func (m *StackTrace_StackFrame) Reset()
func (*StackTrace_StackFrame) String ¶
func (m *StackTrace_StackFrame) String() string
func (*StackTrace_StackFrame) XXX_DiscardUnknown ¶
func (m *StackTrace_StackFrame) XXX_DiscardUnknown()
func (*StackTrace_StackFrame) XXX_Marshal ¶
func (m *StackTrace_StackFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StackTrace_StackFrame) XXX_Merge ¶
func (m *StackTrace_StackFrame) XXX_Merge(src proto.Message)
func (*StackTrace_StackFrame) XXX_Size ¶
func (m *StackTrace_StackFrame) XXX_Size() int
func (*StackTrace_StackFrame) XXX_Unmarshal ¶
func (m *StackTrace_StackFrame) XXX_Unmarshal(b []byte) error
type StackTrace_StackFrames ¶
type StackTrace_StackFrames struct { // Stack frames in this call stack. Frame []*StackTrace_StackFrame `protobuf:"bytes,1,rep,name=frame,proto3" json:"frame,omitempty"` // The number of stack frames that were dropped because there // were too many stack frames. // If this value is 0, then no stack frames were dropped. DroppedFramesCount int32 `protobuf:"varint,2,opt,name=dropped_frames_count,json=droppedFramesCount,proto3" json:"dropped_frames_count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A collection of stack frames, which can be truncated.
func (*StackTrace_StackFrames) Descriptor ¶
func (*StackTrace_StackFrames) Descriptor() ([]byte, []int)
func (*StackTrace_StackFrames) GetDroppedFramesCount ¶
func (m *StackTrace_StackFrames) GetDroppedFramesCount() int32
func (*StackTrace_StackFrames) GetFrame ¶
func (m *StackTrace_StackFrames) GetFrame() []*StackTrace_StackFrame
func (*StackTrace_StackFrames) ProtoMessage ¶
func (*StackTrace_StackFrames) ProtoMessage()
func (*StackTrace_StackFrames) Reset ¶
func (m *StackTrace_StackFrames) Reset()
func (*StackTrace_StackFrames) String ¶
func (m *StackTrace_StackFrames) String() string
func (*StackTrace_StackFrames) XXX_DiscardUnknown ¶
func (m *StackTrace_StackFrames) XXX_DiscardUnknown()
func (*StackTrace_StackFrames) XXX_Marshal ¶
func (m *StackTrace_StackFrames) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StackTrace_StackFrames) XXX_Merge ¶
func (m *StackTrace_StackFrames) XXX_Merge(src proto.Message)
func (*StackTrace_StackFrames) XXX_Size ¶
func (m *StackTrace_StackFrames) XXX_Size() int
func (*StackTrace_StackFrames) XXX_Unmarshal ¶
func (m *StackTrace_StackFrames) XXX_Unmarshal(b []byte) error
type Status ¶
type Status struct { // The status code. This is optional field. It is safe to assume 0 (OK) // when not set. Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` // A developer-facing error message, which should be in English. Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. This proto's fields are a subset of those of [google.rpc.Status](https://github.com/googleapis/googleapis/blob/master/google/rpc/status.proto), which is used by [gRPC](https://github.com/grpc).
func (*Status) Descriptor ¶
func (*Status) GetMessage ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) XXX_DiscardUnknown ¶
func (m *Status) XXX_DiscardUnknown()
func (*Status) XXX_Marshal ¶
func (*Status) XXX_Unmarshal ¶
type StreamExporterClient ¶
type StreamExporterClient interface { // Sends a batch of telemetry data. Export(ctx context.Context, opts ...grpc.CallOption) (StreamExporter_ExportClient, error) }
StreamExporterClient is the client API for StreamExporter service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStreamExporterClient ¶
func NewStreamExporterClient(cc *grpc.ClientConn) StreamExporterClient
type StreamExporterServer ¶
type StreamExporterServer interface { // Sends a batch of telemetry data. Export(StreamExporter_ExportServer) error }
StreamExporterServer is the server API for StreamExporter service.
type StreamExporter_ExportClient ¶
type StreamExporter_ExportClient interface { Send(*ExportRequest) error Recv() (*ExportResponse, error) grpc.ClientStream }
type StreamExporter_ExportServer ¶
type StreamExporter_ExportServer interface { Send(*ExportResponse) error Recv() (*ExportRequest, error) grpc.ServerStream }
type UnaryExporterClient ¶
type UnaryExporterClient interface { // Sends a batch of telemetry data. Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (*ExportResponse, error) }
UnaryExporterClient is the client API for UnaryExporter service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewUnaryExporterClient ¶
func NewUnaryExporterClient(cc *grpc.ClientConn) UnaryExporterClient
type UnaryExporterServer ¶
type UnaryExporterServer interface { // Sends a batch of telemetry data. Export(context.Context, *ExportRequest) (*ExportResponse, error) }
UnaryExporterServer is the server API for UnaryExporter service.
type UnimplementedStreamExporterServer ¶
type UnimplementedStreamExporterServer struct { }
UnimplementedStreamExporterServer can be embedded to have forward compatible implementations.
func (*UnimplementedStreamExporterServer) Export ¶
func (*UnimplementedStreamExporterServer) Export(srv StreamExporter_ExportServer) error
type UnimplementedUnaryExporterServer ¶
type UnimplementedUnaryExporterServer struct { }
UnimplementedUnaryExporterServer can be embedded to have forward compatible implementations.
func (*UnimplementedUnaryExporterServer) Export ¶
func (*UnimplementedUnaryExporterServer) Export(ctx context.Context, req *ExportRequest) (*ExportResponse, error)