v1

package
v0.30.0 Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2024 License: Apache-2.0 Imports: 8 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	ArrowLogsService_ArrowLogs_FullMethodName = "/opentelemetry.proto.experimental.arrow.v1.ArrowLogsService/ArrowLogs"
)
View Source 
const (
	ArrowMetricsService_ArrowMetrics_FullMethodName = "/opentelemetry.proto.experimental.arrow.v1.ArrowMetricsService/ArrowMetrics"
)
View Source 
const (
	ArrowTracesService_ArrowTraces_FullMethodName = "/opentelemetry.proto.experimental.arrow.v1.ArrowTracesService/ArrowTraces"
)

Variables

View Source 
var (
	ArrowPayloadType_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "RESOURCE_ATTRS",
		2:  "SCOPE_ATTRS",
		10: "UNIVARIATE_METRICS",
		11: "NUMBER_DATA_POINTS",
		12: "SUMMARY_DATA_POINTS",
		13: "HISTOGRAM_DATA_POINTS",
		14: "EXP_HISTOGRAM_DATA_POINTS",
		15: "NUMBER_DP_ATTRS",
		16: "SUMMARY_DP_ATTRS",
		17: "HISTOGRAM_DP_ATTRS",
		18: "EXP_HISTOGRAM_DP_ATTRS",
		19: "NUMBER_DP_EXEMPLARS",
		20: "HISTOGRAM_DP_EXEMPLARS",
		21: "EXP_HISTOGRAM_DP_EXEMPLARS",
		22: "NUMBER_DP_EXEMPLAR_ATTRS",
		23: "HISTOGRAM_DP_EXEMPLAR_ATTRS",
		24: "EXP_HISTOGRAM_DP_EXEMPLAR_ATTRS",
		25: "MULTIVARIATE_METRICS",
		30: "LOGS",
		31: "LOG_ATTRS",
		40: "SPANS",
		41: "SPAN_ATTRS",
		42: "SPAN_EVENTS",
		43: "SPAN_LINKS",
		44: "SPAN_EVENT_ATTRS",
		45: "SPAN_LINK_ATTRS",
	}
	ArrowPayloadType_value = map[string]int32{
		"UNKNOWN":                         0,
		"RESOURCE_ATTRS":                  1,
		"SCOPE_ATTRS":                     2,
		"UNIVARIATE_METRICS":              10,
		"NUMBER_DATA_POINTS":              11,
		"SUMMARY_DATA_POINTS":             12,
		"HISTOGRAM_DATA_POINTS":           13,
		"EXP_HISTOGRAM_DATA_POINTS":       14,
		"NUMBER_DP_ATTRS":                 15,
		"SUMMARY_DP_ATTRS":                16,
		"HISTOGRAM_DP_ATTRS":              17,
		"EXP_HISTOGRAM_DP_ATTRS":          18,
		"NUMBER_DP_EXEMPLARS":             19,
		"HISTOGRAM_DP_EXEMPLARS":          20,
		"EXP_HISTOGRAM_DP_EXEMPLARS":      21,
		"NUMBER_DP_EXEMPLAR_ATTRS":        22,
		"HISTOGRAM_DP_EXEMPLAR_ATTRS":     23,
		"EXP_HISTOGRAM_DP_EXEMPLAR_ATTRS": 24,
		"MULTIVARIATE_METRICS":            25,
		"LOGS":                            30,
		"LOG_ATTRS":                       31,
		"SPANS":                           40,
		"SPAN_ATTRS":                      41,
		"SPAN_EVENTS":                     42,
		"SPAN_LINKS":                      43,
		"SPAN_EVENT_ATTRS":                44,
		"SPAN_LINK_ATTRS":                 45,
	}
)

Enum value maps for ArrowPayloadType.

