baseline

package
v0.0.0-...-c8bf5b5 Latest Latest
Warning

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

Go to latest
Published: Nov 9, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
var (
	RequestType_name = map[int32]string{
		0: "_",
		1: "TraceExport",
	}
	RequestType_value = map[string]int32{
		"_":           0,
		"TraceExport": 1,
	}
)

Enum value maps for RequestType.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
var File_common_proto protoreflect.FileDescriptor
View Source
var File_exchange_proto protoreflect.FileDescriptor
View Source
var File_logs_service_proto protoreflect.FileDescriptor
View Source
var File_metric_data_proto protoreflect.FileDescriptor
View Source
var File_telemetry_data_proto protoreflect.FileDescriptor
View Source
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)

View Source
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) Enum

func (AggregationTemporality) EnumDescriptor deprecated

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

Deprecated: Use AggregationTemporality.Descriptor instead.

func (AggregationTemporality) Number

func (AggregationTemporality) String

func (x AggregationTemporality) String() string

func (AggregationTemporality) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use AnyValue.ProtoReflect.Descriptor instead.

func (*AnyValue) GetArrayValue

func (x *AnyValue) GetArrayValue() *ArrayValue

func (*AnyValue) GetBoolValue

func (x *AnyValue) GetBoolValue() bool

func (*AnyValue) GetDoubleValue

func (x *AnyValue) GetDoubleValue() float64

func (*AnyValue) GetIntValue

func (x *AnyValue) GetIntValue() int64

func (*AnyValue) GetKvlistValue

func (x *AnyValue) GetKvlistValue() *KeyValueList

func (*AnyValue) GetStringValue

func (x *AnyValue) GetStringValue() string

func (*AnyValue) GetValue

func (m *AnyValue) GetValue() isAnyValue_Value

func (*AnyValue) ProtoMessage

func (*AnyValue) ProtoMessage()

func (*AnyValue) ProtoReflect

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

func (*AnyValue) Reset

func (x *AnyValue) Reset()

func (*AnyValue) String

func (x *AnyValue) String() string

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) Enum

func (x Capabilities) Enum() *Capabilities

func (Capabilities) EnumDescriptor deprecated

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

Deprecated: Use Capabilities.Descriptor instead.

func (Capabilities) Number

func (Capabilities) String

func (x Capabilities) String() string

func (Capabilities) Type

type CompressionMethod

type CompressionMethod int32
const (
	CompressionMethod_NONE CompressionMethod = 0
	CompressionMethod_LZ4  CompressionMethod = 1
	CompressionMethod_ZLIB CompressionMethod = 2
)

func (CompressionMethod) Descriptor

func (CompressionMethod) Enum

func (CompressionMethod) EnumDescriptor deprecated

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

Deprecated: Use CompressionMethod.Descriptor instead.

func (CompressionMethod) Number

func (CompressionMethod) String

func (x CompressionMethod) String() string

func (CompressionMethod) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Exemplar.ProtoReflect.Descriptor instead.

func (*Exemplar) GetAsDouble

func (x *Exemplar) GetAsDouble() float64

func (*Exemplar) GetAsInt

func (x *Exemplar) GetAsInt() int64

func (*Exemplar) GetFilteredLabels

func (x *Exemplar) GetFilteredLabels() []*StringKeyValue

func (*Exemplar) GetSpanId

func (x *Exemplar) GetSpanId() []byte

func (*Exemplar) GetTimeUnixNano

func (x *Exemplar) GetTimeUnixNano() uint64

func (*Exemplar) GetTraceId

func (x *Exemplar) GetTraceId() []byte

func (*Exemplar) GetValue

func (m *Exemplar) GetValue() isExemplar_Value

func (*Exemplar) ProtoMessage

func (*Exemplar) ProtoMessage()

func (*Exemplar) ProtoReflect

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

func (*Exemplar) Reset

func (x *Exemplar) Reset()

func (*Exemplar) String

func (x *Exemplar) String() string

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 (*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) Enum

