v1

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: 10 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 (
	ConstantSampler_ConstantDecision_name = map[int32]string{
		0: "ALWAYS_OFF",
		1: "ALWAYS_ON",
		2: "ALWAYS_PARENT",
	}
	ConstantSampler_ConstantDecision_value = map[string]int32{
		"ALWAYS_OFF":    0,
		"ALWAYS_ON":     1,
		"ALWAYS_PARENT": 2,
	}
)

Enum value maps for ConstantSampler_ConstantDecision.

View Source 
var File_collector_trace_v1_exchangee_proto protoreflect.FileDescriptor
View Source 
var File_collector_trace_v1_trace_service_proto protoreflect.FileDescriptor
View Source 
var File_collector_trace_v1_trace_service_stream_proto protoreflect.FileDescriptor
View Source 
var File_trace_v1_trace_config_proto protoreflect.FileDescriptor
View Source 
var StreamExporter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "experimental.collector.trace.v1.StreamExporter",
	HandlerType: (*StreamExporterServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExportTraces",
			Handler:       _StreamExporter_ExportTraces_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "collector/trace/v1/trace_service_stream.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 TraceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "experimental.collector.trace.v1.TraceService",
	HandlerType: (*TraceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Export",
			Handler:    _TraceService_Export_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "collector/trace/v1/trace_service.proto",
}

TraceService_ServiceDesc is the grpc.ServiceDesc for TraceService 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 RegisterTraceServiceServer 

func RegisterTraceServiceServer(s grpc.ServiceRegistrar, srv TraceServiceServer)

Types

type Capabilities 

type Capabilities int32
const (
	Capabilities_SKIP             Capabilities = 0
	Capabilities_ZLIB_COMPRESSION Capabilities = 1 // bit 0 of capabilities
	Capabilities_LZ4_COMPRESSION  Capabilities = 2 // bit 1 of capabilities
)

func (Capabilities) Descriptor 

func (Capabilities) Descriptor() protoreflect.EnumDescriptor

func (Capabilities) Enum 

func (x Capabilities) Enum() *Capabilities

func (Capabilities) EnumDescriptor deprecated 

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

Deprecated: Use Capabilities.Descriptor instead.

func (Capabilities) Number 

func (x Capabilities) Number() protoreflect.EnumNumber

func (Capabilities) String 

func (x Capabilities) String() string

func (Capabilities) Type 

func (Capabilities) Type() protoreflect.EnumType

type CompressionMethod 

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

func (CompressionMethod) Descriptor 

func (CompressionMethod) Descriptor() protoreflect.EnumDescriptor

func (CompressionMethod) Enum 

func (x CompressionMethod) Enum() *CompressionMethod

func (CompressionMethod) EnumDescriptor deprecated 

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

Deprecated: Use CompressionMethod.Descriptor instead.

func (CompressionMethod) Number 

func (x CompressionMethod) Number() protoreflect.EnumNumber

func (CompressionMethod) String 

func (x CompressionMethod) String() string

func (CompressionMethod) Type 

func (CompressionMethod) Type() protoreflect.EnumType

type ConstantSampler 

type ConstantSampler struct {
	Decision ConstantSampler_ConstantDecision `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

Sampler that always makes a constant decision on span sampling.

func (*ConstantSampler) Descriptor deprecated 

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

Deprecated: Use ConstantSampler.ProtoReflect.Descriptor instead.

func (*ConstantSampler) GetDecision 

func (x *ConstantSampler) GetDecision() ConstantSampler_ConstantDecision

func (*ConstantSampler) ProtoMessage 

func (*ConstantSampler) ProtoMessage()

func (*ConstantSampler) ProtoReflect 

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

func (*ConstantSampler) Reset 

func (x *ConstantSampler) Reset()

func (*ConstantSampler) String 

func (x *ConstantSampler) String() string

type ConstantSampler_ConstantDecision 

type ConstantSampler_ConstantDecision int32

How spans should be sampled: - Always off - Always on - Always follow the parent Span's decision (off if no parent). 

const (
	ConstantSampler_ALWAYS_OFF    ConstantSampler_ConstantDecision = 0
	ConstantSampler_ALWAYS_ON     ConstantSampler_ConstantDecision = 1
	ConstantSampler_ALWAYS_PARENT ConstantSampler_ConstantDecision = 2
)

func (ConstantSampler_ConstantDecision) Descriptor 

func (ConstantSampler_ConstantDecision) Descriptor() protoreflect.EnumDescriptor

func (ConstantSampler_ConstantDecision) Enum 

func (x ConstantSampler_ConstantDecision) Enum() *ConstantSampler_ConstantDecision

func (ConstantSampler_ConstantDecision) EnumDescriptor deprecated 

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

Deprecated: Use ConstantSampler_ConstantDecision.Descriptor instead.

func (ConstantSampler_ConstantDecision) Number 

func (x ConstantSampler_ConstantDecision) Number() protoreflect.EnumNumber

func (ConstantSampler_ConstantDecision) String 

func (x ConstantSampler_ConstantDecision) String() string

func (ConstantSampler_ConstantDecision) Type 

func (ConstantSampler_ConstantDecision) Type() protoreflect.EnumType

type ExportResponse 

type ExportResponse struct {

	// ID of a response that the server acknowledges.
	Id         uint64                    `protobuf:"varint,1,opt,name=id,json=i,proto3" json:"id,omitempty"`
	ResultCode ExportResponse_ResultCode `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

A response to ExportRequest.

func (*ExportResponse) Descriptor deprecated 

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

Deprecated: Use ExportResponse.ProtoReflect.Descriptor instead.

func (*ExportResponse) GetId 

func (x *ExportResponse) GetId() uint64

func (*ExportResponse) GetResultCode 

func (x *ExportResponse) GetResultCode() ExportResponse_ResultCode

func (*ExportResponse) ProtoMessage 

func (*ExportResponse) ProtoMessage()

func (*ExportResponse) ProtoReflect 

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

func (*ExportResponse) Reset 

func (x *ExportResponse) Reset()

func (*ExportResponse) String 

func (x *ExportResponse) String() string

type ExportResponse_ResultCode 

type ExportResponse_ResultCode int32
const (
	// Telemetry data is successfully processed by the server.
	ExportResponse_Success ExportResponse_ResultCode = 0
	// processing of telemetry data failed. The client MUST NOT retry
	// sending the same telemetry data. The telemetry data MUST be dropped.
	// This for example can happen when the request contains bad data and
	// cannot be deserialized or otherwise processed by the server.
	ExportResponse_FailedNoneRetryable ExportResponse_ResultCode = 1
	// Processing of telemetry data failed. The client SHOULD record the
	// error and MAY retry exporting the same data after some time. This
	// for example can happen when the server is overloaded.
	ExportResponse_FailedRetryable ExportResponse_ResultCode = 2
)

func (ExportResponse_ResultCode) Descriptor 

func (ExportResponse_ResultCode) Descriptor() protoreflect.EnumDescriptor

func (ExportResponse_ResultCode) Enum 

func (x ExportResponse_ResultCode) Enum() *ExportResponse_ResultCode

func (ExportResponse_ResultCode) EnumDescriptor deprecated 

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

Deprecated: Use ExportResponse_ResultCode.Descriptor instead.

func (ExportResponse_ResultCode) Number 

func (x ExportResponse_ResultCode) Number() protoreflect.EnumNumber

func (ExportResponse_ResultCode) String 

func (x ExportResponse_ResultCode) String() string

func (ExportResponse_ResultCode) Type 

func (ExportResponse_ResultCode) Type() protoreflect.EnumType

type ExportTracePartialSuccess 

type ExportTracePartialSuccess struct {

	// The number of rejected spans.
	//
	// A `rejected_<signal>` field holding a `0` value indicates that the
	// request was fully accepted.
	RejectedSpans int64 `protobuf:"varint,1,opt,name=rejected_spans,json=rejectedSpans,proto3" json:"rejected_spans,omitempty"`
	// A developer-facing human-readable message in English. It should be used
	// either to explain why the server rejected parts of the data during a partial
	// success or to convey warnings/suggestions during a full success. The message
	// should offer guidance on how users can address such issues.
	//
	// error_message is an optional field. An error_message with an empty value
	// is equivalent to it not being set.
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportTracePartialSuccess) Descriptor deprecated 

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

Deprecated: Use ExportTracePartialSuccess.ProtoReflect.Descriptor instead.

func (*ExportTracePartialSuccess) GetErrorMessage 

func (x *ExportTracePartialSuccess) GetErrorMessage() string

func (*ExportTracePartialSuccess) GetRejectedSpans 

func (x *ExportTracePartialSuccess) GetRejectedSpans() int64

func (*ExportTracePartialSuccess) ProtoMessage 

func (*ExportTracePartialSuccess) ProtoMessage()

func (*ExportTracePartialSuccess) ProtoReflect 

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

func (*ExportTracePartialSuccess) Reset 

func (x *ExportTracePartialSuccess) Reset()

func (*ExportTracePartialSuccess) String 

func (x *ExportTracePartialSuccess) String() string

type ExportTraceServiceRequest 

type ExportTraceServiceRequest 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.
	ResourceSpans []*v1.ResourceSpans `protobuf:"bytes,1,rep,name=resource_spans,json=resourceSpans,proto3" json:"resource_spans,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportTraceServiceRequest) Descriptor deprecated 

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

Deprecated: Use ExportTraceServiceRequest.ProtoReflect.Descriptor instead.

func (*ExportTraceServiceRequest) GetResourceSpans 

func (x *ExportTraceServiceRequest) GetResourceSpans() []*v1.ResourceSpans

func (*ExportTraceServiceRequest) ProtoMessage 

func (*ExportTraceServiceRequest) ProtoMessage()

func (*ExportTraceServiceRequest) ProtoReflect 

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

func (*ExportTraceServiceRequest) Reset 

func (x *ExportTraceServiceRequest) Reset()

func (*ExportTraceServiceRequest) String 

func (x *ExportTraceServiceRequest) String() string

type ExportTraceServiceResponse 

type ExportTraceServiceResponse struct {

	// The details of a partially successful export request.
	//
	// If the request is only partially accepted
	// (i.e. when the server accepts only parts of the data and rejects the rest)
	// the server MUST initialize the `partial_success` field and MUST
	// set the `rejected_<signal>` with the number of items it rejected.
	//
	// Servers MAY also make use of the `partial_success` field to convey
	// warnings/suggestions to senders even when the request was fully accepted.
	// In such cases, the `rejected_<signal>` MUST have a value of `0` and
	// the `error_message` MUST be non-empty.
	//
	// A `partial_success` message with an empty value (rejected_<signal> = 0 and
	// `error_message` = "") is equivalent to it not being set/present. Senders
	// SHOULD interpret it the same way as in the full success case.
	PartialSuccess *ExportTracePartialSuccess `protobuf:"bytes,1,opt,name=partial_success,json=partialSuccess,proto3" json:"partial_success,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportTraceServiceResponse) Descriptor deprecated 

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

Deprecated: Use ExportTraceServiceResponse.ProtoReflect.Descriptor instead.

func (*ExportTraceServiceResponse) GetPartialSuccess 

func (x *ExportTraceServiceResponse) GetPartialSuccess() *ExportTracePartialSuccess

func (*ExportTraceServiceResponse) ProtoMessage 

func (*ExportTraceServiceResponse) ProtoMessage()

func (*ExportTraceServiceResponse) ProtoReflect 

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

func (*ExportTraceServiceResponse) Reset 

func (x *ExportTraceServiceResponse) Reset()

func (*ExportTraceServiceResponse) String 

func (x *ExportTraceServiceResponse) String() string

type MetricExportRequest 

type MetricExportRequest struct {

	// Unique sequential ID generated by the client.
	Id uint64 `protobuf:"varint,1,opt,name=id,json=i,proto3" json:"id,omitempty"`
	// Telemetry data. An array of ResourceMetrics.
	ResourceMetrics []*v11.ResourceMetrics `protobuf:"bytes,2,rep,name=resourceMetrics,json=r,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() []*v11.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 RateLimitingSampler 

type RateLimitingSampler struct {

	// Rate per second.
	Qps int64 `protobuf:"varint,1,opt,name=qps,proto3" json:"qps,omitempty"`
	// contains filtered or unexported fields
}

Sampler that tries to sample with a rate per time window.

func (*RateLimitingSampler) Descriptor deprecated 

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

Deprecated: Use RateLimitingSampler.ProtoReflect.Descriptor instead.

func (*RateLimitingSampler) GetQps 

func (x *RateLimitingSampler) GetQps() int64

func (*RateLimitingSampler) ProtoMessage 

func (*RateLimitingSampler) ProtoMessage()

func (*RateLimitingSampler) ProtoReflect 

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

func (*RateLimitingSampler) Reset 

func (x *RateLimitingSampler) Reset()

func (*RateLimitingSampler) String 

func (x *RateLimitingSampler) String() string

type RequestBody 

type RequestBody struct {
	RequestType RequestType         `` /* 144-byte string literal not displayed */
	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 `` /* 131-byte string literal not displayed */
	// Compression level as defined by the compression method.
	CompressionLevel int32 `protobuf:"varint,2,opt,name=compression_level,json=compressionLevel,proto3" json:"compression_level,omitempty"`
	// contains filtered or unexported fields
}

RequestHeader is used by transports that unlike gRPC don't have built-in request compression such as WebSocket. Request body typically follows the header.

func (*RequestHeader) Descriptor deprecated 

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

Deprecated: Use RequestHeader.ProtoReflect.Descriptor instead.

func (*RequestHeader) GetCompression 

func (x *RequestHeader) GetCompression() CompressionMethod

func (*RequestHeader) GetCompressionLevel 

func (x *RequestHeader) GetCompressionLevel() int32

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) ProtoReflect 

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

func (*RequestHeader) Reset 

func (x *RequestHeader) Reset()

func (*RequestHeader) String 

func (x *RequestHeader) String() string

type RequestType 

type RequestType int32
const (
	RequestType__           RequestType = 0
	RequestType_TraceExport RequestType = 1
)

func (RequestType) Descriptor 

func (RequestType) Descriptor() protoreflect.EnumDescriptor

func (RequestType) Enum 

func (x RequestType) Enum() *RequestType

func (RequestType) EnumDescriptor deprecated 

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

Deprecated: Use RequestType.Descriptor instead.

func (RequestType) Number 

func (x RequestType) Number() protoreflect.EnumNumber

func (RequestType) String 

func (x RequestType) String() string

func (RequestType) Type 

func (RequestType) Type() protoreflect.EnumType

type Response 

type Response struct {
	ResponseType RequestType     `` /* 147-byte string literal not displayed */
	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 StreamExporterClient 

type StreamExporterClient interface {
	ExportTraces(ctx context.Context, opts ...grpc.CallOption) (StreamExporter_ExportTracesClient, error)
}

StreamExporterClient is the client API for StreamExporter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStreamExporterClient 

func NewStreamExporterClient(cc grpc.ClientConnInterface) StreamExporterClient

type StreamExporterServer 

type StreamExporterServer interface {
	ExportTraces(StreamExporter_ExportTracesServer) error
	// contains filtered or unexported methods
}

StreamExporterServer is the server API for StreamExporter service. All implementations must embed UnimplementedStreamExporterServer for forward compatibility

type StreamExporter_ExportTracesClient 

type StreamExporter_ExportTracesClient interface {
	Send(*TraceExportRequest) error
	Recv() (*ExportResponse, error)
	grpc.ClientStream
}

type StreamExporter_ExportTracesServer 

type StreamExporter_ExportTracesServer interface {
	Send(*ExportResponse) error
	Recv() (*TraceExportRequest, error)
	grpc.ServerStream
}

type TraceConfig 

type TraceConfig struct {

	// The global default sampler used to make decisions on span sampling.
	//
	// Types that are assignable to Sampler:
	//	*TraceConfig_ConstantSampler
	//	*TraceConfig_TraceIdRatioBased
	//	*TraceConfig_RateLimitingSampler
	Sampler isTraceConfig_Sampler `protobuf_oneof:"sampler"`
	// The global default max number of attributes per span.
	MaxNumberOfAttributes int64 `` /* 129-byte string literal not displayed */
	// The global default max number of annotation events per span.
	MaxNumberOfTimedEvents int64 `` /* 134-byte string literal not displayed */
	// The global default max number of attributes per timed event.
	MaxNumberOfAttributesPerTimedEvent int64 `` /* 174-byte string literal not displayed */
	// The global default max number of link entries per span.
	MaxNumberOfLinks int64 `protobuf:"varint,7,opt,name=max_number_of_links,json=maxNumberOfLinks,proto3" json:"max_number_of_links,omitempty"`
	// The global default max number of attributes per span.
	MaxNumberOfAttributesPerLink int64 `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

Global configuration of the trace service. All fields must be specified, or the default (zero) values will be used for each type.

func (*TraceConfig) Descriptor deprecated 

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

Deprecated: Use TraceConfig.ProtoReflect.Descriptor instead.

func (*TraceConfig) GetConstantSampler 

func (x *TraceConfig) GetConstantSampler() *ConstantSampler

func (*TraceConfig) GetMaxNumberOfAttributes 

func (x *TraceConfig) GetMaxNumberOfAttributes() int64
func (x *TraceConfig) GetMaxNumberOfAttributesPerLink() int64

func (*TraceConfig) GetMaxNumberOfAttributesPerTimedEvent 

func (x *TraceConfig) GetMaxNumberOfAttributesPerTimedEvent() int64
func (x *TraceConfig) GetMaxNumberOfLinks() int64

func (*TraceConfig) GetMaxNumberOfTimedEvents 

func (x *TraceConfig) GetMaxNumberOfTimedEvents() int64

func (*TraceConfig) GetRateLimitingSampler 

func (x *TraceConfig) GetRateLimitingSampler() *RateLimitingSampler

func (*TraceConfig) GetSampler 

func (m *TraceConfig) GetSampler() isTraceConfig_Sampler

func (*TraceConfig) GetTraceIdRatioBased 

func (x *TraceConfig) GetTraceIdRatioBased() *TraceIdRatioBased

func (*TraceConfig) ProtoMessage 

func (*TraceConfig) ProtoMessage()

func (*TraceConfig) ProtoReflect 

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

func (*TraceConfig) Reset 

func (x *TraceConfig) Reset()

func (*TraceConfig) String 

func (x *TraceConfig) String() string

type TraceConfig_ConstantSampler 

type TraceConfig_ConstantSampler struct {
	ConstantSampler *ConstantSampler `protobuf:"bytes,1,opt,name=constant_sampler,json=constantSampler,proto3,oneof"`
}

type TraceConfig_RateLimitingSampler 

type TraceConfig_RateLimitingSampler struct {
	RateLimitingSampler *RateLimitingSampler `protobuf:"bytes,3,opt,name=rate_limiting_sampler,json=rateLimitingSampler,proto3,oneof"`
}

type TraceConfig_TraceIdRatioBased 

type TraceConfig_TraceIdRatioBased struct {
	TraceIdRatioBased *TraceIdRatioBased `protobuf:"bytes,2,opt,name=trace_id_ratio_based,json=traceIdRatioBased,proto3,oneof"`
}

type TraceExportRequest 

type TraceExportRequest struct {

	// Unique sequential ID generated by the client.
	Id uint64 `protobuf:"varint,1,opt,name=id,json=i,proto3" json:"id,omitempty"`
	// Telemetry data. An array of ResourceSpans.
	ResourceSpans []*v1.ResourceSpans `protobuf:"bytes,2,rep,name=resourceSpans,json=r,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() []*v1.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 TraceIdRatioBased 

type TraceIdRatioBased struct {

	// The desired ratio of sampling. Must be within [0.0, 1.0].
	SamplingRatio float64 `protobuf:"fixed64,1,opt,name=samplingRatio,proto3" json:"samplingRatio,omitempty"`
	// contains filtered or unexported fields
}

Sampler that tries to uniformly sample traces with a given ratio. The ratio of sampling a trace is equal to that of the specified ratio.

func (*TraceIdRatioBased) Descriptor deprecated 

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

Deprecated: Use TraceIdRatioBased.ProtoReflect.Descriptor instead.

func (*TraceIdRatioBased) GetSamplingRatio 

func (x *TraceIdRatioBased) GetSamplingRatio() float64

func (*TraceIdRatioBased) ProtoMessage 

func (*TraceIdRatioBased) ProtoMessage()

func (*TraceIdRatioBased) ProtoReflect 

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

func (*TraceIdRatioBased) Reset 

func (x *TraceIdRatioBased) Reset()

func (*TraceIdRatioBased) String 

func (x *TraceIdRatioBased) String() string

type TraceServiceClient 

type TraceServiceClient interface {
	// For performance reasons, it is recommended to keep this RPC
	// alive for the entire life of the application.
	Export(ctx context.Context, in *ExportTraceServiceRequest, opts ...grpc.CallOption) (*ExportTraceServiceResponse, error)
}

TraceServiceClient is the client API for TraceService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTraceServiceClient 

func NewTraceServiceClient(cc grpc.ClientConnInterface) TraceServiceClient

type TraceServiceServer 

type TraceServiceServer interface {
	// For performance reasons, it is recommended to keep this RPC
	// alive for the entire life of the application.
	Export(context.Context, *ExportTraceServiceRequest) (*ExportTraceServiceResponse, error)
	// contains filtered or unexported methods
}

TraceServiceServer is the server API for TraceService service. All implementations must embed UnimplementedTraceServiceServer for forward compatibility

type UnimplementedStreamExporterServer 

type UnimplementedStreamExporterServer struct {
}

UnimplementedStreamExporterServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamExporterServer) ExportTraces 

func (UnimplementedStreamExporterServer) ExportTraces(StreamExporter_ExportTracesServer) error

type UnimplementedTraceServiceServer 

type UnimplementedTraceServiceServer struct {
}

UnimplementedTraceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTraceServiceServer) Export 

func (UnimplementedTraceServiceServer) Export(context.Context, *ExportTraceServiceRequest) (*ExportTraceServiceResponse, error)

type UnsafeStreamExporterServer 

type UnsafeStreamExporterServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamExporterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamExporterServer will result in compilation errors.

type UnsafeTraceServiceServer 

type UnsafeTraceServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTraceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TraceServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.