View Source 
var (
	StatusCode_name = map[int32]string{
		0:  "OK",
		1:  "CANCELED",
		3:  "INVALID_ARGUMENT",
		4:  "DEADLINE_EXCEEDED",
		7:  "PERMISSION_DENIED",
		8:  "RESOURCE_EXHAUSTED",
		10: "ABORTED",
		13: "INTERNAL",
		14: "UNAVAILABLE",
		16: "UNAUTHENTICATED",
	}
	StatusCode_value = map[string]int32{
		"OK":                 0,
		"CANCELED":           1,
		"INVALID_ARGUMENT":   3,
		"DEADLINE_EXCEEDED":  4,
		"PERMISSION_DENIED":  7,
		"RESOURCE_EXHAUSTED": 8,
		"ABORTED":            10,
		"INTERNAL":           13,
		"UNAVAILABLE":        14,
		"UNAUTHENTICATED":    16,
	}
)

Enum value maps for StatusCode.

View Source 
var ArrowLogsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "opentelemetry.proto.experimental.arrow.v1.ArrowLogsService",
	HandlerType: (*ArrowLogsServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ArrowLogs",
			Handler:       _ArrowLogsService_ArrowLogs_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "opentelemetry/proto/experimental/arrow/v1/arrow_service.proto",
}

ArrowLogsService_ServiceDesc is the grpc.ServiceDesc for ArrowLogsService 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 ArrowMetricsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "opentelemetry.proto.experimental.arrow.v1.ArrowMetricsService",
	HandlerType: (*ArrowMetricsServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ArrowMetrics",
			Handler:       _ArrowMetricsService_ArrowMetrics_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "opentelemetry/proto/experimental/arrow/v1/arrow_service.proto",
}

ArrowMetricsService_ServiceDesc is the grpc.ServiceDesc for ArrowMetricsService 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 ArrowTracesService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "opentelemetry.proto.experimental.arrow.v1.ArrowTracesService",
	HandlerType: (*ArrowTracesServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ArrowTraces",
			Handler:       _ArrowTracesService_ArrowTraces_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "opentelemetry/proto/experimental/arrow/v1/arrow_service.proto",
}

ArrowTracesService_ServiceDesc is the grpc.ServiceDesc for ArrowTracesService 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 File_opentelemetry_proto_experimental_arrow_v1_arrow_service_proto protoreflect.FileDescriptor

Functions

func RegisterArrowLogsServiceServer 

func RegisterArrowLogsServiceServer(s grpc.ServiceRegistrar, srv ArrowLogsServiceServer)

func RegisterArrowMetricsServiceServer 

func RegisterArrowMetricsServiceServer(s grpc.ServiceRegistrar, srv ArrowMetricsServiceServer)

func RegisterArrowTracesServiceServer 

func RegisterArrowTracesServiceServer(s grpc.ServiceRegistrar, srv ArrowTracesServiceServer)

Types

type ArrowLogsServiceClient 

type ArrowLogsServiceClient interface {
	ArrowLogs(ctx context.Context, opts ...grpc.CallOption) (ArrowLogsService_ArrowLogsClient, error)
}

ArrowLogsServiceClient is the client API for ArrowLogsService 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 NewArrowLogsServiceClient 

func NewArrowLogsServiceClient(cc grpc.ClientConnInterface) ArrowLogsServiceClient

type ArrowLogsServiceServer 

type ArrowLogsServiceServer interface {
	ArrowLogs(ArrowLogsService_ArrowLogsServer) error
	// contains filtered or unexported methods
}

ArrowLogsServiceServer is the server API for ArrowLogsService service. All implementations must embed UnimplementedArrowLogsServiceServer for forward compatibility

type ArrowLogsService_ArrowLogsClient 

type ArrowLogsService_ArrowLogsClient interface {
	Send(*BatchArrowRecords) error
	Recv() (*BatchStatus, error)
	grpc.ClientStream
}

type ArrowLogsService_ArrowLogsServer 

type ArrowLogsService_ArrowLogsServer interface {
	Send(*BatchStatus) error
	Recv() (*BatchArrowRecords, error)
	grpc.ServerStream
}

type ArrowMetricsServiceClient 

type ArrowMetricsServiceClient interface {
	ArrowMetrics(ctx context.Context, opts ...grpc.CallOption) (ArrowMetricsService_ArrowMetricsClient, error)
}

ArrowMetricsServiceClient is the client API for ArrowMetricsService 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 NewArrowMetricsServiceClient 

func NewArrowMetricsServiceClient(cc grpc.ClientConnInterface) ArrowMetricsServiceClient

type ArrowMetricsServiceServer 