func (ExportResponse_ResultCode) EnumDescriptor deprecated

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

Deprecated: Use ExportResponse_ResultCode.Descriptor instead.

func (ExportResponse_ResultCode) Number

func (ExportResponse_ResultCode) String

func (x ExportResponse_ResultCode) String() string

func (ExportResponse_ResultCode) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Gauge.ProtoReflect.Descriptor instead.

func (*Gauge) GetDataPoints

func (x *Gauge) GetDataPoints() []*NumberDataPoint

func (*Gauge) ProtoMessage

func (*Gauge) ProtoMessage()

func (*Gauge) ProtoReflect

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

func (*Gauge) Reset

func (x *Gauge) Reset()

func (*Gauge) String

func (x *Gauge) String() string

type Generator

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

Generator allows to generate a ExportRequest.

func NewGenerator

func NewGenerator() *Generator

func (*Generator) GenerateLogBatch

func (g *Generator) GenerateLogBatch(logsPerBatch int, attrsPerLog int) core.ExportRequest

func (*Generator) GenerateMetricBatch

func (g *Generator) GenerateMetricBatch(
	metricsPerBatch int,
	valuesPerTimeseries int,
	int64 bool,
	histogram bool,
	summary bool,
) core.ExportRequest

func (*Generator) GenerateSpanBatch

func (g *Generator) GenerateSpanBatch(spansPerBatch int, attrsPerSpan int, timedEventsPerSpan int) core.ExportRequest

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) Descriptor() ([]byte, []int)

Deprecated: Use Histogram.ProtoReflect.Descriptor instead.

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

func (*Histogram) Reset

func (x *Histogram) Reset()

func (*Histogram) String

func (x *Histogram) String() string

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 (*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 (*InstrumentationLibraryMetrics) Reset

func (x *InstrumentationLibraryMetrics) Reset()

func (*InstrumentationLibraryMetrics) 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 (*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) Descriptor() ([]byte, []int)

Deprecated: Use IntGauge.ProtoReflect.Descriptor instead.

func (*IntGauge) GetDataPoints

func (x *IntGauge) GetDataPoints() []*IntDataPoint

func (*IntGauge) ProtoMessage

func (*IntGauge) ProtoMessage()

func (*IntGauge) ProtoReflect

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

func (*IntGauge) Reset

func (x *IntGauge) Reset()

func (*IntGauge) String

func (x *IntGauge) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use IntSum.ProtoReflect.Descriptor instead.

func (*IntSum) GetAggregationTemporality

func (x *IntSum) GetAggregationTemporality() AggregationTemporality

func (*IntSum) GetDataPoints

func (x *IntSum) GetDataPoints() []*IntDataPoint

func (*IntSum) GetIsMonotonic

func (x *IntSum) GetIsMonotonic() bool

func (*IntSum) ProtoMessage

func (*IntSum) ProtoMessage()

func (*IntSum) ProtoReflect

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

func (*IntSum) Reset

func (x *IntSum) Reset()

func (*IntSum) String

func (x *IntSum) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey

func (x *KeyValue) GetKey() string

func (*KeyValue) GetValue

func (x *KeyValue) GetValue() *AnyValue

func (*KeyValue) ProtoMessage

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect

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

func (*KeyValue) Reset

func (x *KeyValue) Reset()

func (*KeyValue) String

func (x *KeyValue) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use LogRecord.ProtoReflect.Descriptor instead.

func (*LogRecord) GetAttributes

func (x *LogRecord) GetAttributes() []*KeyValue

func (*LogRecord) GetBody

func (x *LogRecord) GetBody() *AnyValue

func (*LogRecord) GetDroppedAttributesCount

func (x *LogRecord) GetDroppedAttributesCount() uint32

func (*LogRecord) GetFlags

func (x *LogRecord) GetFlags() uint32

func (*LogRecord) GetName

func (x *LogRecord) GetName() string

func (*LogRecord) GetSeverityNumber

func (x *LogRecord) GetSeverityNumber() SeverityNumber

func (*LogRecord) GetSeverityText

func (x *LogRecord) GetSeverityText() string

func (*LogRecord) GetSpanId

func (x *LogRecord) GetSpanId() []byte

func (*LogRecord) GetTimeUnixNano

func (x *LogRecord) GetTimeUnixNano() uint64

func (*LogRecord) GetTraceId

func (x *LogRecord) GetTraceId() []byte

func (*LogRecord) ProtoMessage

func (*LogRecord) ProtoMessage()

func (*LogRecord) ProtoReflect

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

func (*LogRecord) Reset

func (x *LogRecord) Reset()

func (*LogRecord) String

func (x *LogRecord) String() string

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) Enum

