Documentation ¶
Index ¶
- Variables
- func RegisterStreamExporterServer(s grpc.ServiceRegistrar, srv StreamExporterServer)
- func RegisterUnaryExporterServer(s grpc.ServiceRegistrar, srv UnaryExporterServer)
- type AggregationTemporality
- func (AggregationTemporality) Descriptor() protoreflect.EnumDescriptor
- func (x AggregationTemporality) Enum() *AggregationTemporality
- func (AggregationTemporality) EnumDescriptor() ([]byte, []int)deprecated
- func (x AggregationTemporality) Number() protoreflect.EnumNumber
- func (x AggregationTemporality) String() string
- func (AggregationTemporality) Type() protoreflect.EnumType
- type AnyValue
- func (*AnyValue) Descriptor() ([]byte, []int)deprecated
- func (x *AnyValue) GetArrayValue() *ArrayValue
- func (x *AnyValue) GetBoolValue() bool
- func (x *AnyValue) GetDoubleValue() float64
- func (x *AnyValue) GetIntValue() int64
- func (x *AnyValue) GetKvlistValue() *KeyValueList
- func (x *AnyValue) GetStringValue() string
- func (m *AnyValue) GetValue() isAnyValue_Value
- func (*AnyValue) ProtoMessage()
- func (x *AnyValue) ProtoReflect() protoreflect.Message
- func (x *AnyValue) Reset()
- func (x *AnyValue) String() string
- type AnyValue_ArrayValue
- type AnyValue_BoolValue
- type AnyValue_DoubleValue
- type AnyValue_IntValue
- type AnyValue_KvlistValue
- type AnyValue_StringValue
- type ArrayValue
- type Capabilities
- func (Capabilities) Descriptor() protoreflect.EnumDescriptor
- func (x Capabilities) Enum() *Capabilities
- func (Capabilities) EnumDescriptor() ([]byte, []int)deprecated
- func (x Capabilities) Number() protoreflect.EnumNumber
- func (x Capabilities) String() string
- func (Capabilities) Type() protoreflect.EnumType
- type CompressionMethod
- func (CompressionMethod) Descriptor() protoreflect.EnumDescriptor
- func (x CompressionMethod) Enum() *CompressionMethod
- func (CompressionMethod) EnumDescriptor() ([]byte, []int)deprecated
- func (x CompressionMethod) Number() protoreflect.EnumNumber
- func (x CompressionMethod) String() string
- func (CompressionMethod) Type() protoreflect.EnumType
- type Exemplar
- func (*Exemplar) Descriptor() ([]byte, []int)deprecated
- func (x *Exemplar) GetAsDouble() float64
- func (x *Exemplar) GetAsInt() int64
- func (x *Exemplar) GetFilteredLabels() []*StringKeyValue
- func (x *Exemplar) GetSpanId() []byte
- func (x *Exemplar) GetTimeUnixNano() uint64
- func (x *Exemplar) GetTraceId() []byte
- func (m *Exemplar) GetValue() isExemplar_Value
- func (*Exemplar) ProtoMessage()
- func (x *Exemplar) ProtoReflect() protoreflect.Message
- func (x *Exemplar) Reset()
- func (x *Exemplar) String() string
- type Exemplar_AsDouble
- type Exemplar_AsInt
- type ExportLogsServiceRequest
- func (*ExportLogsServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExportLogsServiceRequest) GetResourceLogs() []*ResourceLogs
- func (*ExportLogsServiceRequest) ProtoMessage()
- func (x *ExportLogsServiceRequest) ProtoReflect() protoreflect.Message
- func (x *ExportLogsServiceRequest) Reset()
- func (x *ExportLogsServiceRequest) String() string
- type ExportLogsServiceResponse
- type ExportResponse
- func (*ExportResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExportResponse) GetId() uint64
- func (x *ExportResponse) GetResultCode() ExportResponse_ResultCode
- func (*ExportResponse) ProtoMessage()
- func (x *ExportResponse) ProtoReflect() protoreflect.Message
- func (x *ExportResponse) Reset()
- func (x *ExportResponse) String() string
- type ExportResponse_ResultCode
- func (ExportResponse_ResultCode) Descriptor() protoreflect.EnumDescriptor
- func (x ExportResponse_ResultCode) Enum() *ExportResponse_ResultCode
- func (ExportResponse_ResultCode) EnumDescriptor() ([]byte, []int)deprecated
- func (x ExportResponse_ResultCode) Number() protoreflect.EnumNumber
- func (x ExportResponse_ResultCode) String() string
- func (ExportResponse_ResultCode) Type() protoreflect.EnumType
- type Gauge
- type Generator
- func (g *Generator) GenerateLogBatch(logsPerBatch int, attrsPerLog int) core.ExportRequest
- func (g *Generator) GenerateMetricBatch(metricsPerBatch int, valuesPerTimeseries int, int64 bool, histogram bool, ...) core.ExportRequest
- func (g *Generator) GenerateSpanBatch(spansPerBatch int, attrsPerSpan int, timedEventsPerSpan int) core.ExportRequest
- type Histogram
- func (*Histogram) Descriptor() ([]byte, []int)deprecated
- func (x *Histogram) GetAggregationTemporality() AggregationTemporality
- func (x *Histogram) GetDataPoints() []*HistogramDataPoint
- func (*Histogram) ProtoMessage()
- func (x *Histogram) ProtoReflect() protoreflect.Message
- func (x *Histogram) Reset()
- func (x *Histogram) String() string
- type HistogramDataPoint
- func (*HistogramDataPoint) Descriptor() ([]byte, []int)deprecated
- func (x *HistogramDataPoint) GetBucketCounts() []uint64
- func (x *HistogramDataPoint) GetCount() uint64
- func (x *HistogramDataPoint) GetExemplars() []*Exemplar
- func (x *HistogramDataPoint) GetExplicitBounds() []float64
- func (x *HistogramDataPoint) GetLabels() []*StringKeyValue
- func (x *HistogramDataPoint) GetStartTimeUnixNano() uint64
- func (x *HistogramDataPoint) GetSum() float64
- func (x *HistogramDataPoint) GetTimeUnixNano() uint64
- func (*HistogramDataPoint) ProtoMessage()
- func (x *HistogramDataPoint) ProtoReflect() protoreflect.Message
- func (x *HistogramDataPoint) Reset()
- func (x *HistogramDataPoint) String() string
- type InstrumentationLibrary
- func (*InstrumentationLibrary) Descriptor() ([]byte, []int)deprecated
- func (x *InstrumentationLibrary) GetName() string
- func (x *InstrumentationLibrary) GetVersion() string
- func (*InstrumentationLibrary) ProtoMessage()
- func (x *InstrumentationLibrary) ProtoReflect() protoreflect.Message
- func (x *InstrumentationLibrary) Reset()
- func (x *InstrumentationLibrary) String() string
- type InstrumentationLibraryLogs
- func (*InstrumentationLibraryLogs) Descriptor() ([]byte, []int)deprecated
- func (x *InstrumentationLibraryLogs) GetInstrumentationLibrary() *InstrumentationLibrary
- func (x *InstrumentationLibraryLogs) GetLogs() []*LogRecord
- func (*InstrumentationLibraryLogs) ProtoMessage()
- func (x *InstrumentationLibraryLogs) ProtoReflect() protoreflect.Message
- func (x *InstrumentationLibraryLogs) Reset()
- func (x *InstrumentationLibraryLogs) String() string
- type InstrumentationLibraryMetrics
- func (*InstrumentationLibraryMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *InstrumentationLibraryMetrics) GetInstrumentationLibrary() *InstrumentationLibrary
- func (x *InstrumentationLibraryMetrics) GetMetrics() []*Metric
- func (*InstrumentationLibraryMetrics) ProtoMessage()
- func (x *InstrumentationLibraryMetrics) ProtoReflect() protoreflect.Message
- func (x *InstrumentationLibraryMetrics) Reset()
- func (x *InstrumentationLibraryMetrics) String() string
- type InstrumentationLibrarySpans
- func (*InstrumentationLibrarySpans) Descriptor() ([]byte, []int)deprecated
- func (x *InstrumentationLibrarySpans) GetInstrumentationLibrary() *InstrumentationLibrary
- func (x *InstrumentationLibrarySpans) GetSpans() []*Span
- func (*InstrumentationLibrarySpans) ProtoMessage()
- func (x *InstrumentationLibrarySpans) ProtoReflect() protoreflect.Message
- func (x *InstrumentationLibrarySpans) Reset()
- func (x *InstrumentationLibrarySpans) String() string
- type IntDataPointdeprecated
- func (*IntDataPoint) Descriptor() ([]byte, []int)deprecated
- func (x *IntDataPoint) GetExemplars() []*IntExemplar
- func (x *IntDataPoint) GetLabels() []*StringKeyValue
- func (x *IntDataPoint) GetStartTimeUnixNano() uint64
- func (x *IntDataPoint) GetTimeUnixNano() uint64
- func (x *IntDataPoint) GetValue() int64
- func (*IntDataPoint) ProtoMessage()
- func (x *IntDataPoint) ProtoReflect() protoreflect.Message
- func (x *IntDataPoint) Reset()
- func (x *IntDataPoint) String() string
- type IntExemplardeprecated
- func (*IntExemplar) Descriptor() ([]byte, []int)deprecated
- func (x *IntExemplar) GetFilteredLabels() []*StringKeyValue
- func (x *IntExemplar) GetSpanId() []byte
- func (x *IntExemplar) GetTimeUnixNano() uint64
- func (x *IntExemplar) GetTraceId() []byte
- func (x *IntExemplar) GetValue() int64
- func (*IntExemplar) ProtoMessage()
- func (x *IntExemplar) ProtoReflect() protoreflect.Message
- func (x *IntExemplar) Reset()
- func (x *IntExemplar) String() string
- type IntGaugedeprecated
- type IntHistogramdeprecated
- func (*IntHistogram) Descriptor() ([]byte, []int)deprecated
- func (x *IntHistogram) GetAggregationTemporality() AggregationTemporality
- func (x *IntHistogram) GetDataPoints() []*IntHistogramDataPoint
- func (*IntHistogram) ProtoMessage()
- func (x *IntHistogram) ProtoReflect() protoreflect.Message
- func (x *IntHistogram) Reset()
- func (x *IntHistogram) String() string
- type IntHistogramDataPointdeprecated
- func (*IntHistogramDataPoint) Descriptor() ([]byte, []int)deprecated
- func (x *IntHistogramDataPoint) GetBucketCounts() []uint64
- func (x *IntHistogramDataPoint) GetCount() uint64
- func (x *IntHistogramDataPoint) GetExemplars() []*IntExemplar
- func (x *IntHistogramDataPoint) GetExplicitBounds() []float64
- func (x *IntHistogramDataPoint) GetLabels() []*StringKeyValue
- func (x *IntHistogramDataPoint) GetStartTimeUnixNano() uint64
- func (x *IntHistogramDataPoint) GetSum() int64
- func (x *IntHistogramDataPoint) GetTimeUnixNano() uint64
- func (*IntHistogramDataPoint) ProtoMessage()
- func (x *IntHistogramDataPoint) ProtoReflect() protoreflect.Message
- func (x *IntHistogramDataPoint) Reset()
- func (x *IntHistogramDataPoint) String() string
- type IntSumdeprecated
- func (*IntSum) Descriptor() ([]byte, []int)deprecated
- func (x *IntSum) GetAggregationTemporality() AggregationTemporality
- func (x *IntSum) GetDataPoints() []*IntDataPoint
- func (x *IntSum) GetIsMonotonic() bool
- func (*IntSum) ProtoMessage()
- func (x *IntSum) ProtoReflect() protoreflect.Message
- func (x *IntSum) Reset()
- func (x *IntSum) String() string
- type KeyValue
- type KeyValueList
- type LogRecord
- func (*LogRecord) Descriptor() ([]byte, []int)deprecated
- func (x *LogRecord) GetAttributes() []*KeyValue
- func (x *LogRecord) GetBody() *AnyValue
- func (x *LogRecord) GetDroppedAttributesCount() uint32
- func (x *LogRecord) GetFlags() uint32
- func (x *LogRecord) GetName() string
- func (x *LogRecord) GetSeverityNumber() SeverityNumber
- func (x *LogRecord) GetSeverityText() string
- func (x *LogRecord) GetSpanId() []byte
- func (x *LogRecord) GetTimeUnixNano() uint64
- func (x *LogRecord) GetTraceId() []byte
- func (*LogRecord) ProtoMessage()
- func (x *LogRecord) ProtoReflect() protoreflect.Message
- func (x *LogRecord) Reset()
- func (x *LogRecord) String() string
- type LogRecordFlags
- func (LogRecordFlags) Descriptor() protoreflect.EnumDescriptor
- func (x LogRecordFlags) Enum() *LogRecordFlags
- func (LogRecordFlags) EnumDescriptor() ([]byte, []int)deprecated
- func (x LogRecordFlags) Number() protoreflect.EnumNumber
- func (x LogRecordFlags) String() string
- func (LogRecordFlags) Type() protoreflect.EnumType
- type Metric
- func (*Metric) Descriptor() ([]byte, []int)deprecated
- func (m *Metric) GetData() isMetric_Data
- func (x *Metric) GetDescription() string
- func (x *Metric) GetGauge() *Gauge
- func (x *Metric) GetHistogram() *Histogram
- func (x *Metric) GetIntGauge() *IntGaugedeprecated
- func (x *Metric) GetIntHistogram() *IntHistogramdeprecated
- func (x *Metric) GetIntSum() *IntSumdeprecated
- func (x *Metric) GetName() string
- func (x *Metric) GetSum() *Sum
- func (x *Metric) GetSummary() *Summary
- func (x *Metric) GetUnit() string
- func (*Metric) ProtoMessage()
- func (x *Metric) ProtoReflect() protoreflect.Message
- func (x *Metric) Reset()
- func (x *Metric) String() string
- type MetricExportRequest
- func (*MetricExportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MetricExportRequest) GetId() uint64
- func (x *MetricExportRequest) GetResourceMetrics() []*ResourceMetrics
- func (*MetricExportRequest) ProtoMessage()
- func (x *MetricExportRequest) ProtoReflect() protoreflect.Message
- func (x *MetricExportRequest) Reset()
- func (x *MetricExportRequest) String() string
- type Metric_Gauge
- type Metric_Histogram
- type Metric_IntGauge
- type Metric_IntHistogram
- type Metric_IntSum
- type Metric_Sum
- type Metric_Summary
- type NumberDataPoint
- func (*NumberDataPoint) Descriptor() ([]byte, []int)deprecated
- func (x *NumberDataPoint) GetAsDouble() float64
- func (x *NumberDataPoint) GetAsInt() int64
- func (x *NumberDataPoint) GetExemplars() []*Exemplar
- func (x *NumberDataPoint) GetLabels() []*StringKeyValue
- func (x *NumberDataPoint) GetStartTimeUnixNano() uint64
- func (x *NumberDataPoint) GetTimeUnixNano() uint64
- func (m *NumberDataPoint) GetValue() isNumberDataPoint_Value
- func (*NumberDataPoint) ProtoMessage()
- func (x *NumberDataPoint) ProtoReflect() protoreflect.Message
- func (x *NumberDataPoint) Reset()
- func (x *NumberDataPoint) String() string
- type NumberDataPoint_AsDouble
- type NumberDataPoint_AsInt
- type RequestBody
- func (*RequestBody) Descriptor() ([]byte, []int)deprecated
- func (x *RequestBody) GetExport() *TraceExportRequest
- func (x *RequestBody) GetRequestType() RequestType
- func (*RequestBody) ProtoMessage()
- func (x *RequestBody) ProtoReflect() protoreflect.Message
- func (x *RequestBody) Reset()
- func (x *RequestBody) String() string
- type RequestHeader
- func (*RequestHeader) Descriptor() ([]byte, []int)deprecated
- func (x *RequestHeader) GetCompression() CompressionMethod
- func (x *RequestHeader) GetCompressionLevel() int32
- func (*RequestHeader) ProtoMessage()
- func (x *RequestHeader) ProtoReflect() protoreflect.Message
- func (x *RequestHeader) Reset()
- func (x *RequestHeader) String() string
- type RequestType
- func (RequestType) Descriptor() protoreflect.EnumDescriptor
- func (x RequestType) Enum() *RequestType
- func (RequestType) EnumDescriptor() ([]byte, []int)deprecated
- func (x RequestType) Number() protoreflect.EnumNumber
- func (x RequestType) String() string
- func (RequestType) Type() protoreflect.EnumType
- type Resource
- func (*Resource) Descriptor() ([]byte, []int)deprecated
- func (x *Resource) GetAttributes() []*KeyValue
- func (x *Resource) GetDroppedAttributesCount() uint32
- func (*Resource) ProtoMessage()
- func (x *Resource) ProtoReflect() protoreflect.Message
- func (x *Resource) Reset()
- func (x *Resource) String() string
- type ResourceLogs
- func (*ResourceLogs) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceLogs) GetInstrumentationLibraryLogs() []*InstrumentationLibraryLogs
- func (x *ResourceLogs) GetResource() *Resource
- func (*ResourceLogs) ProtoMessage()
- func (x *ResourceLogs) ProtoReflect() protoreflect.Message
- func (x *ResourceLogs) Reset()
- func (x *ResourceLogs) String() string
- type ResourceMetrics
- func (*ResourceMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceMetrics) GetInstrumentationLibraryMetrics() []*InstrumentationLibraryMetrics
- func (x *ResourceMetrics) GetResource() *Resource
- func (*ResourceMetrics) ProtoMessage()
- func (x *ResourceMetrics) ProtoReflect() protoreflect.Message
- func (x *ResourceMetrics) Reset()
- func (x *ResourceMetrics) String() string
- type ResourceSpans
- func (*ResourceSpans) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceSpans) GetInstrumentationLibrarySpans() []*InstrumentationLibrarySpans
- func (x *ResourceSpans) GetResource() *Resource
- func (*ResourceSpans) ProtoMessage()
- func (x *ResourceSpans) ProtoReflect() protoreflect.Message
- func (x *ResourceSpans) Reset()
- func (x *ResourceSpans) String() string
- type Response
- func (*Response) Descriptor() ([]byte, []int)deprecated
- func (x *Response) GetExport() *ExportResponse
- func (x *Response) GetResponseType() RequestType
- func (*Response) ProtoMessage()
- func (x *Response) ProtoReflect() protoreflect.Message
- func (x *Response) Reset()
- func (x *Response) String() string
- type SeverityNumber
- func (SeverityNumber) Descriptor() protoreflect.EnumDescriptor
- func (x SeverityNumber) Enum() *SeverityNumber
- func (SeverityNumber) EnumDescriptor() ([]byte, []int)deprecated
- func (x SeverityNumber) Number() protoreflect.EnumNumber
- func (x SeverityNumber) String() string
- func (SeverityNumber) Type() protoreflect.EnumType
- type Span
- func (*Span) Descriptor() ([]byte, []int)deprecated
- func (x *Span) GetAttributes() []*KeyValue
- func (x *Span) GetDroppedAttributesCount() uint32
- func (x *Span) GetDroppedEventsCount() uint32
- func (x *Span) GetDroppedLinksCount() uint32
- func (x *Span) GetEndTimeUnixNano() uint64
- func (x *Span) GetEvents() []*Span_Event
- func (x *Span) GetKind() Span_SpanKind
- func (x *Span) GetLinks() []*Span_Link
- func (x *Span) GetName() string
- func (x *Span) GetParentSpanId() []byte
- func (x *Span) GetSpanId() []byte
- func (x *Span) GetStartTimeUnixNano() uint64
- func (x *Span) GetStatus() *Status
- func (x *Span) GetTraceId() []byte
- func (x *Span) GetTraceState() string
- func (*Span) ProtoMessage()
- func (x *Span) ProtoReflect() protoreflect.Message
- func (x *Span) Reset()
- func (x *Span) String() string
- type Span_Event
- func (*Span_Event) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Event) GetAttributes() []*KeyValue
- func (x *Span_Event) GetDroppedAttributesCount() uint32
- func (x *Span_Event) GetName() string
- func (x *Span_Event) GetTimeUnixNano() uint64
- func (*Span_Event) ProtoMessage()
- func (x *Span_Event) ProtoReflect() protoreflect.Message
- func (x *Span_Event) Reset()
- func (x *Span_Event) String() string
- type Span_Link
- func (*Span_Link) Descriptor() ([]byte, []int)deprecated
- func (x *Span_Link) GetAttributes() []*KeyValue
- func (x *Span_Link) GetDroppedAttributesCount() uint32
- func (x *Span_Link) GetSpanId() []byte
- func (x *Span_Link) GetTraceId() []byte
- func (x *Span_Link) GetTraceState() string
- func (*Span_Link) ProtoMessage()
- func (x *Span_Link) ProtoReflect() protoreflect.Message
- func (x *Span_Link) Reset()
- func (x *Span_Link) String() string
- type Span_SpanKind
- func (Span_SpanKind) Descriptor() protoreflect.EnumDescriptor
- func (x Span_SpanKind) Enum() *Span_SpanKind
- func (Span_SpanKind) EnumDescriptor() ([]byte, []int)deprecated
- func (x Span_SpanKind) Number() protoreflect.EnumNumber
- func (x Span_SpanKind) String() string
- func (Span_SpanKind) Type() protoreflect.EnumType
- type Status
- type Status_StatusCode
- func (Status_StatusCode) Descriptor() protoreflect.EnumDescriptor
- func (x Status_StatusCode) Enum() *Status_StatusCode
- func (Status_StatusCode) EnumDescriptor() ([]byte, []int)deprecated
- func (x Status_StatusCode) Number() protoreflect.EnumNumber
- func (x Status_StatusCode) String() string
- func (Status_StatusCode) Type() protoreflect.EnumType
- type StreamExporterClient
- type StreamExporterServer
- type StreamExporter_ExportTracesClient
- type StreamExporter_ExportTracesServer
- type StringKeyValue
- func (*StringKeyValue) Descriptor() ([]byte, []int)deprecated
- func (x *StringKeyValue) GetKey() string
- func (x *StringKeyValue) GetValue() string
- func (*StringKeyValue) ProtoMessage()
- func (x *StringKeyValue) ProtoReflect() protoreflect.Message
- func (x *StringKeyValue) Reset()
- func (x *StringKeyValue) String() string
- type Sum
- func (*Sum) Descriptor() ([]byte, []int)deprecated
- func (x *Sum) GetAggregationTemporality() AggregationTemporality
- func (x *Sum) GetDataPoints() []*NumberDataPoint
- func (x *Sum) GetIsMonotonic() bool
- func (*Sum) ProtoMessage()
- func (x *Sum) ProtoReflect() protoreflect.Message
- func (x *Sum) Reset()
- func (x *Sum) String() string
- type Summary
- type SummaryDataPoint
- func (*SummaryDataPoint) Descriptor() ([]byte, []int)deprecated
- func (x *SummaryDataPoint) GetCount() uint64
- func (x *SummaryDataPoint) GetLabels() []*StringKeyValue
- func (x *SummaryDataPoint) GetQuantileValues() []*SummaryDataPoint_ValueAtQuantile
- func (x *SummaryDataPoint) GetStartTimeUnixNano() uint64
- func (x *SummaryDataPoint) GetSum() float64
- func (x *SummaryDataPoint) GetTimeUnixNano() uint64
- func (*SummaryDataPoint) ProtoMessage()
- func (x *SummaryDataPoint) ProtoReflect() protoreflect.Message
- func (x *SummaryDataPoint) Reset()
- func (x *SummaryDataPoint) String() string
- type SummaryDataPoint_ValueAtQuantile
- func (*SummaryDataPoint_ValueAtQuantile) Descriptor() ([]byte, []int)deprecated
- func (x *SummaryDataPoint_ValueAtQuantile) GetQuantile() float64
- func (x *SummaryDataPoint_ValueAtQuantile) GetValue() float64
- func (*SummaryDataPoint_ValueAtQuantile) ProtoMessage()
- func (x *SummaryDataPoint_ValueAtQuantile) ProtoReflect() protoreflect.Message
- func (x *SummaryDataPoint_ValueAtQuantile) Reset()
- func (x *SummaryDataPoint_ValueAtQuantile) String() string
- type TraceExportRequest
- func (*TraceExportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TraceExportRequest) GetId() uint64
- func (x *TraceExportRequest) GetResourceSpans() []*ResourceSpans
- func (*TraceExportRequest) ProtoMessage()
- func (x *TraceExportRequest) ProtoReflect() protoreflect.Message
- func (x *TraceExportRequest) Reset()
- func (x *TraceExportRequest) String() string
- type UnaryExporterClient
- type UnaryExporterServer
- type UnimplementedStreamExporterServer
- type UnimplementedUnaryExporterServer
- type UnsafeStreamExporterServer
- type UnsafeUnaryExporterServer
Constants ¶
This section is empty.
Variables ¶
var ( Capabilities_name = map[int32]string{ 0: "SKIP", 1: "ZLIB_COMPRESSION", 2: "LZ4_COMPRESSION", } Capabilities_value = map[string]int32{ "SKIP": 0, "ZLIB_COMPRESSION": 1, "LZ4_COMPRESSION": 2, } )
Enum value maps for Capabilities.
var ( CompressionMethod_name = map[int32]string{ 0: "NONE", 1: "LZ4", 2: "ZLIB", } CompressionMethod_value = map[string]int32{ "NONE": 0, "LZ4": 1, "ZLIB": 2, } )
Enum value maps for CompressionMethod.
var ( RequestType_name = map[int32]string{ 0: "_", 1: "TraceExport", } RequestType_value = map[string]int32{ "_": 0, "TraceExport": 1, } )
Enum value maps for RequestType.
var ( ExportResponse_ResultCode_name = map[int32]string{ 0: "Success", 1: "FailedNoneRetryable", 2: "FailedRetryable", } ExportResponse_ResultCode_value = map[string]int32{ "Success": 0, "FailedNoneRetryable": 1, "FailedRetryable": 2, } )
Enum value maps for ExportResponse_ResultCode.
var ( SeverityNumber_name = map[int32]string{ 0: "SEVERITY_NUMBER_UNSPECIFIED", 1: "SEVERITY_NUMBER_TRACE", 2: "SEVERITY_NUMBER_TRACE2", 3: "SEVERITY_NUMBER_TRACE3", 4: "SEVERITY_NUMBER_TRACE4", 5: "SEVERITY_NUMBER_DEBUG", 6: "SEVERITY_NUMBER_DEBUG2", 7: "SEVERITY_NUMBER_DEBUG3", 8: "SEVERITY_NUMBER_DEBUG4", 9: "SEVERITY_NUMBER_INFO", 10: "SEVERITY_NUMBER_INFO2", 11: "SEVERITY_NUMBER_INFO3", 12: "SEVERITY_NUMBER_INFO4", 13: "SEVERITY_NUMBER_WARN", 14: "SEVERITY_NUMBER_WARN2", 15: "SEVERITY_NUMBER_WARN3", 16: "SEVERITY_NUMBER_WARN4", 17: "SEVERITY_NUMBER_ERROR", 18: "SEVERITY_NUMBER_ERROR2", 19: "SEVERITY_NUMBER_ERROR3", 20: "SEVERITY_NUMBER_ERROR4", 21: "SEVERITY_NUMBER_FATAL", 22: "SEVERITY_NUMBER_FATAL2", 23: "SEVERITY_NUMBER_FATAL3", 24: "SEVERITY_NUMBER_FATAL4", } SeverityNumber_value = map[string]int32{ "SEVERITY_NUMBER_UNSPECIFIED": 0, "SEVERITY_NUMBER_TRACE": 1, "SEVERITY_NUMBER_TRACE2": 2, "SEVERITY_NUMBER_TRACE3": 3, "SEVERITY_NUMBER_TRACE4": 4, "SEVERITY_NUMBER_DEBUG": 5, "SEVERITY_NUMBER_DEBUG2": 6, "SEVERITY_NUMBER_DEBUG3": 7, "SEVERITY_NUMBER_DEBUG4": 8, "SEVERITY_NUMBER_INFO": 9, "SEVERITY_NUMBER_INFO2": 10, "SEVERITY_NUMBER_INFO3": 11, "SEVERITY_NUMBER_INFO4": 12, "SEVERITY_NUMBER_WARN": 13, "SEVERITY_NUMBER_WARN2": 14, "SEVERITY_NUMBER_WARN3": 15, "SEVERITY_NUMBER_WARN4": 16, "SEVERITY_NUMBER_ERROR": 17, "SEVERITY_NUMBER_ERROR2": 18, "SEVERITY_NUMBER_ERROR3": 19, "SEVERITY_NUMBER_ERROR4": 20, "SEVERITY_NUMBER_FATAL": 21, "SEVERITY_NUMBER_FATAL2": 22, "SEVERITY_NUMBER_FATAL3": 23, "SEVERITY_NUMBER_FATAL4": 24, } )
Enum value maps for SeverityNumber.
var ( LogRecordFlags_name = map[int32]string{ 0: "LOG_RECORD_FLAG_UNSPECIFIED", 255: "LOG_RECORD_FLAG_TRACE_FLAGS_MASK", } LogRecordFlags_value = map[string]int32{ "LOG_RECORD_FLAG_UNSPECIFIED": 0, "LOG_RECORD_FLAG_TRACE_FLAGS_MASK": 255, } )
Enum value maps for LogRecordFlags.
var ( AggregationTemporality_name = map[int32]string{ 0: "AGGREGATION_TEMPORALITY_UNSPECIFIED", 1: "AGGREGATION_TEMPORALITY_DELTA", 2: "AGGREGATION_TEMPORALITY_CUMULATIVE", } AggregationTemporality_value = map[string]int32{ "AGGREGATION_TEMPORALITY_UNSPECIFIED": 0, "AGGREGATION_TEMPORALITY_DELTA": 1, "AGGREGATION_TEMPORALITY_CUMULATIVE": 2, } )
Enum value maps for AggregationTemporality.
var ( Span_SpanKind_name = map[int32]string{ 0: "SPAN_KIND_UNSPECIFIED", 1: "SPAN_KIND_INTERNAL", 2: "SPAN_KIND_SERVER", 3: "SPAN_KIND_CLIENT", 4: "SPAN_KIND_PRODUCER", 5: "SPAN_KIND_CONSUMER", } Span_SpanKind_value = map[string]int32{ "SPAN_KIND_UNSPECIFIED": 0, "SPAN_KIND_INTERNAL": 1, "SPAN_KIND_SERVER": 2, "SPAN_KIND_CLIENT": 3, "SPAN_KIND_PRODUCER": 4, "SPAN_KIND_CONSUMER": 5, } )
Enum value maps for Span_SpanKind.
var ( Status_StatusCode_name = map[int32]string{ 0: "STATUS_CODE_OK", 1: "STATUS_CODE_CANCELLED", 2: "STATUS_CODE_UNKNOWN_ERROR", 3: "STATUS_CODE_INVALID_ARGUMENT", 4: "STATUS_CODE_DEADLINE_EXCEEDED", 5: "STATUS_CODE_NOT_FOUND", 6: "STATUS_CODE_ALREADY_EXISTS", 7: "STATUS_CODE_PERMISSION_DENIED", 8: "STATUS_CODE_RESOURCE_EXHAUSTED", 9: "STATUS_CODE_FAILED_PRECONDITION", 10: "STATUS_CODE_ABORTED", 11: "STATUS_CODE_OUT_OF_RANGE", 12: "STATUS_CODE_UNIMPLEMENTED", 13: "STATUS_CODE_INTERNAL_ERROR", 14: "STATUS_CODE_UNAVAILABLE", 15: "STATUS_CODE_DATA_LOSS", 16: "STATUS_CODE_UNAUTHENTICATED", } Status_StatusCode_value = map[string]int32{ "STATUS_CODE_OK": 0, "STATUS_CODE_CANCELLED": 1, "STATUS_CODE_UNKNOWN_ERROR": 2, "STATUS_CODE_INVALID_ARGUMENT": 3, "STATUS_CODE_DEADLINE_EXCEEDED": 4, "STATUS_CODE_NOT_FOUND": 5, "STATUS_CODE_ALREADY_EXISTS": 6, "STATUS_CODE_PERMISSION_DENIED": 7, "STATUS_CODE_RESOURCE_EXHAUSTED": 8, "STATUS_CODE_FAILED_PRECONDITION": 9, "STATUS_CODE_ABORTED": 10, "STATUS_CODE_OUT_OF_RANGE": 11, "STATUS_CODE_UNIMPLEMENTED": 12, "STATUS_CODE_INTERNAL_ERROR": 13, "STATUS_CODE_UNAVAILABLE": 14, "STATUS_CODE_DATA_LOSS": 15, "STATUS_CODE_UNAUTHENTICATED": 16, } )
Enum value maps for Status_StatusCode.
var File_common_proto protoreflect.FileDescriptor
var File_exchange_proto protoreflect.FileDescriptor
var File_grpc_proto protoreflect.FileDescriptor
var File_logs_proto protoreflect.FileDescriptor
var File_logs_service_proto protoreflect.FileDescriptor
var File_metric_data_proto protoreflect.FileDescriptor
var File_telemetry_data_proto protoreflect.FileDescriptor
var StreamExporter_ServiceDesc = grpc.ServiceDesc{ ServiceName: "baseline.StreamExporter", HandlerType: (*StreamExporterServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "ExportTraces", Handler: _StreamExporter_ExportTraces_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "grpc.proto", }
StreamExporter_ServiceDesc is the grpc.ServiceDesc for StreamExporter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var UnaryExporter_ServiceDesc = grpc.ServiceDesc{ ServiceName: "baseline.UnaryExporter", HandlerType: (*UnaryExporterServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ExportTraces", Handler: _UnaryExporter_ExportTraces_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc.proto", }
UnaryExporter_ServiceDesc is the grpc.ServiceDesc for UnaryExporter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterStreamExporterServer ¶
func RegisterStreamExporterServer(s grpc.ServiceRegistrar, srv StreamExporterServer)
func RegisterUnaryExporterServer ¶
func RegisterUnaryExporterServer(s grpc.ServiceRegistrar, srv UnaryExporterServer)
Types ¶
type AggregationTemporality ¶
type AggregationTemporality int32
AggregationTemporality defines how a metric aggregator reports aggregated values. It describes how those values relate to the time interval over which they are aggregated.
const ( // UNSPECIFIED is the default AggregationTemporality, it MUST not be used. AggregationTemporality_AGGREGATION_TEMPORALITY_UNSPECIFIED AggregationTemporality = 0 // DELTA is an AggregationTemporality for a metric aggregator which reports // changes since last report time. Successive metrics contain aggregation of // values from continuous and non-overlapping intervals. // // The values for a DELTA metric are based only on the time interval // associated with one measurement cycle. There is no dependency on // previous measurements like is the case for CUMULATIVE metrics. // // For example, consider a system measuring the number of requests that // it receives and reports the sum of these requests every second as a // DELTA metric: // // 1. The system starts receiving at time=t_0. // 2. A request is received, the system measures 1 request. // 3. A request is received, the system measures 1 request. // 4. A request is received, the system measures 1 request. // 5. The 1 second collection cycle ends. A metric is exported for the // number of requests received over the interval of time t_0 to // t_0+1 with a value of 3. // 6. A request is received, the system measures 1 request. // 7. A request is received, the system measures 1 request. // 8. The 1 second collection cycle ends. A metric is exported for the // number of requests received over the interval of time t_0+1 to // t_0+2 with a value of 2. AggregationTemporality_AGGREGATION_TEMPORALITY_DELTA AggregationTemporality = 1 // CUMULATIVE is an AggregationTemporality for a metric aggregator which // reports changes since a fixed start time. This means that current values // of a CUMULATIVE metric depend on all previous measurements since the // start time. Because of this, the sender is required to retain this state // in some form. If this state is lost or invalidated, the CUMULATIVE metric // values MUST be reset and a new fixed start time following the last // reported measurement time sent MUST be used. // // For example, consider a system measuring the number of requests that // it receives and reports the sum of these requests every second as a // CUMULATIVE metric: // // 1. The system starts receiving at time=t_0. // 2. A request is received, the system measures 1 request. // 3. A request is received, the system measures 1 request. // 4. A request is received, the system measures 1 request. // 5. The 1 second collection cycle ends. A metric is exported for the // number of requests received over the interval of time t_0 to // t_0+1 with a value of 3. // 6. A request is received, the system measures 1 request. // 7. A request is received, the system measures 1 request. // 8. The 1 second collection cycle ends. A metric is exported for the // number of requests received over the interval of time t_0 to // t_0+2 with a value of 5. // 9. The system experiences a fault and loses state. // 10. The system recovers and resumes receiving at time=t_1. // 11. A request is received, the system measures 1 request. // 12. The 1 second collection cycle ends. A metric is exported for the // number of requests received over the interval of time t_1 to // t_0+1 with a value of 1. // // Note: Even though, when reporting changes since last report time, using // CUMULATIVE is valid, it is not recommended. This may cause problems for // systems that do not use start_time to determine when the aggregation // value was reset (e.g. Prometheus). AggregationTemporality_AGGREGATION_TEMPORALITY_CUMULATIVE AggregationTemporality = 2 )
func (AggregationTemporality) Descriptor ¶
func (AggregationTemporality) Descriptor() protoreflect.EnumDescriptor
func (AggregationTemporality) Enum ¶
func (x AggregationTemporality) Enum() *AggregationTemporality
func (AggregationTemporality) EnumDescriptor
deprecated
func (AggregationTemporality) EnumDescriptor() ([]byte, []int)
Deprecated: Use AggregationTemporality.Descriptor instead.
func (AggregationTemporality) Number ¶
func (x AggregationTemporality) Number() protoreflect.EnumNumber
func (AggregationTemporality) String ¶
func (x AggregationTemporality) String() string
func (AggregationTemporality) Type ¶
func (AggregationTemporality) Type() protoreflect.EnumType
type AnyValue ¶
type AnyValue struct { // The value is one of the listed fields. It is valid for all values to be unspecified // in which case this AnyValue is considered to be "null". // // Types that are assignable to Value: // *AnyValue_StringValue // *AnyValue_BoolValue // *AnyValue_IntValue // *AnyValue_DoubleValue // *AnyValue_ArrayValue // *AnyValue_KvlistValue Value isAnyValue_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
AnyValue is used to represent any type of attribute value. AnyValue may contain a primitive value such as a string or integer or it may contain an arbitrary nested object containing arrays, key-value lists and primitives.
func (*AnyValue) Descriptor
deprecated
func (*AnyValue) GetArrayValue ¶
func (x *AnyValue) GetArrayValue() *ArrayValue
func (*AnyValue) GetBoolValue ¶
func (*AnyValue) GetDoubleValue ¶
func (*AnyValue) GetIntValue ¶
func (*AnyValue) GetKvlistValue ¶
func (x *AnyValue) GetKvlistValue() *KeyValueList
func (*AnyValue) GetStringValue ¶
func (*AnyValue) ProtoMessage ¶
func (*AnyValue) ProtoMessage()
func (*AnyValue) ProtoReflect ¶
func (x *AnyValue) ProtoReflect() protoreflect.Message
type AnyValue_ArrayValue ¶
type AnyValue_ArrayValue struct {
ArrayValue *ArrayValue `protobuf:"bytes,5,opt,name=array_value,json=arrayValue,proto3,oneof"`
}
type AnyValue_BoolValue ¶
type AnyValue_BoolValue struct {
BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3,oneof"`
}
type AnyValue_DoubleValue ¶
type AnyValue_DoubleValue struct {
DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}
type AnyValue_IntValue ¶
type AnyValue_IntValue struct {
IntValue int64 `protobuf:"varint,3,opt,name=int_value,json=intValue,proto3,oneof"`
}
type AnyValue_KvlistValue ¶
type AnyValue_KvlistValue struct {
KvlistValue *KeyValueList `protobuf:"bytes,6,opt,name=kvlist_value,json=kvlistValue,proto3,oneof"`
}
type AnyValue_StringValue ¶
type AnyValue_StringValue struct {
StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}
type ArrayValue ¶
type ArrayValue struct { // Array of values. The array may be empty (contain 0 elements). Values []*AnyValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
ArrayValue is a list of AnyValue messages. We need ArrayValue as a message since oneof in AnyValue does not allow repeated fields.
func (*ArrayValue) Descriptor
deprecated
func (*ArrayValue) Descriptor() ([]byte, []int)
Deprecated: Use ArrayValue.ProtoReflect.Descriptor instead.
func (*ArrayValue) GetValues ¶
func (x *ArrayValue) GetValues() []*AnyValue
func (*ArrayValue) ProtoMessage ¶
func (*ArrayValue) ProtoMessage()
func (*ArrayValue) ProtoReflect ¶
func (x *ArrayValue) ProtoReflect() protoreflect.Message
func (*ArrayValue) Reset ¶
func (x *ArrayValue) Reset()
func (*ArrayValue) String ¶
func (x *ArrayValue) String() string
type Capabilities ¶
type Capabilities int32
const ( Capabilities_SKIP Capabilities = 0 Capabilities_ZLIB_COMPRESSION Capabilities = 1 // bit 0 of capabilities Capabilities_LZ4_COMPRESSION Capabilities = 2 // bit 1 of capabilities )
func (Capabilities) Descriptor ¶
func (Capabilities) Descriptor() protoreflect.EnumDescriptor
func (Capabilities) Enum ¶
func (x Capabilities) Enum() *Capabilities
func (Capabilities) EnumDescriptor
deprecated
func (Capabilities) EnumDescriptor() ([]byte, []int)
Deprecated: Use Capabilities.Descriptor instead.
func (Capabilities) Number ¶
func (x Capabilities) Number() protoreflect.EnumNumber
func (Capabilities) String ¶
func (x Capabilities) String() string
func (Capabilities) Type ¶
func (Capabilities) Type() protoreflect.EnumType
type CompressionMethod ¶
type CompressionMethod int32
const ( CompressionMethod_NONE CompressionMethod = 0 CompressionMethod_LZ4 CompressionMethod = 1 CompressionMethod_ZLIB CompressionMethod = 2 )
func (CompressionMethod) Descriptor ¶
func (CompressionMethod) Descriptor() protoreflect.EnumDescriptor
func (CompressionMethod) Enum ¶
func (x CompressionMethod) Enum() *CompressionMethod
func (CompressionMethod) EnumDescriptor
deprecated
func (CompressionMethod) EnumDescriptor() ([]byte, []int)
Deprecated: Use CompressionMethod.Descriptor instead.
func (CompressionMethod) Number ¶
func (x CompressionMethod) Number() protoreflect.EnumNumber
func (CompressionMethod) String ¶
func (x CompressionMethod) String() string
func (CompressionMethod) Type ¶
func (CompressionMethod) Type() protoreflect.EnumType
type Exemplar ¶
type Exemplar struct { // The set of labels that were filtered out by the aggregator, but recorded // alongside the original measurement. Only labels that were filtered out // by the aggregator should be included FilteredLabels []*StringKeyValue `protobuf:"bytes,1,rep,name=filtered_labels,json=filteredLabels,proto3" json:"filtered_labels,omitempty"` // time_unix_nano is the exact time when this exemplar was recorded // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. TimeUnixNano uint64 `protobuf:"fixed64,2,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"` // Numerical value of the measurement that was recorded. An exemplar is // considered invalid when one of the recognized value fields is not present // inside this oneof. // // Types that are assignable to Value: // *Exemplar_AsDouble // *Exemplar_AsInt Value isExemplar_Value `protobuf_oneof:"value"` // (Optional) Span ID of the exemplar trace. // span_id may be missing if the measurement is not recorded inside a trace // or if the trace is not sampled. SpanId []byte `protobuf:"bytes,4,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"` // (Optional) Trace ID of the exemplar trace. // trace_id may be missing if the measurement is not recorded inside a trace // or if the trace is not sampled. TraceId []byte `protobuf:"bytes,5,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // contains filtered or unexported fields }
A representation of an exemplar, which is a sample input measurement. Exemplars also hold information about the environment when the measurement was recorded, for example the span and trace ID of the active span when the exemplar was recorded.
func (*Exemplar) Descriptor
deprecated
func (*Exemplar) GetAsDouble ¶
func (*Exemplar) GetFilteredLabels ¶
func (x *Exemplar) GetFilteredLabels() []*StringKeyValue
func (*Exemplar) GetTimeUnixNano ¶
func (*Exemplar) GetTraceId ¶
func (*Exemplar) ProtoMessage ¶
func (*Exemplar) ProtoMessage()
func (*Exemplar) ProtoReflect ¶
func (x *Exemplar) ProtoReflect() protoreflect.Message
type Exemplar_AsDouble ¶
type Exemplar_AsDouble struct {
AsDouble float64 `protobuf:"fixed64,3,opt,name=as_double,json=asDouble,proto3,oneof"`
}
type Exemplar_AsInt ¶
type Exemplar_AsInt struct {
AsInt int64 `protobuf:"fixed64,6,opt,name=as_int,json=asInt,proto3,oneof"`
}
type ExportLogsServiceRequest ¶
type ExportLogsServiceRequest struct { // An array of ResourceSpans. // For data coming from a single resource this array will typically contain one // element. Intermediary nodes (such as OpenTelemetry Collector) that receive // data from multiple origins typically batch the data before forwarding further and // in that case this array will contain multiple elements. ResourceLogs []*ResourceLogs `protobuf:"bytes,1,rep,name=resource_logs,json=resourceLogs,proto3" json:"resource_logs,omitempty"` // contains filtered or unexported fields }
func (*ExportLogsServiceRequest) Descriptor
deprecated
func (*ExportLogsServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExportLogsServiceRequest.ProtoReflect.Descriptor instead.
func (*ExportLogsServiceRequest) GetResourceLogs ¶
func (x *ExportLogsServiceRequest) GetResourceLogs() []*ResourceLogs
func (*ExportLogsServiceRequest) ProtoMessage ¶
func (*ExportLogsServiceRequest) ProtoMessage()
func (*ExportLogsServiceRequest) ProtoReflect ¶
func (x *ExportLogsServiceRequest) ProtoReflect() protoreflect.Message
func (*ExportLogsServiceRequest) Reset ¶
func (x *ExportLogsServiceRequest) Reset()
func (*ExportLogsServiceRequest) String ¶
func (x *ExportLogsServiceRequest) String() string
type ExportLogsServiceResponse ¶
type ExportLogsServiceResponse struct {
// contains filtered or unexported fields
}
func (*ExportLogsServiceResponse) Descriptor
deprecated
func (*ExportLogsServiceResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExportLogsServiceResponse.ProtoReflect.Descriptor instead.
func (*ExportLogsServiceResponse) ProtoMessage ¶
func (*ExportLogsServiceResponse) ProtoMessage()
func (*ExportLogsServiceResponse) ProtoReflect ¶
func (x *ExportLogsServiceResponse) ProtoReflect() protoreflect.Message
func (*ExportLogsServiceResponse) Reset ¶
func (x *ExportLogsServiceResponse) Reset()
func (*ExportLogsServiceResponse) String ¶
func (x *ExportLogsServiceResponse) String() string
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 `` /* 132-byte string literal not displayed */ // contains filtered or unexported fields }
A response to ExportRequest.
func (*ExportResponse) Descriptor
deprecated
func (*ExportResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExportResponse.ProtoReflect.Descriptor instead.
func (*ExportResponse) GetId ¶
func (x *ExportResponse) GetId() uint64
func (*ExportResponse) GetResultCode ¶
func (x *ExportResponse) GetResultCode() ExportResponse_ResultCode
func (*ExportResponse) ProtoMessage ¶
func (*ExportResponse) ProtoMessage()
func (*ExportResponse) ProtoReflect ¶
func (x *ExportResponse) ProtoReflect() protoreflect.Message
func (*ExportResponse) Reset ¶
func (x *ExportResponse) Reset()
func (*ExportResponse) String ¶
func (x *ExportResponse) String() string
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) Descriptor ¶
func (ExportResponse_ResultCode) Descriptor() protoreflect.EnumDescriptor
func (ExportResponse_ResultCode) Enum ¶
func (x ExportResponse_ResultCode) Enum() *ExportResponse_ResultCode
func (ExportResponse_ResultCode) EnumDescriptor
deprecated
func (ExportResponse_ResultCode) EnumDescriptor() ([]byte, []int)
Deprecated: Use ExportResponse_ResultCode.Descriptor instead.
func (ExportResponse_ResultCode) Number ¶
func (x ExportResponse_ResultCode) Number() protoreflect.EnumNumber
func (ExportResponse_ResultCode) String ¶
func (x ExportResponse_ResultCode) String() string
func (ExportResponse_ResultCode) Type ¶
func (ExportResponse_ResultCode) Type() protoreflect.EnumType
type Gauge ¶
type Gauge struct { DataPoints []*NumberDataPoint `protobuf:"bytes,1,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"` // contains filtered or unexported fields }
Gauge represents the type of a double scalar metric that always exports the "current value" for every data point. It should be used for an "unknown" aggregation.
A Gauge does not support different aggregation temporalities. Given the aggregation is unknown, points cannot be combined using the same aggregation, regardless of aggregation temporalities. Therefore, AggregationTemporality is not included. Consequently, this also means "StartTimeUnixNano" is ignored for all data points.
func (*Gauge) Descriptor
deprecated
func (*Gauge) GetDataPoints ¶
func (x *Gauge) GetDataPoints() []*NumberDataPoint
func (*Gauge) ProtoMessage ¶
func (*Gauge) ProtoMessage()
func (*Gauge) ProtoReflect ¶
func (x *Gauge) ProtoReflect() protoreflect.Message
type Generator ¶
type Generator struct {
// contains filtered or unexported fields
}
Generator allows to generate a ExportRequest.
func NewGenerator ¶
func NewGenerator() *Generator
func (*Generator) GenerateLogBatch ¶
func (g *Generator) GenerateLogBatch(logsPerBatch int, attrsPerLog int) core.ExportRequest
func (*Generator) GenerateMetricBatch ¶
func (*Generator) GenerateSpanBatch ¶
type Histogram ¶
type Histogram struct { DataPoints []*HistogramDataPoint `protobuf:"bytes,1,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"` // aggregation_temporality describes if the aggregator reports delta changes // since last report time, or cumulative changes since a fixed start time. AggregationTemporality AggregationTemporality `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
Histogram represents the type of a metric that is calculated by aggregating as a Histogram of all reported double measurements over a time interval.
func (*Histogram) Descriptor
deprecated
func (*Histogram) GetAggregationTemporality ¶
func (x *Histogram) GetAggregationTemporality() AggregationTemporality
func (*Histogram) GetDataPoints ¶
func (x *Histogram) GetDataPoints() []*HistogramDataPoint
func (*Histogram) ProtoMessage ¶
func (*Histogram) ProtoMessage()
func (*Histogram) ProtoReflect ¶
func (x *Histogram) ProtoReflect() protoreflect.Message
type HistogramDataPoint ¶
type HistogramDataPoint struct { // The set of labels that uniquely identify this timeseries. Labels []*StringKeyValue `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"` // start_time_unix_nano is the last time when the aggregation value was reset // to "zero". For some metric types this is ignored, see data types for more // details. // // The aggregation value is over the time interval (start_time_unix_nano, // time_unix_nano]. // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. // // Value of 0 indicates that the timestamp is unspecified. In that case the // timestamp may be decided by the backend. StartTimeUnixNano uint64 `protobuf:"fixed64,2,opt,name=start_time_unix_nano,json=startTimeUnixNano,proto3" json:"start_time_unix_nano,omitempty"` // time_unix_nano is the moment when this aggregation value was reported. // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. TimeUnixNano uint64 `protobuf:"fixed64,3,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"` // count is the number of values in the population. Must be non-negative. This // value must be equal to the sum of the "count" fields in buckets if a // histogram is provided. Count uint64 `protobuf:"fixed64,4,opt,name=count,proto3" json:"count,omitempty"` // sum of the values in the population. If count is zero then this field // must be zero. This value must be equal to the sum of the "sum" fields in // buckets if a histogram is provided. Sum float64 `protobuf:"fixed64,5,opt,name=sum,proto3" json:"sum,omitempty"` // bucket_counts is an optional field contains the count values of histogram // for each bucket. // // The sum of the bucket_counts must equal the value in the count field. // // The number of elements in bucket_counts array must be by one greater than // the number of elements in explicit_bounds array. BucketCounts []uint64 `protobuf:"fixed64,6,rep,packed,name=bucket_counts,json=bucketCounts,proto3" json:"bucket_counts,omitempty"` // explicit_bounds specifies buckets with explicitly defined bounds for values. // // This defines size(explicit_bounds) + 1 (= N) buckets. The boundaries for // bucket at index i are: // // (-infinity, explicit_bounds[i]] for i == 0 // (explicit_bounds[i-1], explicit_bounds[i]] for 0 < i < N-1 // (explicit_bounds[i], +infinity) for i == N-1 // // The values in the explicit_bounds array must be strictly increasing. // // Histogram buckets are inclusive of their upper boundary, except the last // bucket where the boundary is at infinity. This format is intentionally // compatible with the OpenMetrics histogram definition. ExplicitBounds []float64 `protobuf:"fixed64,7,rep,packed,name=explicit_bounds,json=explicitBounds,proto3" json:"explicit_bounds,omitempty"` // (Optional) List of exemplars collected from // measurements that were used to form the data point Exemplars []*Exemplar `protobuf:"bytes,8,rep,name=exemplars,proto3" json:"exemplars,omitempty"` // contains filtered or unexported fields }
HistogramDataPoint is a single data point in a timeseries that describes the time-varying values of a Histogram of double values. A Histogram contains summary statistics for a population of values, it may optionally contain the distribution of those values across a set of buckets.
func (*HistogramDataPoint) Descriptor
deprecated
func (*HistogramDataPoint) Descriptor() ([]byte, []int)
Deprecated: Use HistogramDataPoint.ProtoReflect.Descriptor instead.
func (*HistogramDataPoint) GetBucketCounts ¶
func (x *HistogramDataPoint) GetBucketCounts() []uint64
func (*HistogramDataPoint) GetCount ¶
func (x *HistogramDataPoint) GetCount() uint64
func (*HistogramDataPoint) GetExemplars ¶
func (x *HistogramDataPoint) GetExemplars() []*Exemplar
func (*HistogramDataPoint) GetExplicitBounds ¶
func (x *HistogramDataPoint) GetExplicitBounds() []float64
func (*HistogramDataPoint) GetLabels ¶
func (x *HistogramDataPoint) GetLabels() []*StringKeyValue
func (*HistogramDataPoint) GetStartTimeUnixNano ¶
func (x *HistogramDataPoint) GetStartTimeUnixNano() uint64
func (*HistogramDataPoint) GetSum ¶
func (x *HistogramDataPoint) GetSum() float64
func (*HistogramDataPoint) GetTimeUnixNano ¶
func (x *HistogramDataPoint) GetTimeUnixNano() uint64
func (*HistogramDataPoint) ProtoMessage ¶
func (*HistogramDataPoint) ProtoMessage()
func (*HistogramDataPoint) ProtoReflect ¶
func (x *HistogramDataPoint) ProtoReflect() protoreflect.Message
func (*HistogramDataPoint) Reset ¶
func (x *HistogramDataPoint) Reset()
func (*HistogramDataPoint) String ¶
func (x *HistogramDataPoint) String() string
type InstrumentationLibrary ¶
type InstrumentationLibrary struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
InstrumentationLibrary is a message representing the instrumentation library information such as the fully qualified name and version.
func (*InstrumentationLibrary) Descriptor
deprecated
func (*InstrumentationLibrary) Descriptor() ([]byte, []int)
Deprecated: Use InstrumentationLibrary.ProtoReflect.Descriptor instead.
func (*InstrumentationLibrary) GetName ¶
func (x *InstrumentationLibrary) GetName() string
func (*InstrumentationLibrary) GetVersion ¶
func (x *InstrumentationLibrary) GetVersion() string
func (*InstrumentationLibrary) ProtoMessage ¶
func (*InstrumentationLibrary) ProtoMessage()
func (*InstrumentationLibrary) ProtoReflect ¶
func (x *InstrumentationLibrary) ProtoReflect() protoreflect.Message
func (*InstrumentationLibrary) Reset ¶
func (x *InstrumentationLibrary) Reset()
func (*InstrumentationLibrary) String ¶
func (x *InstrumentationLibrary) String() string
type InstrumentationLibraryLogs ¶
type InstrumentationLibraryLogs struct { // The instrumentation library information for the logs in this message. // If this field is not set then no library info is known. InstrumentationLibrary *InstrumentationLibrary `` /* 127-byte string literal not displayed */ // A list of log records. Logs []*LogRecord `protobuf:"bytes,2,rep,name=logs,proto3" json:"logs,omitempty"` // contains filtered or unexported fields }
A collection of Logs produced by an InstrumentationLibrary.
func (*InstrumentationLibraryLogs) Descriptor
deprecated
func (*InstrumentationLibraryLogs) Descriptor() ([]byte, []int)
Deprecated: Use InstrumentationLibraryLogs.ProtoReflect.Descriptor instead.
func (*InstrumentationLibraryLogs) GetInstrumentationLibrary ¶
func (x *InstrumentationLibraryLogs) GetInstrumentationLibrary() *InstrumentationLibrary
func (*InstrumentationLibraryLogs) GetLogs ¶
func (x *InstrumentationLibraryLogs) GetLogs() []*LogRecord
func (*InstrumentationLibraryLogs) ProtoMessage ¶
func (*InstrumentationLibraryLogs) ProtoMessage()
func (*InstrumentationLibraryLogs) ProtoReflect ¶
func (x *InstrumentationLibraryLogs) ProtoReflect() protoreflect.Message
func (*InstrumentationLibraryLogs) Reset ¶
func (x *InstrumentationLibraryLogs) Reset()
func (*InstrumentationLibraryLogs) String ¶
func (x *InstrumentationLibraryLogs) String() string
type InstrumentationLibraryMetrics ¶
type InstrumentationLibraryMetrics struct { // The instrumentation library information for the metrics in this message. // Semantically when InstrumentationLibrary isn't set, it is equivalent with // an empty instrumentation library name (unknown). InstrumentationLibrary *InstrumentationLibrary `` /* 127-byte string literal not displayed */ // A list of metrics that originate from an instrumentation library. Metrics []*Metric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"` // contains filtered or unexported fields }
A collection of Metrics produced by an InstrumentationLibrary.
func (*InstrumentationLibraryMetrics) Descriptor
deprecated
func (*InstrumentationLibraryMetrics) Descriptor() ([]byte, []int)
Deprecated: Use InstrumentationLibraryMetrics.ProtoReflect.Descriptor instead.
func (*InstrumentationLibraryMetrics) GetInstrumentationLibrary ¶
func (x *InstrumentationLibraryMetrics) GetInstrumentationLibrary() *InstrumentationLibrary
func (*InstrumentationLibraryMetrics) GetMetrics ¶
func (x *InstrumentationLibraryMetrics) GetMetrics() []*Metric
func (*InstrumentationLibraryMetrics) ProtoMessage ¶
func (*InstrumentationLibraryMetrics) ProtoMessage()
func (*InstrumentationLibraryMetrics) ProtoReflect ¶
func (x *InstrumentationLibraryMetrics) ProtoReflect() protoreflect.Message
func (*InstrumentationLibraryMetrics) Reset ¶
func (x *InstrumentationLibraryMetrics) Reset()
func (*InstrumentationLibraryMetrics) String ¶
func (x *InstrumentationLibraryMetrics) String() string
type InstrumentationLibrarySpans ¶
type InstrumentationLibrarySpans struct { // The instrumentation library information for the spans in this message. // If this field is not set then no library info is known. InstrumentationLibrary *InstrumentationLibrary `` /* 127-byte string literal not displayed */ // A list of Spans that originate from an instrumentation library. Spans []*Span `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"` // contains filtered or unexported fields }
A collection of Spans produced by an InstrumentationLibrary.
func (*InstrumentationLibrarySpans) Descriptor
deprecated
func (*InstrumentationLibrarySpans) Descriptor() ([]byte, []int)
Deprecated: Use InstrumentationLibrarySpans.ProtoReflect.Descriptor instead.
func (*InstrumentationLibrarySpans) GetInstrumentationLibrary ¶
func (x *InstrumentationLibrarySpans) GetInstrumentationLibrary() *InstrumentationLibrary
func (*InstrumentationLibrarySpans) GetSpans ¶
func (x *InstrumentationLibrarySpans) GetSpans() []*Span
func (*InstrumentationLibrarySpans) ProtoMessage ¶
func (*InstrumentationLibrarySpans) ProtoMessage()
func (*InstrumentationLibrarySpans) ProtoReflect ¶
func (x *InstrumentationLibrarySpans) ProtoReflect() protoreflect.Message
func (*InstrumentationLibrarySpans) Reset ¶
func (x *InstrumentationLibrarySpans) Reset()
func (*InstrumentationLibrarySpans) String ¶
func (x *InstrumentationLibrarySpans) String() string
type IntDataPoint
deprecated
type IntDataPoint struct { // The set of labels that uniquely identify this timeseries. Labels []*StringKeyValue `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"` // start_time_unix_nano is the last time when the aggregation value was reset // to "zero". For some metric types this is ignored, see data types for more // details. // // The aggregation value is over the time interval (start_time_unix_nano, // time_unix_nano]. // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. // // Value of 0 indicates that the timestamp is unspecified. In that case the // timestamp may be decided by the backend. StartTimeUnixNano uint64 `protobuf:"fixed64,2,opt,name=start_time_unix_nano,json=startTimeUnixNano,proto3" json:"start_time_unix_nano,omitempty"` // time_unix_nano is the moment when this aggregation value was reported. // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. TimeUnixNano uint64 `protobuf:"fixed64,3,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"` // value itself. Value int64 `protobuf:"fixed64,4,opt,name=value,proto3" json:"value,omitempty"` // (Optional) List of exemplars collected from // measurements that were used to form the data point Exemplars []*IntExemplar `protobuf:"bytes,5,rep,name=exemplars,proto3" json:"exemplars,omitempty"` // contains filtered or unexported fields }
IntDataPoint is a single data point in a timeseries that describes the time-varying values of a int64 metric.
Deprecated: Do not use.
func (*IntDataPoint) Descriptor
deprecated
func (*IntDataPoint) Descriptor() ([]byte, []int)
Deprecated: Use IntDataPoint.ProtoReflect.Descriptor instead.
func (*IntDataPoint) GetExemplars ¶
func (x *IntDataPoint) GetExemplars() []*IntExemplar
func (*IntDataPoint) GetLabels ¶
func (x *IntDataPoint) GetLabels() []*StringKeyValue
func (*IntDataPoint) GetStartTimeUnixNano ¶
func (x *IntDataPoint) GetStartTimeUnixNano() uint64
func (*IntDataPoint) GetTimeUnixNano ¶
func (x *IntDataPoint) GetTimeUnixNano() uint64
func (*IntDataPoint) GetValue ¶
func (x *IntDataPoint) GetValue() int64
func (*IntDataPoint) ProtoMessage ¶
func (*IntDataPoint) ProtoMessage()
func (*IntDataPoint) ProtoReflect ¶
func (x *IntDataPoint) ProtoReflect() protoreflect.Message
func (*IntDataPoint) Reset ¶
func (x *IntDataPoint) Reset()
func (*IntDataPoint) String ¶
func (x *IntDataPoint) String() string
type IntExemplar
deprecated
type IntExemplar struct { // The set of labels that were filtered out by the aggregator, but recorded // alongside the original measurement. Only labels that were filtered out // by the aggregator should be included FilteredLabels []*StringKeyValue `protobuf:"bytes,1,rep,name=filtered_labels,json=filteredLabels,proto3" json:"filtered_labels,omitempty"` // time_unix_nano is the exact time when this exemplar was recorded // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. TimeUnixNano uint64 `protobuf:"fixed64,2,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"` // Numerical int value of the measurement that was recorded. Value int64 `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"` // (Optional) Span ID of the exemplar trace. // span_id may be missing if the measurement is not recorded inside a trace // or if the trace is not sampled. SpanId []byte `protobuf:"bytes,4,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"` // (Optional) Trace ID of the exemplar trace. // trace_id may be missing if the measurement is not recorded inside a trace // or if the trace is not sampled. TraceId []byte `protobuf:"bytes,5,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // contains filtered or unexported fields }
A representation of an exemplar, which is a sample input int measurement. Exemplars also hold information about the environment when the measurement was recorded, for example the span and trace ID of the active span when the exemplar was recorded.
Deprecated: Do not use.
func (*IntExemplar) Descriptor
deprecated
func (*IntExemplar) Descriptor() ([]byte, []int)
Deprecated: Use IntExemplar.ProtoReflect.Descriptor instead.
func (*IntExemplar) GetFilteredLabels ¶
func (x *IntExemplar) GetFilteredLabels() []*StringKeyValue
func (*IntExemplar) GetSpanId ¶
func (x *IntExemplar) GetSpanId() []byte
func (*IntExemplar) GetTimeUnixNano ¶
func (x *IntExemplar) GetTimeUnixNano() uint64
func (*IntExemplar) GetTraceId ¶
func (x *IntExemplar) GetTraceId() []byte
func (*IntExemplar) GetValue ¶
func (x *IntExemplar) GetValue() int64
func (*IntExemplar) ProtoMessage ¶
func (*IntExemplar) ProtoMessage()
func (*IntExemplar) ProtoReflect ¶
func (x *IntExemplar) ProtoReflect() protoreflect.Message
func (*IntExemplar) Reset ¶
func (x *IntExemplar) Reset()
func (*IntExemplar) String ¶
func (x *IntExemplar) String() string
type IntGauge
deprecated
type IntGauge struct { DataPoints []*IntDataPoint `protobuf:"bytes,1,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"` // contains filtered or unexported fields }
IntGauge is deprecated. Use Gauge with an integer value in NumberDataPoint.
IntGauge represents the type of a int scalar metric that always exports the "current value" for every data point. It should be used for an "unknown" aggregation.
A Gauge does not support different aggregation temporalities. Given the aggregation is unknown, points cannot be combined using the same aggregation, regardless of aggregation temporalities. Therefore, AggregationTemporality is not included. Consequently, this also means "StartTimeUnixNano" is ignored for all data points.
Deprecated: Do not use.
func (*IntGauge) Descriptor
deprecated
func (*IntGauge) GetDataPoints ¶
func (x *IntGauge) GetDataPoints() []*IntDataPoint
func (*IntGauge) ProtoMessage ¶
func (*IntGauge) ProtoMessage()
func (*IntGauge) ProtoReflect ¶
func (x *IntGauge) ProtoReflect() protoreflect.Message
type IntHistogram
deprecated
type IntHistogram struct { DataPoints []*IntHistogramDataPoint `protobuf:"bytes,1,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"` // aggregation_temporality describes if the aggregator reports delta changes // since last report time, or cumulative changes since a fixed start time. AggregationTemporality AggregationTemporality `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
IntHistogram is deprecated, replaced by Histogram points using double- valued exemplars.
This represents the type of a metric that is calculated by aggregating as a Histogram of all reported int measurements over a time interval.
Deprecated: Do not use.
func (*IntHistogram) Descriptor
deprecated
func (*IntHistogram) Descriptor() ([]byte, []int)
Deprecated: Use IntHistogram.ProtoReflect.Descriptor instead.
func (*IntHistogram) GetAggregationTemporality ¶
func (x *IntHistogram) GetAggregationTemporality() AggregationTemporality
func (*IntHistogram) GetDataPoints ¶
func (x *IntHistogram) GetDataPoints() []*IntHistogramDataPoint
func (*IntHistogram) ProtoMessage ¶
func (*IntHistogram) ProtoMessage()
func (*IntHistogram) ProtoReflect ¶
func (x *IntHistogram) ProtoReflect() protoreflect.Message
func (*IntHistogram) Reset ¶
func (x *IntHistogram) Reset()
func (*IntHistogram) String ¶
func (x *IntHistogram) String() string
type IntHistogramDataPoint
deprecated
type IntHistogramDataPoint struct { // The set of labels that uniquely identify this timeseries. Labels []*StringKeyValue `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"` // start_time_unix_nano is the last time when the aggregation value was reset // to "zero". For some metric types this is ignored, see data types for more // details. // // The aggregation value is over the time interval (start_time_unix_nano, // time_unix_nano]. // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. // // Value of 0 indicates that the timestamp is unspecified. In that case the // timestamp may be decided by the backend. StartTimeUnixNano uint64 `protobuf:"fixed64,2,opt,name=start_time_unix_nano,json=startTimeUnixNano,proto3" json:"start_time_unix_nano,omitempty"` // time_unix_nano is the moment when this aggregation value was reported. // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. TimeUnixNano uint64 `protobuf:"fixed64,3,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"` // count is the number of values in the population. Must be non-negative. This // value must be equal to the sum of the "count" fields in buckets if a // histogram is provided. Count uint64 `protobuf:"fixed64,4,opt,name=count,proto3" json:"count,omitempty"` // sum of the values in the population. If count is zero then this field // must be zero. This value must be equal to the sum of the "sum" fields in // buckets if a histogram is provided. Sum int64 `protobuf:"fixed64,5,opt,name=sum,proto3" json:"sum,omitempty"` // bucket_counts is an optional field contains the count values of histogram // for each bucket. // // The sum of the bucket_counts must equal the value in the count field. // // The number of elements in bucket_counts array must be by one greater than // the number of elements in explicit_bounds array. BucketCounts []uint64 `protobuf:"fixed64,6,rep,packed,name=bucket_counts,json=bucketCounts,proto3" json:"bucket_counts,omitempty"` // explicit_bounds specifies buckets with explicitly defined bounds for values. // // This defines size(explicit_bounds) + 1 (= N) buckets. The boundaries for // bucket at index i are: // // (-infinity, explicit_bounds[i]] for i == 0 // (explicit_bounds[i-1], explicit_bounds[i]] for 0 < i < N-1 // (explicit_bounds[i], +infinity) for i == N-1 // // The values in the explicit_bounds array must be strictly increasing. // // Histogram buckets are inclusive of their upper boundary, except the last // bucket where the boundary is at infinity. This format is intentionally // compatible with the OpenMetrics histogram definition. ExplicitBounds []float64 `protobuf:"fixed64,7,rep,packed,name=explicit_bounds,json=explicitBounds,proto3" json:"explicit_bounds,omitempty"` // (Optional) List of exemplars collected from // measurements that were used to form the data point Exemplars []*IntExemplar `protobuf:"bytes,8,rep,name=exemplars,proto3" json:"exemplars,omitempty"` // contains filtered or unexported fields }
IntHistogramDataPoint is deprecated; use HistogramDataPoint.
This is a single data point in a timeseries that describes the time-varying values of a Histogram of int values. A Histogram contains summary statistics for a population of values, it may optionally contain the distribution of those values across a set of buckets.
Deprecated: Do not use.
func (*IntHistogramDataPoint) Descriptor
deprecated
func (*IntHistogramDataPoint) Descriptor() ([]byte, []int)
Deprecated: Use IntHistogramDataPoint.ProtoReflect.Descriptor instead.
func (*IntHistogramDataPoint) GetBucketCounts ¶
func (x *IntHistogramDataPoint) GetBucketCounts() []uint64
func (*IntHistogramDataPoint) GetCount ¶
func (x *IntHistogramDataPoint) GetCount() uint64
func (*IntHistogramDataPoint) GetExemplars ¶
func (x *IntHistogramDataPoint) GetExemplars() []*IntExemplar
func (*IntHistogramDataPoint) GetExplicitBounds ¶
func (x *IntHistogramDataPoint) GetExplicitBounds() []float64
func (*IntHistogramDataPoint) GetLabels ¶
func (x *IntHistogramDataPoint) GetLabels() []*StringKeyValue
func (*IntHistogramDataPoint) GetStartTimeUnixNano ¶
func (x *IntHistogramDataPoint) GetStartTimeUnixNano() uint64
func (*IntHistogramDataPoint) GetSum ¶
func (x *IntHistogramDataPoint) GetSum() int64
func (*IntHistogramDataPoint) GetTimeUnixNano ¶
func (x *IntHistogramDataPoint) GetTimeUnixNano() uint64
func (*IntHistogramDataPoint) ProtoMessage ¶
func (*IntHistogramDataPoint) ProtoMessage()
func (*IntHistogramDataPoint) ProtoReflect ¶
func (x *IntHistogramDataPoint) ProtoReflect() protoreflect.Message
func (*IntHistogramDataPoint) Reset ¶
func (x *IntHistogramDataPoint) Reset()
func (*IntHistogramDataPoint) String ¶
func (x *IntHistogramDataPoint) String() string
type IntSum
deprecated
type IntSum struct { DataPoints []*IntDataPoint `protobuf:"bytes,1,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"` // aggregation_temporality describes if the aggregator reports delta changes // since last report time, or cumulative changes since a fixed start time. AggregationTemporality AggregationTemporality `` /* 165-byte string literal not displayed */ // If "true" means that the sum is monotonic. IsMonotonic bool `protobuf:"varint,3,opt,name=is_monotonic,json=isMonotonic,proto3" json:"is_monotonic,omitempty"` // contains filtered or unexported fields }
IntSum is deprecated. Use Sum with an integer value in NumberDataPoint.
IntSum represents the type of a numeric int scalar metric that is calculated as a sum of all reported measurements over a time interval.
Deprecated: Do not use.
func (*IntSum) Descriptor
deprecated
func (*IntSum) GetAggregationTemporality ¶
func (x *IntSum) GetAggregationTemporality() AggregationTemporality
func (*IntSum) GetDataPoints ¶
func (x *IntSum) GetDataPoints() []*IntDataPoint
func (*IntSum) GetIsMonotonic ¶
func (*IntSum) ProtoMessage ¶
func (*IntSum) ProtoMessage()
func (*IntSum) ProtoReflect ¶
func (x *IntSum) ProtoReflect() protoreflect.Message
type KeyValue ¶
type KeyValue struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value *AnyValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
KeyValue is a key-value pair that is used to store Span attributes, Link attributes, etc.
func (*KeyValue) Descriptor
deprecated
func (*KeyValue) ProtoMessage ¶
func (*KeyValue) ProtoMessage()
func (*KeyValue) ProtoReflect ¶
func (x *KeyValue) ProtoReflect() protoreflect.Message
type KeyValueList ¶
type KeyValueList struct { // A collection of key/value pairs of key-value pairs. The list may be empty (may // contain 0 elements). Values []*KeyValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
KeyValueList is a list of KeyValue messages. We need KeyValueList as a message since `oneof` in AnyValue does not allow repeated fields. Everywhere else where we need a list of KeyValue messages (e.g. in Span) we use `repeated KeyValue` directly to avoid unnecessary extra wrapping (which slows down the protocol). The 2 approaches are semantically equivalent.
func (*KeyValueList) Descriptor
deprecated
func (*KeyValueList) Descriptor() ([]byte, []int)
Deprecated: Use KeyValueList.ProtoReflect.Descriptor instead.
func (*KeyValueList) GetValues ¶
func (x *KeyValueList) GetValues() []*KeyValue
func (*KeyValueList) ProtoMessage ¶
func (*KeyValueList) ProtoMessage()
func (*KeyValueList) ProtoReflect ¶
func (x *KeyValueList) ProtoReflect() protoreflect.Message
func (*KeyValueList) Reset ¶
func (x *KeyValueList) Reset()
func (*KeyValueList) String ¶
func (x *KeyValueList) String() string
type LogRecord ¶
type LogRecord struct { // time_unix_nano is the time when the event occurred. // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January 1970. // Value of 0 indicates unknown or missing timestamp. TimeUnixNano uint64 `protobuf:"fixed64,1,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"` // Numerical value of the severity, normalized to values described in Log Data Model. // [Optional]. SeverityNumber SeverityNumber `` /* 133-byte string literal not displayed */ // The severity text (also known as log level). The original string representation as // it is known at the source. [Optional]. SeverityText string `protobuf:"bytes,3,opt,name=severity_text,json=severityText,proto3" json:"severity_text,omitempty"` // Short event identifier that does not contain varying parts. Name describes // what happened (e.g. "ProcessStarted"). Recommended to be no longer than 50 // characters. Not guaranteed to be unique in any way. [Optional]. Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` // A value containing the body of the log record. Can be for example a human-readable // string message (including multi-line) describing the event in a free form or it can // be a structured data composed of arrays and maps of other values. [Optional]. Body *AnyValue `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"` // Additional attributes that describe the specific event occurrence. [Optional]. Attributes []*KeyValue `protobuf:"bytes,6,rep,name=attributes,proto3" json:"attributes,omitempty"` DroppedAttributesCount uint32 `` /* 130-byte string literal not displayed */ // Flags, a bit field. 8 least significant bits are the trace flags as // defined in W3C Trace Context specification. 24 most significant bits are reserved // and must be set to 0. Readers must not assume that 24 most significant bits // will be zero and must correctly mask the bits when reading 8-bit trace flag (use // flags & TRACE_FLAGS_MASK). [Optional]. Flags uint32 `protobuf:"fixed32,8,opt,name=flags,proto3" json:"flags,omitempty"` // A unique identifier for a trace. All logs from the same trace share // the same `trace_id`. The ID is a 16-byte array. An ID with all zeroes // is considered invalid. Can be set for logs that are part of request processing // and have an assigned trace id. [Optional]. TraceId []byte `protobuf:"bytes,9,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. Can be set for logs that are part of a particular processing span. // If span_id is present trace_id SHOULD be also present. [Optional]. SpanId []byte `protobuf:"bytes,10,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"` // contains filtered or unexported fields }
A log record according to OpenTelemetry Log Data Model: https://github.com/open-telemetry/oteps/blob/master/text/logs/0097-log-data-model.md
func (*LogRecord) Descriptor
deprecated
func (*LogRecord) GetAttributes ¶
func (*LogRecord) GetDroppedAttributesCount ¶
func (*LogRecord) GetSeverityNumber ¶
func (x *LogRecord) GetSeverityNumber() SeverityNumber
func (*LogRecord) GetSeverityText ¶
func (*LogRecord) GetTimeUnixNano ¶
func (*LogRecord) GetTraceId ¶
func (*LogRecord) ProtoMessage ¶
func (*LogRecord) ProtoMessage()
func (*LogRecord) ProtoReflect ¶
func (x *LogRecord) ProtoReflect() protoreflect.Message
type LogRecordFlags ¶
type LogRecordFlags int32
Masks for LogRecord.flags field.
const ( LogRecordFlags_LOG_RECORD_FLAG_UNSPECIFIED LogRecordFlags = 0 LogRecordFlags_LOG_RECORD_FLAG_TRACE_FLAGS_MASK LogRecordFlags = 255 )
func (LogRecordFlags) Descriptor ¶
func (LogRecordFlags) Descriptor() protoreflect.EnumDescriptor
func (LogRecordFlags) Enum ¶
func (x LogRecordFlags) Enum() *LogRecordFlags
func (LogRecordFlags) EnumDescriptor
deprecated
func (LogRecordFlags) EnumDescriptor() ([]byte, []int)
Deprecated: Use LogRecordFlags.Descriptor instead.
func (LogRecordFlags) Number ¶
func (x LogRecordFlags) Number() protoreflect.EnumNumber
func (LogRecordFlags) String ¶
func (x LogRecordFlags) String() string
func (LogRecordFlags) Type ¶
func (LogRecordFlags) Type() protoreflect.EnumType
type Metric ¶
type Metric struct { // name of the metric, including its DNS name prefix. It must be unique. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // description of the metric, which can be used in documentation. Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` // unit in which the metric value is reported. Follows the format // described by http://unitsofmeasure.org/ucum.html. Unit string `protobuf:"bytes,3,opt,name=unit,proto3" json:"unit,omitempty"` // Data determines the aggregation type (if any) of the metric, what is the // reported value type for the data points, as well as the relatationship to // the time interval over which they are reported. // // Types that are assignable to Data: // *Metric_IntGauge // *Metric_Gauge // *Metric_IntSum // *Metric_Sum // *Metric_IntHistogram // *Metric_Histogram // *Metric_Summary Data isMetric_Data `protobuf_oneof:"data"` // contains filtered or unexported fields }
Defines a Metric which has one or more timeseries.
The data model and relation between entities is shown in the diagram below. Here, "DataPoint" is the term used to refer to any one of the specific data point value types, and "points" is the term used to refer to any one of the lists of points contained in the Metric.
Metric is composed of a metadata and data.
Metadata part contains a name, description, unit.
Data is one of the possible types (Gauge, Sum, Histogram, etc.).
DataPoint contains timestamps, labels, and one of the possible value type fields.
Metric +------------+ |name | |description | |unit | +------------------------------------+ |data |---> |Gauge, Sum, Histogram, Summary, ... | +------------+ +------------------------------------+
Data [One of Gauge, Sum, Histogram, Summary, ...] +-----------+ |... | // Metadata about the Data. |points |--+ +-----------+ | | +---------------------------+ | |DataPoint 1 | v |+------+------+ +------+ | +-----+ ||label |label |...|label | | | 1 |-->||value1|value2|...|valueN| | +-----+ |+------+------+ +------+ | | . | |+-----+ | | . | ||value| | | . | |+-----+ | | . | +---------------------------+ | . | . | . | . | . | . | . | +---------------------------+ | . | |DataPoint M | +-----+ |+------+------+ +------+ | | M |-->||label |label |...|label | | +-----+ ||value1|value2|...|valueN| | |+------+------+ +------+ | |+-----+ | ||value| | |+-----+ | +---------------------------+
All DataPoint types have three common fields:
- Labels zero or more key-value pairs associated with the data point.
- StartTimeUnixNano MUST be set to the start of the interval when the data's type includes an AggregationTemporality. This field is not set otherwise.
- TimeUnixNano MUST be set to:
- the moment when an aggregation is reported (independent of the aggregation temporality).
- the instantaneous time of the event.
func GenMetricDescriptor ¶
func (*Metric) Descriptor
deprecated
func (*Metric) GetDescription ¶
func (*Metric) GetHistogram ¶
func (*Metric) GetIntGauge
deprecated
func (*Metric) GetIntHistogram
deprecated
func (x *Metric) GetIntHistogram() *IntHistogram
Deprecated: Do not use.
func (*Metric) GetSummary ¶
func (*Metric) ProtoMessage ¶
func (*Metric) ProtoMessage()
func (*Metric) ProtoReflect ¶
func (x *Metric) ProtoReflect() protoreflect.Message
type MetricExportRequest ¶
type MetricExportRequest struct { // Unique sequential ID generated by the client. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // Telemetry data. An array of ResourceMetrics. ResourceMetrics []*ResourceMetrics `protobuf:"bytes,2,rep,name=resourceMetrics,proto3" json:"resourceMetrics,omitempty"` // contains filtered or unexported fields }
A request from client to server containing metric data to export.
func (*MetricExportRequest) Descriptor
deprecated
func (*MetricExportRequest) Descriptor() ([]byte, []int)
Deprecated: Use MetricExportRequest.ProtoReflect.Descriptor instead.
func (*MetricExportRequest) GetId ¶
func (x *MetricExportRequest) GetId() uint64
func (*MetricExportRequest) GetResourceMetrics ¶
func (x *MetricExportRequest) GetResourceMetrics() []*ResourceMetrics
func (*MetricExportRequest) ProtoMessage ¶
func (*MetricExportRequest) ProtoMessage()
func (*MetricExportRequest) ProtoReflect ¶
func (x *MetricExportRequest) ProtoReflect() protoreflect.Message
func (*MetricExportRequest) Reset ¶
func (x *MetricExportRequest) Reset()
func (*MetricExportRequest) String ¶
func (x *MetricExportRequest) String() string
type Metric_Gauge ¶
type Metric_Gauge struct {
Gauge *Gauge `protobuf:"bytes,5,opt,name=gauge,proto3,oneof"`
}
type Metric_Histogram ¶
type Metric_Histogram struct {
Histogram *Histogram `protobuf:"bytes,9,opt,name=histogram,proto3,oneof"`
}
type Metric_IntGauge ¶
type Metric_IntGauge struct { // IntGauge and IntSum are deprecated and will be removed soon. // 1. Old senders and receivers that are not aware of this change will // continue using the `int_gauge` and `int_sum` fields. // 2. New senders, which are aware of this change MUST send only `gauge` // and `sum` fields. // 3. New receivers, which are aware of this change MUST convert these into // `gauge` and `sum` by using the provided as_int field in the oneof values. // This field will be removed in ~3 months, on July 1, 2021. // // Deprecated: Do not use. IntGauge *IntGauge `protobuf:"bytes,4,opt,name=int_gauge,json=intGauge,proto3,oneof"` }
func GenInt64Timeseries ¶
func GenInt64Timeseries(startTime time.Time, offset int, valuesPerTimeseries int) *Metric_IntGauge
type Metric_IntHistogram ¶
type Metric_IntHistogram struct { // IntHistogram is deprecated and will be removed soon. // 1. Old senders and receivers that are not aware of this change will // continue using the `int_histogram` field. // 2. New senders, which are aware of this change MUST send only `histogram`. // 3. New receivers, which are aware of this change MUST convert this into // `histogram` by simply converting all int64 values into float. // This field will be removed in ~3 months, on July 1, 2021. // // Deprecated: Do not use. IntHistogram *IntHistogram `protobuf:"bytes,8,opt,name=int_histogram,json=intHistogram,proto3,oneof"` }
type Metric_IntSum ¶
type Metric_IntSum struct { // This field will be removed in ~3 months, on July 1, 2021. // // Deprecated: Do not use. IntSum *IntSum `protobuf:"bytes,6,opt,name=int_sum,json=intSum,proto3,oneof"` }
type Metric_Sum ¶
type Metric_Sum struct {
Sum *Sum `protobuf:"bytes,7,opt,name=sum,proto3,oneof"`
}
type Metric_Summary ¶
type Metric_Summary struct {
Summary *Summary `protobuf:"bytes,11,opt,name=summary,proto3,oneof"`
}
type NumberDataPoint ¶
type NumberDataPoint struct { // The set of labels that uniquely identify this timeseries. Labels []*StringKeyValue `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"` // start_time_unix_nano is the last time when the aggregation value was reset // to "zero". For some metric types this is ignored, see data types for more // details. // // The aggregation value is over the time interval (start_time_unix_nano, // time_unix_nano]. // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. // // Value of 0 indicates that the timestamp is unspecified. In that case the // timestamp may be decided by the backend. StartTimeUnixNano uint64 `protobuf:"fixed64,2,opt,name=start_time_unix_nano,json=startTimeUnixNano,proto3" json:"start_time_unix_nano,omitempty"` // time_unix_nano is the moment when this aggregation value was reported. // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. TimeUnixNano uint64 `protobuf:"fixed64,3,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"` // The value itself. A point is considered invalid when one of the recognized // value fields is not present inside this oneof. // // Types that are assignable to Value: // *NumberDataPoint_AsDouble // *NumberDataPoint_AsInt Value isNumberDataPoint_Value `protobuf_oneof:"value"` // (Optional) List of exemplars collected from // measurements that were used to form the data point Exemplars []*Exemplar `protobuf:"bytes,5,rep,name=exemplars,proto3" json:"exemplars,omitempty"` // contains filtered or unexported fields }
NumberDataPoint is a single data point in a timeseries that describes the time-varying value of a double metric.
func (*NumberDataPoint) Descriptor
deprecated
func (*NumberDataPoint) Descriptor() ([]byte, []int)
Deprecated: Use NumberDataPoint.ProtoReflect.Descriptor instead.
func (*NumberDataPoint) GetAsDouble ¶
func (x *NumberDataPoint) GetAsDouble() float64
func (*NumberDataPoint) GetAsInt ¶
func (x *NumberDataPoint) GetAsInt() int64
func (*NumberDataPoint) GetExemplars ¶
func (x *NumberDataPoint) GetExemplars() []*Exemplar
func (*NumberDataPoint) GetLabels ¶
func (x *NumberDataPoint) GetLabels() []*StringKeyValue
func (*NumberDataPoint) GetStartTimeUnixNano ¶
func (x *NumberDataPoint) GetStartTimeUnixNano() uint64
func (*NumberDataPoint) GetTimeUnixNano ¶
func (x *NumberDataPoint) GetTimeUnixNano() uint64
func (*NumberDataPoint) GetValue ¶
func (m *NumberDataPoint) GetValue() isNumberDataPoint_Value
func (*NumberDataPoint) ProtoMessage ¶
func (*NumberDataPoint) ProtoMessage()
func (*NumberDataPoint) ProtoReflect ¶
func (x *NumberDataPoint) ProtoReflect() protoreflect.Message
func (*NumberDataPoint) Reset ¶
func (x *NumberDataPoint) Reset()
func (*NumberDataPoint) String ¶
func (x *NumberDataPoint) String() string
type NumberDataPoint_AsDouble ¶
type NumberDataPoint_AsDouble struct {
AsDouble float64 `protobuf:"fixed64,4,opt,name=as_double,json=asDouble,proto3,oneof"`
}
type NumberDataPoint_AsInt ¶
type NumberDataPoint_AsInt struct {
AsInt int64 `protobuf:"fixed64,6,opt,name=as_int,json=asInt,proto3,oneof"`
}
type RequestBody ¶
type RequestBody struct { RequestType RequestType `protobuf:"varint,1,opt,name=request_type,json=requestType,proto3,enum=baseline.RequestType" json:"request_type,omitempty"` Export *TraceExportRequest `protobuf:"bytes,2,opt,name=export,proto3" json:"export,omitempty"` // contains filtered or unexported fields }
RequestBody is used by transports that unlike gRPC don't have built-in message type multiplexing such as WebSocket.
func (*RequestBody) Descriptor
deprecated
func (*RequestBody) Descriptor() ([]byte, []int)
Deprecated: Use RequestBody.ProtoReflect.Descriptor instead.
func (*RequestBody) GetExport ¶
func (x *RequestBody) GetExport() *TraceExportRequest
func (*RequestBody) GetRequestType ¶
func (x *RequestBody) GetRequestType() RequestType
func (*RequestBody) ProtoMessage ¶
func (*RequestBody) ProtoMessage()
func (*RequestBody) ProtoReflect ¶
func (x *RequestBody) ProtoReflect() protoreflect.Message
func (*RequestBody) Reset ¶
func (x *RequestBody) Reset()
func (*RequestBody) String ¶
func (x *RequestBody) String() string
type RequestHeader ¶
type RequestHeader struct { // Compression method used for body. Compression CompressionMethod `protobuf:"varint,1,opt,name=compression,proto3,enum=baseline.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"` // contains filtered or unexported fields }
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
deprecated
func (*RequestHeader) Descriptor() ([]byte, []int)
Deprecated: Use RequestHeader.ProtoReflect.Descriptor instead.
func (*RequestHeader) GetCompression ¶
func (x *RequestHeader) GetCompression() CompressionMethod
func (*RequestHeader) GetCompressionLevel ¶
func (x *RequestHeader) GetCompressionLevel() int32
func (*RequestHeader) ProtoMessage ¶
func (*RequestHeader) ProtoMessage()
func (*RequestHeader) ProtoReflect ¶
func (x *RequestHeader) ProtoReflect() protoreflect.Message
func (*RequestHeader) Reset ¶
func (x *RequestHeader) Reset()
func (*RequestHeader) String ¶
func (x *RequestHeader) String() string
type RequestType ¶
type RequestType int32
const ( RequestType__ RequestType = 0 RequestType_TraceExport RequestType = 1 )
func (RequestType) Descriptor ¶
func (RequestType) Descriptor() protoreflect.EnumDescriptor
func (RequestType) Enum ¶
func (x RequestType) Enum() *RequestType
func (RequestType) EnumDescriptor
deprecated
func (RequestType) EnumDescriptor() ([]byte, []int)
Deprecated: Use RequestType.Descriptor instead.
func (RequestType) Number ¶
func (x RequestType) Number() protoreflect.EnumNumber
func (RequestType) String ¶
func (x RequestType) String() string
func (RequestType) Type ¶
func (RequestType) Type() protoreflect.EnumType
type Resource ¶
type Resource struct { // Set of labels that describe the resource. Attributes []*KeyValue `protobuf:"bytes,1,rep,name=attributes,proto3" json:"attributes,omitempty"` // dropped_attributes_count is the number of dropped attributes. If the value is 0, then // no attributes were dropped. DroppedAttributesCount uint32 `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
Resource information.
func GenResource ¶
func GenResource() *Resource
func (*Resource) Descriptor
deprecated
func (*Resource) GetAttributes ¶
func (*Resource) GetDroppedAttributesCount ¶
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) ProtoReflect ¶
func (x *Resource) ProtoReflect() protoreflect.Message
type ResourceLogs ¶
type ResourceLogs struct { // The resource for the logs in this message. // If this field is not set then no resource info is known. Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` // A list of InstrumentationLibraryLogs that originate from a resource. InstrumentationLibraryLogs []*InstrumentationLibraryLogs `` /* 141-byte string literal not displayed */ // contains filtered or unexported fields }
A collection of InstrumentationLibraryLogs from a Resource.
func (*ResourceLogs) Descriptor
deprecated
func (*ResourceLogs) Descriptor() ([]byte, []int)
Deprecated: Use ResourceLogs.ProtoReflect.Descriptor instead.
func (*ResourceLogs) GetInstrumentationLibraryLogs ¶
func (x *ResourceLogs) GetInstrumentationLibraryLogs() []*InstrumentationLibraryLogs
func (*ResourceLogs) GetResource ¶
func (x *ResourceLogs) GetResource() *Resource
func (*ResourceLogs) ProtoMessage ¶
func (*ResourceLogs) ProtoMessage()
func (*ResourceLogs) ProtoReflect ¶
func (x *ResourceLogs) ProtoReflect() protoreflect.Message
func (*ResourceLogs) Reset ¶
func (x *ResourceLogs) Reset()
func (*ResourceLogs) String ¶
func (x *ResourceLogs) String() string
type ResourceMetrics ¶
type ResourceMetrics struct { // The resource for the metrics in this message. // If this field is not set then no resource info is known. Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` // A list of metrics that originate from a resource. InstrumentationLibraryMetrics []*InstrumentationLibraryMetrics `` /* 150-byte string literal not displayed */ // contains filtered or unexported fields }
A collection of InstrumentationLibraryMetrics from a Resource.
func (*ResourceMetrics) Descriptor
deprecated
func (*ResourceMetrics) Descriptor() ([]byte, []int)
Deprecated: Use ResourceMetrics.ProtoReflect.Descriptor instead.
func (*ResourceMetrics) GetInstrumentationLibraryMetrics ¶
func (x *ResourceMetrics) GetInstrumentationLibraryMetrics() []*InstrumentationLibraryMetrics
func (*ResourceMetrics) GetResource ¶
func (x *ResourceMetrics) GetResource() *Resource
func (*ResourceMetrics) ProtoMessage ¶
func (*ResourceMetrics) ProtoMessage()
func (*ResourceMetrics) ProtoReflect ¶
func (x *ResourceMetrics) ProtoReflect() protoreflect.Message
func (*ResourceMetrics) Reset ¶
func (x *ResourceMetrics) Reset()
func (*ResourceMetrics) String ¶
func (x *ResourceMetrics) String() string
type ResourceSpans ¶
type ResourceSpans struct { // The resource for the spans in this message. // If this field is not set then no resource info is known. Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` // A list of InstrumentationLibrarySpans that originate from a resource. InstrumentationLibrarySpans []*InstrumentationLibrarySpans `` /* 144-byte string literal not displayed */ // contains filtered or unexported fields }
A collection of InstrumentationLibrarySpans from a Resource.
func (*ResourceSpans) Descriptor
deprecated
func (*ResourceSpans) Descriptor() ([]byte, []int)
Deprecated: Use ResourceSpans.ProtoReflect.Descriptor instead.
func (*ResourceSpans) GetInstrumentationLibrarySpans ¶
func (x *ResourceSpans) GetInstrumentationLibrarySpans() []*InstrumentationLibrarySpans
func (*ResourceSpans) GetResource ¶
func (x *ResourceSpans) GetResource() *Resource
func (*ResourceSpans) ProtoMessage ¶
func (*ResourceSpans) ProtoMessage()
func (*ResourceSpans) ProtoReflect ¶
func (x *ResourceSpans) ProtoReflect() protoreflect.Message
func (*ResourceSpans) Reset ¶
func (x *ResourceSpans) Reset()
func (*ResourceSpans) String ¶
func (x *ResourceSpans) String() string
type Response ¶
type Response struct { ResponseType RequestType `protobuf:"varint,1,opt,name=response_type,json=responseType,proto3,enum=baseline.RequestType" json:"response_type,omitempty"` Export *ExportResponse `protobuf:"bytes,2,opt,name=export,proto3" json:"export,omitempty"` // contains filtered or unexported fields }
Response is used by transports that unlike gRPC don't have built-in message type multiplexing such as WebSocket.
func (*Response) Descriptor
deprecated
func (*Response) GetExport ¶
func (x *Response) GetExport() *ExportResponse
func (*Response) GetResponseType ¶
func (x *Response) GetResponseType() RequestType
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type SeverityNumber ¶
type SeverityNumber int32
Possible values for LogRecord.SeverityNumber.
const ( // UNSPECIFIED is the default SeverityNumber, it MUST not be used. SeverityNumber_SEVERITY_NUMBER_UNSPECIFIED SeverityNumber = 0 SeverityNumber_SEVERITY_NUMBER_TRACE SeverityNumber = 1 SeverityNumber_SEVERITY_NUMBER_TRACE2 SeverityNumber = 2 SeverityNumber_SEVERITY_NUMBER_TRACE3 SeverityNumber = 3 SeverityNumber_SEVERITY_NUMBER_TRACE4 SeverityNumber = 4 SeverityNumber_SEVERITY_NUMBER_DEBUG SeverityNumber = 5 SeverityNumber_SEVERITY_NUMBER_DEBUG2 SeverityNumber = 6 SeverityNumber_SEVERITY_NUMBER_DEBUG3 SeverityNumber = 7 SeverityNumber_SEVERITY_NUMBER_DEBUG4 SeverityNumber = 8 SeverityNumber_SEVERITY_NUMBER_INFO SeverityNumber = 9 SeverityNumber_SEVERITY_NUMBER_INFO2 SeverityNumber = 10 SeverityNumber_SEVERITY_NUMBER_INFO3 SeverityNumber = 11 SeverityNumber_SEVERITY_NUMBER_INFO4 SeverityNumber = 12 SeverityNumber_SEVERITY_NUMBER_WARN SeverityNumber = 13 SeverityNumber_SEVERITY_NUMBER_WARN2 SeverityNumber = 14 SeverityNumber_SEVERITY_NUMBER_WARN3 SeverityNumber = 15 SeverityNumber_SEVERITY_NUMBER_WARN4 SeverityNumber = 16 SeverityNumber_SEVERITY_NUMBER_ERROR SeverityNumber = 17 SeverityNumber_SEVERITY_NUMBER_ERROR2 SeverityNumber = 18 SeverityNumber_SEVERITY_NUMBER_ERROR3 SeverityNumber = 19 SeverityNumber_SEVERITY_NUMBER_ERROR4 SeverityNumber = 20 SeverityNumber_SEVERITY_NUMBER_FATAL SeverityNumber = 21 SeverityNumber_SEVERITY_NUMBER_FATAL2 SeverityNumber = 22 SeverityNumber_SEVERITY_NUMBER_FATAL3 SeverityNumber = 23 SeverityNumber_SEVERITY_NUMBER_FATAL4 SeverityNumber = 24 )
func (SeverityNumber) Descriptor ¶
func (SeverityNumber) Descriptor() protoreflect.EnumDescriptor
func (SeverityNumber) Enum ¶
func (x SeverityNumber) Enum() *SeverityNumber
func (SeverityNumber) EnumDescriptor
deprecated
func (SeverityNumber) EnumDescriptor() ([]byte, []int)
Deprecated: Use SeverityNumber.Descriptor instead.
func (SeverityNumber) Number ¶
func (x SeverityNumber) Number() protoreflect.EnumNumber
func (SeverityNumber) String ¶
func (x SeverityNumber) String() string
func (SeverityNumber) Type ¶
func (SeverityNumber) Type() protoreflect.EnumType
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"` // trace_state conveys information about request position in multiple distributed tracing graphs. // It is a trace_state in w3c-trace-context format: https://www.w3.org/TR/trace-context/#tracestate-header // See also https://github.com/w3c/distributed-tracing for more details about this field. TraceState string `protobuf:"bytes,3,opt,name=trace_state,json=traceState,proto3" json:"trace_state,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,4,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,5,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,6,opt,name=kind,proto3,enum=baseline.Span_SpanKind" json:"kind,omitempty"` // start_time_unix_nano is 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. // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January 1970. // // This field is semantically required and it is expected that end_time >= start_time. StartTimeUnixNano uint64 `protobuf:"fixed64,7,opt,name=start_time_unix_nano,json=startTimeUnixNano,proto3" json:"start_time_unix_nano,omitempty"` // end_time_unix_nano is 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. // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January 1970. // // This field is semantically required and it is expected that end_time >= start_time. EndTimeUnixNano uint64 `protobuf:"fixed64,8,opt,name=end_time_unix_nano,json=endTimeUnixNano,proto3" json:"end_time_unix_nano,omitempty"` // attributes is a collection of key/value pairs. 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 using the 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 []*KeyValue `protobuf:"bytes,9,rep,name=attributes,proto3" json:"attributes,omitempty"` // dropped_attributes_count is the number of attributes that were discarded. Attributes // can be discarded because their keys are too long or because there are too many // attributes. If this value is 0, then no attributes were dropped. DroppedAttributesCount uint32 `` /* 131-byte string literal not displayed */ // events is a collection of Event items. Events []*Span_Event `protobuf:"bytes,11,rep,name=events,proto3" json:"events,omitempty"` // dropped_events_count is the number of dropped events. If the value is 0, then no // events were dropped. DroppedEventsCount uint32 `protobuf:"varint,12,opt,name=dropped_events_count,json=droppedEventsCount,proto3" json:"dropped_events_count,omitempty"` // links is a collection of Links, which are references from this span to a span // in the same or different trace. Links []*Span_Link `protobuf:"bytes,13,rep,name=links,proto3" json:"links,omitempty"` // dropped_links_count is the number of dropped links after the maximum size was // enforced. If this value is 0, then no links were dropped. DroppedLinksCount uint32 `protobuf:"varint,14,opt,name=dropped_links_count,json=droppedLinksCount,proto3" json:"dropped_links_count,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,15,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
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 available field id is 17.
func (*Span) Descriptor
deprecated
func (*Span) GetAttributes ¶
func (*Span) GetDroppedAttributesCount ¶
func (*Span) GetDroppedEventsCount ¶
func (*Span) GetDroppedLinksCount ¶
func (*Span) GetEndTimeUnixNano ¶
func (*Span) GetEvents ¶
func (x *Span) GetEvents() []*Span_Event
func (*Span) GetKind ¶
func (x *Span) GetKind() Span_SpanKind
func (*Span) GetParentSpanId ¶
func (*Span) GetStartTimeUnixNano ¶
func (*Span) GetTraceId ¶
func (*Span) GetTraceState ¶
func (*Span) ProtoMessage ¶
func (*Span) ProtoMessage()
func (*Span) ProtoReflect ¶
func (x *Span) ProtoReflect() protoreflect.Message
type Span_Event ¶
type Span_Event struct { // time_unix_nano is the time the event occurred. TimeUnixNano uint64 `protobuf:"fixed64,1,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"` // name of the event. // This field is semantically required to be set to non-empty string. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // attributes is a collection of attribute key/value pairs on the event. Attributes []*KeyValue `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty"` // dropped_attributes_count is the number of dropped attributes. If the value is 0, // then no attributes were dropped. DroppedAttributesCount uint32 `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
Event is a time-stamped annotation of the span, consisting of user-supplied text description and key-value pairs.
func (*Span_Event) Descriptor
deprecated
func (*Span_Event) Descriptor() ([]byte, []int)
Deprecated: Use Span_Event.ProtoReflect.Descriptor instead.
func (*Span_Event) GetAttributes ¶
func (x *Span_Event) GetAttributes() []*KeyValue
func (*Span_Event) GetDroppedAttributesCount ¶
func (x *Span_Event) GetDroppedAttributesCount() uint32
func (*Span_Event) GetName ¶
func (x *Span_Event) GetName() string
func (*Span_Event) GetTimeUnixNano ¶
func (x *Span_Event) GetTimeUnixNano() uint64
func (*Span_Event) ProtoMessage ¶
func (*Span_Event) ProtoMessage()
func (*Span_Event) ProtoReflect ¶
func (x *Span_Event) ProtoReflect() protoreflect.Message
func (*Span_Event) Reset ¶
func (x *Span_Event) Reset()
func (*Span_Event) String ¶
func (x *Span_Event) String() string
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 trace_state associated with the link. TraceState string `protobuf:"bytes,3,opt,name=trace_state,json=traceState,proto3" json:"trace_state,omitempty"` // attributes is a collection of attribute key/value pairs on the link. Attributes []*KeyValue `protobuf:"bytes,4,rep,name=attributes,proto3" json:"attributes,omitempty"` // dropped_attributes_count is the number of dropped attributes. If the value is 0, // then no attributes were dropped. DroppedAttributesCount uint32 `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
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
deprecated
func (*Span_Link) GetAttributes ¶
func (*Span_Link) GetDroppedAttributesCount ¶
func (*Span_Link) GetTraceId ¶
func (*Span_Link) GetTraceState ¶
func (*Span_Link) ProtoMessage ¶
func (*Span_Link) ProtoMessage()
func (*Span_Link) ProtoReflect ¶
func (x *Span_Link) ProtoReflect() protoreflect.Message
type Span_SpanKind ¶
type Span_SpanKind int32
SpanKind is the type of span. Can be used to specify additional relationships between spans in addition to a parent/child relationship.
const ( // Unspecified. Do NOT use as default. // Implementations MAY assume SpanKind to be INTERNAL when receiving UNSPECIFIED. Span_SPAN_KIND_UNSPECIFIED Span_SpanKind = 0 // Indicates that the span represents an internal operation within an application, // as opposed to an operations happening at the boundaries. Default value. Span_SPAN_KIND_INTERNAL Span_SpanKind = 1 // Indicates that the span covers server-side handling of an RPC or other // remote network request. Span_SPAN_KIND_SERVER Span_SpanKind = 2 // Indicates that the span describes a request to some remote service. Span_SPAN_KIND_CLIENT Span_SpanKind = 3 // Indicates that the span describes a producer sending a message to a broker. // Unlike CLIENT and SERVER, there is often no direct critical path latency relationship // between producer and consumer spans. A PRODUCER span ends when the message was accepted // by the broker while the logical processing of the message might span a much longer time. Span_SPAN_KIND_PRODUCER Span_SpanKind = 4 // Indicates that the span describes consumer receiving a message from a broker. // Like the PRODUCER kind, there is often no direct critical path latency relationship // between producer and consumer spans. Span_SPAN_KIND_CONSUMER Span_SpanKind = 5 )
func (Span_SpanKind) Descriptor ¶
func (Span_SpanKind) Descriptor() protoreflect.EnumDescriptor
func (Span_SpanKind) Enum ¶
func (x Span_SpanKind) Enum() *Span_SpanKind
func (Span_SpanKind) EnumDescriptor
deprecated
func (Span_SpanKind) EnumDescriptor() ([]byte, []int)
Deprecated: Use Span_SpanKind.Descriptor instead.
func (Span_SpanKind) Number ¶
func (x Span_SpanKind) Number() protoreflect.EnumNumber
func (Span_SpanKind) String ¶
func (x Span_SpanKind) String() string
func (Span_SpanKind) Type ¶
func (Span_SpanKind) Type() protoreflect.EnumType
type Status ¶
type Status struct { // The status code. This is optional field. It is safe to assume 0 (OK) // when not set. Code Status_StatusCode `protobuf:"varint,1,opt,name=code,proto3,enum=baseline.Status_StatusCode" json:"code,omitempty"` // A developer-facing human readable error message. Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
The Status type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs.
func (*Status) Descriptor
deprecated
func (*Status) GetCode ¶
func (x *Status) GetCode() Status_StatusCode
func (*Status) GetMessage ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶
func (x *Status) ProtoReflect() protoreflect.Message
type Status_StatusCode ¶
type Status_StatusCode int32
StatusCode mirrors the codes defined at https://github.com/open-telemetry/opentelemetry-specification/blob/master/specification/api-tracing.md#statuscanonicalcode
const ( Status_STATUS_CODE_OK Status_StatusCode = 0 Status_STATUS_CODE_CANCELLED Status_StatusCode = 1 Status_STATUS_CODE_UNKNOWN_ERROR Status_StatusCode = 2 Status_STATUS_CODE_INVALID_ARGUMENT Status_StatusCode = 3 Status_STATUS_CODE_DEADLINE_EXCEEDED Status_StatusCode = 4 Status_STATUS_CODE_NOT_FOUND Status_StatusCode = 5 Status_STATUS_CODE_ALREADY_EXISTS Status_StatusCode = 6 Status_STATUS_CODE_PERMISSION_DENIED Status_StatusCode = 7 Status_STATUS_CODE_RESOURCE_EXHAUSTED Status_StatusCode = 8 Status_STATUS_CODE_FAILED_PRECONDITION Status_StatusCode = 9 Status_STATUS_CODE_ABORTED Status_StatusCode = 10 Status_STATUS_CODE_OUT_OF_RANGE Status_StatusCode = 11 Status_STATUS_CODE_UNIMPLEMENTED Status_StatusCode = 12 Status_STATUS_CODE_INTERNAL_ERROR Status_StatusCode = 13 Status_STATUS_CODE_UNAVAILABLE Status_StatusCode = 14 Status_STATUS_CODE_DATA_LOSS Status_StatusCode = 15 Status_STATUS_CODE_UNAUTHENTICATED Status_StatusCode = 16 )
func (Status_StatusCode) Descriptor ¶
func (Status_StatusCode) Descriptor() protoreflect.EnumDescriptor
func (Status_StatusCode) Enum ¶
func (x Status_StatusCode) Enum() *Status_StatusCode
func (Status_StatusCode) EnumDescriptor
deprecated
func (Status_StatusCode) EnumDescriptor() ([]byte, []int)
Deprecated: Use Status_StatusCode.Descriptor instead.
func (Status_StatusCode) Number ¶
func (x Status_StatusCode) Number() protoreflect.EnumNumber
func (Status_StatusCode) String ¶
func (x Status_StatusCode) String() string
func (Status_StatusCode) Type ¶
func (Status_StatusCode) Type() protoreflect.EnumType
type StreamExporterClient ¶
type StreamExporterClient interface {
ExportTraces(ctx context.Context, opts ...grpc.CallOption) (StreamExporter_ExportTracesClient, error)
}
StreamExporterClient is the client API for StreamExporter service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewStreamExporterClient ¶
func NewStreamExporterClient(cc grpc.ClientConnInterface) StreamExporterClient
type StreamExporterServer ¶
type StreamExporterServer interface { ExportTraces(StreamExporter_ExportTracesServer) error // contains filtered or unexported methods }
StreamExporterServer is the server API for StreamExporter service. All implementations must embed UnimplementedStreamExporterServer for forward compatibility
type StreamExporter_ExportTracesClient ¶
type StreamExporter_ExportTracesClient interface { Send(*TraceExportRequest) error Recv() (*ExportResponse, error) grpc.ClientStream }
type StreamExporter_ExportTracesServer ¶
type StreamExporter_ExportTracesServer interface { Send(*ExportResponse) error Recv() (*TraceExportRequest, error) grpc.ServerStream }
type StringKeyValue ¶
type StringKeyValue struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
StringKeyValue is a pair of key/value strings. This is the simpler (and faster) version of KeyValue that only supports string values.
func (*StringKeyValue) Descriptor
deprecated
func (*StringKeyValue) Descriptor() ([]byte, []int)
Deprecated: Use StringKeyValue.ProtoReflect.Descriptor instead.
func (*StringKeyValue) GetKey ¶
func (x *StringKeyValue) GetKey() string
func (*StringKeyValue) GetValue ¶
func (x *StringKeyValue) GetValue() string
func (*StringKeyValue) ProtoMessage ¶
func (*StringKeyValue) ProtoMessage()
func (*StringKeyValue) ProtoReflect ¶
func (x *StringKeyValue) ProtoReflect() protoreflect.Message
func (*StringKeyValue) Reset ¶
func (x *StringKeyValue) Reset()
func (*StringKeyValue) String ¶
func (x *StringKeyValue) String() string
type Sum ¶
type Sum struct { DataPoints []*NumberDataPoint `protobuf:"bytes,1,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"` // aggregation_temporality describes if the aggregator reports delta changes // since last report time, or cumulative changes since a fixed start time. AggregationTemporality AggregationTemporality `` /* 165-byte string literal not displayed */ // If "true" means that the sum is monotonic. IsMonotonic bool `protobuf:"varint,3,opt,name=is_monotonic,json=isMonotonic,proto3" json:"is_monotonic,omitempty"` // contains filtered or unexported fields }
Sum represents the type of a numeric double scalar metric that is calculated as a sum of all reported measurements over a time interval.
func (*Sum) Descriptor
deprecated
func (*Sum) GetAggregationTemporality ¶
func (x *Sum) GetAggregationTemporality() AggregationTemporality
func (*Sum) GetDataPoints ¶
func (x *Sum) GetDataPoints() []*NumberDataPoint
func (*Sum) GetIsMonotonic ¶
func (*Sum) ProtoMessage ¶
func (*Sum) ProtoMessage()
func (*Sum) ProtoReflect ¶
func (x *Sum) ProtoReflect() protoreflect.Message
type Summary ¶
type Summary struct { DataPoints []*SummaryDataPoint `protobuf:"bytes,1,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"` // contains filtered or unexported fields }
Summary metric data are used to convey quantile summaries, a Prometheus (see: https://prometheus.io/docs/concepts/metric_types/#summary) and OpenMetrics (see: https://github.com/OpenObservability/OpenMetrics/blob/4dbf6075567ab43296eed941037c12951faafb92/protos/prometheus.proto#L45) data type. These data points cannot always be merged in a meaningful way. While they can be useful in some applications, histogram data points are recommended for new applications.
func (*Summary) Descriptor
deprecated
func (*Summary) GetDataPoints ¶
func (x *Summary) GetDataPoints() []*SummaryDataPoint
func (*Summary) ProtoMessage ¶
func (*Summary) ProtoMessage()
func (*Summary) ProtoReflect ¶
func (x *Summary) ProtoReflect() protoreflect.Message
type SummaryDataPoint ¶
type SummaryDataPoint struct { // The set of labels that uniquely identify this timeseries. Labels []*StringKeyValue `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"` // start_time_unix_nano is the last time when the aggregation value was reset // to "zero". For some metric types this is ignored, see data types for more // details. // // The aggregation value is over the time interval (start_time_unix_nano, // time_unix_nano]. // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. // // Value of 0 indicates that the timestamp is unspecified. In that case the // timestamp may be decided by the backend. StartTimeUnixNano uint64 `protobuf:"fixed64,2,opt,name=start_time_unix_nano,json=startTimeUnixNano,proto3" json:"start_time_unix_nano,omitempty"` // time_unix_nano is the moment when this aggregation value was reported. // // Value is UNIX Epoch time in nanoseconds since 00:00:00 UTC on 1 January // 1970. TimeUnixNano uint64 `protobuf:"fixed64,3,opt,name=time_unix_nano,json=timeUnixNano,proto3" json:"time_unix_nano,omitempty"` // count is the number of values in the population. Must be non-negative. Count uint64 `protobuf:"fixed64,4,opt,name=count,proto3" json:"count,omitempty"` // sum of the values in the population. If count is zero then this field // must be zero. Sum float64 `protobuf:"fixed64,5,opt,name=sum,proto3" json:"sum,omitempty"` // (Optional) list of values at different quantiles of the distribution calculated // from the current snapshot. The quantiles must be strictly increasing. QuantileValues []*SummaryDataPoint_ValueAtQuantile `protobuf:"bytes,6,rep,name=quantile_values,json=quantileValues,proto3" json:"quantile_values,omitempty"` // contains filtered or unexported fields }
SummaryDataPoint is a single data point in a timeseries that describes the time-varying values of a Summary metric.
func (*SummaryDataPoint) Descriptor
deprecated
func (*SummaryDataPoint) Descriptor() ([]byte, []int)
Deprecated: Use SummaryDataPoint.ProtoReflect.Descriptor instead.
func (*SummaryDataPoint) GetCount ¶
func (x *SummaryDataPoint) GetCount() uint64
func (*SummaryDataPoint) GetLabels ¶
func (x *SummaryDataPoint) GetLabels() []*StringKeyValue
func (*SummaryDataPoint) GetQuantileValues ¶
func (x *SummaryDataPoint) GetQuantileValues() []*SummaryDataPoint_ValueAtQuantile
func (*SummaryDataPoint) GetStartTimeUnixNano ¶
func (x *SummaryDataPoint) GetStartTimeUnixNano() uint64
func (*SummaryDataPoint) GetSum ¶
func (x *SummaryDataPoint) GetSum() float64
func (*SummaryDataPoint) GetTimeUnixNano ¶
func (x *SummaryDataPoint) GetTimeUnixNano() uint64
func (*SummaryDataPoint) ProtoMessage ¶
func (*SummaryDataPoint) ProtoMessage()
func (*SummaryDataPoint) ProtoReflect ¶
func (x *SummaryDataPoint) ProtoReflect() protoreflect.Message
func (*SummaryDataPoint) Reset ¶
func (x *SummaryDataPoint) Reset()
func (*SummaryDataPoint) String ¶
func (x *SummaryDataPoint) String() string
type SummaryDataPoint_ValueAtQuantile ¶
type SummaryDataPoint_ValueAtQuantile struct { // The quantile of a distribution. Must be in the interval // [0.0, 1.0]. Quantile float64 `protobuf:"fixed64,1,opt,name=quantile,proto3" json:"quantile,omitempty"` // The value at the given quantile of a distribution. Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
Represents the value at a given quantile of a distribution.
To record Min and Max values following conventions are used: - The 1.0 quantile is equivalent to the maximum value observed. - The 0.0 quantile is equivalent to the minimum value observed.
See the following issue for more context: https://github.com/open-telemetry/opentelemetry-proto/issues/125
func (*SummaryDataPoint_ValueAtQuantile) Descriptor
deprecated
func (*SummaryDataPoint_ValueAtQuantile) Descriptor() ([]byte, []int)
Deprecated: Use SummaryDataPoint_ValueAtQuantile.ProtoReflect.Descriptor instead.
func (*SummaryDataPoint_ValueAtQuantile) GetQuantile ¶
func (x *SummaryDataPoint_ValueAtQuantile) GetQuantile() float64
func (*SummaryDataPoint_ValueAtQuantile) GetValue ¶
func (x *SummaryDataPoint_ValueAtQuantile) GetValue() float64
func (*SummaryDataPoint_ValueAtQuantile) ProtoMessage ¶
func (*SummaryDataPoint_ValueAtQuantile) ProtoMessage()
func (*SummaryDataPoint_ValueAtQuantile) ProtoReflect ¶
func (x *SummaryDataPoint_ValueAtQuantile) ProtoReflect() protoreflect.Message
func (*SummaryDataPoint_ValueAtQuantile) Reset ¶
func (x *SummaryDataPoint_ValueAtQuantile) Reset()
func (*SummaryDataPoint_ValueAtQuantile) String ¶
func (x *SummaryDataPoint_ValueAtQuantile) String() string
type TraceExportRequest ¶
type TraceExportRequest struct { // Unique sequential ID generated by the client. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // Telemetry data. An array of ResourceSpans. ResourceSpans []*ResourceSpans `protobuf:"bytes,2,rep,name=resourceSpans,proto3" json:"resourceSpans,omitempty"` // contains filtered or unexported fields }
A request from client to server containing trace data to export.
func (*TraceExportRequest) Descriptor
deprecated
func (*TraceExportRequest) Descriptor() ([]byte, []int)
Deprecated: Use TraceExportRequest.ProtoReflect.Descriptor instead.
func (*TraceExportRequest) GetId ¶
func (x *TraceExportRequest) GetId() uint64
func (*TraceExportRequest) GetResourceSpans ¶
func (x *TraceExportRequest) GetResourceSpans() []*ResourceSpans
func (*TraceExportRequest) ProtoMessage ¶
func (*TraceExportRequest) ProtoMessage()
func (*TraceExportRequest) ProtoReflect ¶
func (x *TraceExportRequest) ProtoReflect() protoreflect.Message
func (*TraceExportRequest) Reset ¶
func (x *TraceExportRequest) Reset()
func (*TraceExportRequest) String ¶
func (x *TraceExportRequest) String() string
type UnaryExporterClient ¶
type UnaryExporterClient interface {
ExportTraces(ctx context.Context, in *TraceExportRequest, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewUnaryExporterClient ¶
func NewUnaryExporterClient(cc grpc.ClientConnInterface) UnaryExporterClient
type UnaryExporterServer ¶
type UnaryExporterServer interface { ExportTraces(context.Context, *TraceExportRequest) (*ExportResponse, error) // contains filtered or unexported methods }
UnaryExporterServer is the server API for UnaryExporter service. All implementations must embed UnimplementedUnaryExporterServer for forward compatibility
type UnimplementedStreamExporterServer ¶
type UnimplementedStreamExporterServer struct { }
UnimplementedStreamExporterServer must be embedded to have forward compatible implementations.
func (UnimplementedStreamExporterServer) ExportTraces ¶
func (UnimplementedStreamExporterServer) ExportTraces(StreamExporter_ExportTracesServer) error
type UnimplementedUnaryExporterServer ¶
type UnimplementedUnaryExporterServer struct { }
UnimplementedUnaryExporterServer must be embedded to have forward compatible implementations.
func (UnimplementedUnaryExporterServer) ExportTraces ¶
func (UnimplementedUnaryExporterServer) ExportTraces(context.Context, *TraceExportRequest) (*ExportResponse, error)
type UnsafeStreamExporterServer ¶
type UnsafeStreamExporterServer interface {
// contains filtered or unexported methods
}
UnsafeStreamExporterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamExporterServer will result in compilation errors.
type UnsafeUnaryExporterServer ¶
type UnsafeUnaryExporterServer interface {
// contains filtered or unexported methods
}
UnsafeUnaryExporterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UnaryExporterServer will result in compilation errors.