type ArrowMetricsServiceServer interface {
	ArrowMetrics(ArrowMetricsService_ArrowMetricsServer) error
	// contains filtered or unexported methods
}

ArrowMetricsServiceServer is the server API for ArrowMetricsService service. All implementations must embed UnimplementedArrowMetricsServiceServer for forward compatibility

type ArrowMetricsService_ArrowMetricsClient 

type ArrowMetricsService_ArrowMetricsClient interface {
	Send(*BatchArrowRecords) error
	Recv() (*BatchStatus, error)
	grpc.ClientStream
}

type ArrowMetricsService_ArrowMetricsServer 

type ArrowMetricsService_ArrowMetricsServer interface {
	Send(*BatchStatus) error
	Recv() (*BatchArrowRecords, error)
	grpc.ServerStream
}

type ArrowPayload 

type ArrowPayload struct {

	// [mandatory] A canonical ID representing the schema of the Arrow Record.
	// This ID is used on the consumer side to determine the IPC reader to use
	// for interpreting the corresponding record. For any NEW `schema_id`, the
	// consumer must:
	// 1) close the current IPC reader,
	// 2) create a new IPC reader in order to interpret the new schema,
	// dictionaries, and corresponding data.
	SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	// [mandatory] Type of the OTel Arrow payload.
	Type ArrowPayloadType `` /* 126-byte string literal not displayed */
	// [mandatory] Serialized Arrow Record Batch
	// For a description of the Arrow IPC format see:
	// https://arrow.apache.org/docs/format/Columnar.html#serialization-and-interprocess-communication-ipc
	Record []byte `protobuf:"bytes,3,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

Represents a batch of OTel Arrow entities.

func (*ArrowPayload) Descriptor deprecated 

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

Deprecated: Use ArrowPayload.ProtoReflect.Descriptor instead.

func (*ArrowPayload) GetRecord 

func (x *ArrowPayload) GetRecord() []byte

func (*ArrowPayload) GetSchemaId 

func (x *ArrowPayload) GetSchemaId() string

func (*ArrowPayload) GetType 

func (x *ArrowPayload) GetType() ArrowPayloadType

func (*ArrowPayload) ProtoMessage 

func (*ArrowPayload) ProtoMessage()

func (*ArrowPayload) ProtoReflect 

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

func (*ArrowPayload) Reset 

func (x *ArrowPayload) Reset()

func (*ArrowPayload) String 

func (x *ArrowPayload) String() string

type ArrowPayloadType 

type ArrowPayloadType int32

Enumeration of all the OTel Arrow payload types currently supported by the OTel Arrow protocol. 

const (
	ArrowPayloadType_UNKNOWN ArrowPayloadType = 0
	// A payload representing a collection of resource attributes.
	ArrowPayloadType_RESOURCE_ATTRS ArrowPayloadType = 1
	// A payload representing a collection of scope attributes.
	ArrowPayloadType_SCOPE_ATTRS ArrowPayloadType = 2
	// A set of payloads representing a collection of metrics.
	ArrowPayloadType_UNIVARIATE_METRICS              ArrowPayloadType = 10 // Univariate metric payload
	ArrowPayloadType_NUMBER_DATA_POINTS              ArrowPayloadType = 11
	ArrowPayloadType_SUMMARY_DATA_POINTS             ArrowPayloadType = 12
	ArrowPayloadType_HISTOGRAM_DATA_POINTS           ArrowPayloadType = 13
	ArrowPayloadType_EXP_HISTOGRAM_DATA_POINTS       ArrowPayloadType = 14
	ArrowPayloadType_NUMBER_DP_ATTRS                 ArrowPayloadType = 15
	ArrowPayloadType_SUMMARY_DP_ATTRS                ArrowPayloadType = 16
	ArrowPayloadType_HISTOGRAM_DP_ATTRS              ArrowPayloadType = 17
	ArrowPayloadType_EXP_HISTOGRAM_DP_ATTRS          ArrowPayloadType = 18
	ArrowPayloadType_NUMBER_DP_EXEMPLARS             ArrowPayloadType = 19
	ArrowPayloadType_HISTOGRAM_DP_EXEMPLARS          ArrowPayloadType = 20
	ArrowPayloadType_EXP_HISTOGRAM_DP_EXEMPLARS      ArrowPayloadType = 21
	ArrowPayloadType_NUMBER_DP_EXEMPLAR_ATTRS        ArrowPayloadType = 22
	ArrowPayloadType_HISTOGRAM_DP_EXEMPLAR_ATTRS     ArrowPayloadType = 23
	ArrowPayloadType_EXP_HISTOGRAM_DP_EXEMPLAR_ATTRS ArrowPayloadType = 24
	ArrowPayloadType_MULTIVARIATE_METRICS            ArrowPayloadType = 25 // Multivariate metric payload
	// A set of payloads representing a collection of logs.
	ArrowPayloadType_LOGS      ArrowPayloadType = 30
	ArrowPayloadType_LOG_ATTRS ArrowPayloadType = 31
	// A set of payloads representing a collection of traces.
	ArrowPayloadType_SPANS            ArrowPayloadType = 40
	ArrowPayloadType_SPAN_ATTRS       ArrowPayloadType = 41
	ArrowPayloadType_SPAN_EVENTS      ArrowPayloadType = 42
	ArrowPayloadType_SPAN_LINKS       ArrowPayloadType = 43
	ArrowPayloadType_SPAN_EVENT_ATTRS ArrowPayloadType = 44
	ArrowPayloadType_SPAN_LINK_ATTRS  ArrowPayloadType = 45
)

func (ArrowPayloadType) Descriptor 

func (ArrowPayloadType) Descriptor() protoreflect.EnumDescriptor

func (ArrowPayloadType) Enum 

func (x ArrowPayloadType) Enum() *ArrowPayloadType

func (ArrowPayloadType) EnumDescriptor deprecated 

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

Deprecated: Use ArrowPayloadType.Descriptor instead.

func (ArrowPayloadType) Number 

func (x ArrowPayloadType) Number() protoreflect.EnumNumber

func (ArrowPayloadType) String 

func (x ArrowPayloadType) String() string

func (ArrowPayloadType) Type 

func (ArrowPayloadType) Type() protoreflect.EnumType

type ArrowTracesServiceClient 

type ArrowTracesServiceClient interface {
	ArrowTraces(ctx context.Context, opts ...grpc.CallOption) (ArrowTracesService_ArrowTracesClient, error)
}

ArrowTracesServiceClient is the client API for ArrowTracesService 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 NewArrowTracesServiceClient 

func NewArrowTracesServiceClient(cc grpc.ClientConnInterface) ArrowTracesServiceClient

type ArrowTracesServiceServer 

type ArrowTracesServiceServer interface {
	ArrowTraces(ArrowTracesService_ArrowTracesServer) error
	// contains filtered or unexported methods
}

ArrowTracesServiceServer is the server API for ArrowTracesService service. All implementations must embed UnimplementedArrowTracesServiceServer for forward compatibility

type ArrowTracesService_ArrowTracesClient 

type ArrowTracesService_ArrowTracesClient interface {
	Send(*BatchArrowRecords) error
	Recv() (*BatchStatus, error)
	grpc.ClientStream
}

type ArrowTracesService_ArrowTracesServer 

type ArrowTracesService_ArrowTracesServer interface {
	Send(*BatchStatus) error
	Recv() (*BatchArrowRecords, error)
	grpc.ServerStream
}

type BatchArrowRecords 

type BatchArrowRecords struct {

	// [mandatory] Batch ID. Must be unique in the context of the stream.
	BatchId int64 `protobuf:"varint,1,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	// [mandatory] A collection of payloads containing the data of the batch.
	ArrowPayloads []*ArrowPayload `protobuf:"bytes,2,rep,name=arrow_payloads,json=arrowPayloads,proto3" json:"arrow_payloads,omitempty"`
	// [optional] Headers associated with this batch, encoded using hpack.
	Headers []byte `protobuf:"bytes,3,opt,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

A message sent by an exporter to a collector containing a batch of Arrow records.

func (*BatchArrowRecords) Descriptor deprecated 

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

Deprecated: Use BatchArrowRecords.ProtoReflect.Descriptor instead.

func (*BatchArrowRecords) GetArrowPayloads 

func (x *BatchArrowRecords) GetArrowPayloads() []*ArrowPayload

func (*BatchArrowRecords) GetBatchId 

func (x *BatchArrowRecords) GetBatchId() int64

func (*BatchArrowRecords) GetHeaders 

func (x *BatchArrowRecords) GetHeaders() []byte

func (*BatchArrowRecords) ProtoMessage 

func (*BatchArrowRecords) ProtoMessage()

func (*BatchArrowRecords) ProtoReflect 

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

func (*BatchArrowRecords) Reset 

func (x *BatchArrowRecords) Reset()

func (*BatchArrowRecords) String 

func (x *BatchArrowRecords) String() string

type BatchStatus 

type BatchStatus struct {
	BatchId       int64      `protobuf:"varint,1,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	StatusCode    StatusCode `` /* 150-byte string literal not displayed */
	StatusMessage string     `protobuf:"bytes,3,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	// contains filtered or unexported fields
}

A message sent by a Collector to the exporter that opened the data stream.

func (*BatchStatus) Descriptor deprecated 

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

Deprecated: Use BatchStatus.ProtoReflect.Descriptor instead.

func (*BatchStatus) GetBatchId 

func (x *BatchStatus) GetBatchId() int64

func (*BatchStatus) GetStatusCode 

func (x *BatchStatus) GetStatusCode() StatusCode

func (*BatchStatus) GetStatusMessage 

func (x *BatchStatus) GetStatusMessage() string

func (*BatchStatus) ProtoMessage 

func (*BatchStatus) ProtoMessage()

func (*BatchStatus) ProtoReflect 

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

func (*BatchStatus) Reset 

func (x *BatchStatus) Reset()

func (*BatchStatus) String 

func (x *BatchStatus) String() string

type StatusCode 

type StatusCode int32

StatusCode carries certain known meanings in Arrow. Values match the gRPC code space 

const (
	StatusCode_OK                 StatusCode = 0
	StatusCode_CANCELED           StatusCode = 1
	StatusCode_INVALID_ARGUMENT   StatusCode = 3
	StatusCode_DEADLINE_EXCEEDED  StatusCode = 4
	StatusCode_PERMISSION_DENIED  StatusCode = 7
	StatusCode_RESOURCE_EXHAUSTED StatusCode = 8
	StatusCode_ABORTED            StatusCode = 10
	StatusCode_INTERNAL           StatusCode = 13
	StatusCode_UNAVAILABLE        StatusCode = 14
	StatusCode_UNAUTHENTICATED    StatusCode = 16
)

func (StatusCode) Descriptor 

func (StatusCode) Descriptor() protoreflect.EnumDescriptor

func (StatusCode) Enum 

func (x StatusCode) Enum() *StatusCode

func (StatusCode) EnumDescriptor deprecated 

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

Deprecated: Use StatusCode.Descriptor instead.

func (StatusCode) Number 

func (x StatusCode) Number() protoreflect.EnumNumber

func (StatusCode) String 

func (x StatusCode) String() string

func (StatusCode) Type 

func (StatusCode) Type() protoreflect.EnumType

type UnimplementedArrowLogsServiceServer 

type UnimplementedArrowLogsServiceServer struct {
}

UnimplementedArrowLogsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedArrowLogsServiceServer) ArrowLogs 

func (UnimplementedArrowLogsServiceServer) ArrowLogs(ArrowLogsService_ArrowLogsServer) error

type UnimplementedArrowMetricsServiceServer 

type UnimplementedArrowMetricsServiceServer struct {
}

UnimplementedArrowMetricsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedArrowMetricsServiceServer) ArrowMetrics 

func (UnimplementedArrowMetricsServiceServer) ArrowMetrics(ArrowMetricsService_ArrowMetricsServer) error

type UnimplementedArrowTracesServiceServer 

type UnimplementedArrowTracesServiceServer struct {
}

UnimplementedArrowTracesServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedArrowTracesServiceServer) ArrowTraces 

func (UnimplementedArrowTracesServiceServer) ArrowTraces(ArrowTracesService_ArrowTracesServer) error

type UnsafeArrowLogsServiceServer 

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

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

type UnsafeArrowMetricsServiceServer 

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

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

type UnsafeArrowTracesServiceServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

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.