func (x LogRecordFlags) Enum() *LogRecordFlags

func (LogRecordFlags) EnumDescriptor deprecated

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

Deprecated: Use LogRecordFlags.Descriptor instead.

func (LogRecordFlags) Number

func (LogRecordFlags) String

func (x LogRecordFlags) String() string

func (LogRecordFlags) Type

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 GenMetricDescriptor(i int) *Metric

func (*Metric) Descriptor deprecated

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetData

func (m *Metric) GetData() isMetric_Data

func (*Metric) GetDescription

func (x *Metric) GetDescription() string

func (*Metric) GetGauge

func (x *Metric) GetGauge() *Gauge

func (*Metric) GetHistogram

func (x *Metric) GetHistogram() *Histogram

func (*Metric) GetIntGauge deprecated

func (x *Metric) GetIntGauge() *IntGauge

Deprecated: Do not use.

func (*Metric) GetIntHistogram deprecated

func (x *Metric) GetIntHistogram() *IntHistogram

Deprecated: Do not use.

func (*Metric) GetIntSum deprecated

func (x *Metric) GetIntSum() *IntSum

Deprecated: Do not use.

func (*Metric) GetName

func (x *Metric) GetName() string

func (*Metric) GetSum

func (x *Metric) GetSum() *Sum

func (*Metric) GetSummary

func (x *Metric) GetSummary() *Summary

func (*Metric) GetUnit

func (x *Metric) GetUnit() string

func (*Metric) ProtoMessage

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect

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

func (*Metric) Reset

func (x *Metric) Reset()

func (*Metric) String

func (x *Metric) String() string

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) 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

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) Descriptor() ([]byte, []int)

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetAttributes

func (x *Resource) GetAttributes() []*KeyValue

func (*Resource) GetDroppedAttributesCount

func (x *Resource) GetDroppedAttributesCount() uint32

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect

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

func (*Resource) Reset

func (x *Resource) Reset()

func (*Resource) String

func (x *Resource) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

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

func (*Response) Reset

func (x *Response) Reset()

func (*Response) String

func (x *Response) String() string

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) Enum

func (x SeverityNumber) Enum() *SeverityNumber

func (SeverityNumber) EnumDescriptor deprecated

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

Deprecated: Use SeverityNumber.Descriptor instead.

func (SeverityNumber) Number

func (SeverityNumber) String

func (x SeverityNumber) String() string

func (SeverityNumber) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Span.ProtoReflect.Descriptor instead.

func (*Span) GetAttributes

func (x *Span) GetAttributes() []*KeyValue

func (*Span) GetDroppedAttributesCount

func (x *Span) GetDroppedAttributesCount() uint32

func (*Span) GetDroppedEventsCount

func (x *Span) GetDroppedEventsCount() uint32

func (*Span) GetDroppedLinksCount

func (x *Span) GetDroppedLinksCount() uint32

func (*Span) GetEndTimeUnixNano

func (x *Span) GetEndTimeUnixNano() uint64

func (*Span) GetEvents

func (x *Span) GetEvents() []*Span_Event

func (*Span) GetKind

func (x *Span) GetKind() Span_SpanKind
func (x *Span) GetLinks() []*Span_Link

func (*Span) GetName

func (x *Span) GetName() string

func (*Span) GetParentSpanId

func (x *Span) GetParentSpanId() []byte

func (*Span) GetSpanId

func (x *Span) GetSpanId() []byte

func (*Span) GetStartTimeUnixNano

func (x *Span) GetStartTimeUnixNano() uint64

func (*Span) GetStatus

func (x *Span) GetStatus() *Status

func (*Span) GetTraceId

func (x *Span) GetTraceId() []byte

func (*Span) GetTraceState

func (x *Span) GetTraceState() string

func (*Span) ProtoMessage

func (*Span) ProtoMessage()

func (*Span) ProtoReflect

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

func (*Span) Reset

func (x *Span) Reset()

func (*Span) String

func (x *Span) String() string

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 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) Descriptor() ([]byte, []int)

Deprecated: Use Span_Link.ProtoReflect.Descriptor instead.

func (*Span_Link) GetAttributes

func (x *Span_Link) GetAttributes() []*KeyValue

func (*Span_Link) GetDroppedAttributesCount

func (x *Span_Link) GetDroppedAttributesCount() uint32

func (*Span_Link) GetSpanId

func (x *Span_Link) GetSpanId() []byte

func (*Span_Link) GetTraceId

func (x *Span_Link) GetTraceId() []byte

func (*Span_Link) GetTraceState

func (x *Span_Link) GetTraceState() string

func (*Span_Link) ProtoMessage

func (*Span_Link) ProtoMessage()

func (*Span_Link) ProtoReflect

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

func (*Span_Link) Reset

func (x *Span_Link) Reset()

func (*Span_Link) String

func (x *Span_Link) String() string

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) 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 (Span_SpanKind) String

func (x Span_SpanKind) String() string

func (Span_SpanKind) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode

func (x *Status) GetCode() Status_StatusCode

func (*Status) GetMessage

func (x *Status) GetMessage() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) ProtoReflect

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

func (*Status) Reset

func (x *Status) Reset()

func (*Status) String

func (x *Status) String() string

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) Enum

func (Status_StatusCode) EnumDescriptor deprecated

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

Deprecated: Use Status_StatusCode.Descriptor instead.

func (Status_StatusCode) Number

func (Status_StatusCode) String

func (x Status_StatusCode) String() string

func (Status_StatusCode) Type

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.

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) Descriptor() ([]byte, []int)

Deprecated: Use Sum.ProtoReflect.Descriptor instead.

func (*Sum) GetAggregationTemporality

func (x *Sum) GetAggregationTemporality() AggregationTemporality

func (*Sum) GetDataPoints

func (x *Sum) GetDataPoints() []*NumberDataPoint

func (*Sum) GetIsMonotonic

func (x *Sum) GetIsMonotonic() bool

func (*Sum) ProtoMessage

func (*Sum) ProtoMessage()

func (*Sum) ProtoReflect

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

func (*Sum) Reset

func (x *Sum) Reset()

func (*Sum) String

func (x *Sum) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Summary.ProtoReflect.Descriptor instead.

func (*Summary) GetDataPoints

func (x *Summary) GetDataPoints() []*SummaryDataPoint

func (*Summary) ProtoMessage

func (*Summary) ProtoMessage()

func (*Summary) ProtoReflect

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

func (*Summary) Reset

func (x *Summary) Reset()

func (*Summary) String

func (x *Summary) String() string

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 (*SummaryDataPoint_ValueAtQuantile) ProtoMessage

func (*SummaryDataPoint_ValueAtQuantile) ProtoMessage()

func (*SummaryDataPoint_ValueAtQuantile) ProtoReflect

func (*SummaryDataPoint_ValueAtQuantile) Reset

func (*SummaryDataPoint_ValueAtQuantile) 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.

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

type UnimplementedUnaryExporterServer

type UnimplementedUnaryExporterServer struct {
}

UnimplementedUnaryExporterServer must be embedded to have forward compatible implementations.

func (UnimplementedUnaryExporterServer) ExportTraces

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.

Jump to

Keyboard shortcuts

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