Documentation ¶
Index ¶
- Variables
- func RegisterArrowLogsServiceServer(s grpc.ServiceRegistrar, srv ArrowLogsServiceServer)
- func RegisterArrowMetricsServiceServer(s grpc.ServiceRegistrar, srv ArrowMetricsServiceServer)
- func RegisterArrowStreamServiceServer(s grpc.ServiceRegistrar, srv ArrowStreamServiceServer)
- func RegisterArrowTracesServiceServer(s grpc.ServiceRegistrar, srv ArrowTracesServiceServer)
- type ArrowLogsServiceClient
- type ArrowLogsServiceServer
- type ArrowLogsService_ArrowLogsClient
- type ArrowLogsService_ArrowLogsServer
- type ArrowMetricsServiceClient
- type ArrowMetricsServiceServer
- type ArrowMetricsService_ArrowMetricsClient
- type ArrowMetricsService_ArrowMetricsServer
- type ArrowPayload
- func (*ArrowPayload) Descriptor() ([]byte, []int)deprecated
- func (x *ArrowPayload) GetRecord() []byte
- func (x *ArrowPayload) GetSchemaId() string
- func (x *ArrowPayload) GetType() ArrowPayloadType
- func (*ArrowPayload) ProtoMessage()
- func (x *ArrowPayload) ProtoReflect() protoreflect.Message
- func (x *ArrowPayload) Reset()
- func (x *ArrowPayload) String() string
- type ArrowPayloadType
- func (ArrowPayloadType) Descriptor() protoreflect.EnumDescriptor
- func (x ArrowPayloadType) Enum() *ArrowPayloadType
- func (ArrowPayloadType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ArrowPayloadType) Number() protoreflect.EnumNumber
- func (x ArrowPayloadType) String() string
- func (ArrowPayloadType) Type() protoreflect.EnumType
- type ArrowStreamServiceClient
- type ArrowStreamServiceServer
- type ArrowStreamService_ArrowStreamClient
- type ArrowStreamService_ArrowStreamServer
- type ArrowTracesServiceClient
- type ArrowTracesServiceServer
- type ArrowTracesService_ArrowTracesClient
- type ArrowTracesService_ArrowTracesServer
- type BatchArrowRecords
- func (*BatchArrowRecords) Descriptor() ([]byte, []int)deprecated
- func (x *BatchArrowRecords) GetArrowPayloads() []*ArrowPayload
- func (x *BatchArrowRecords) GetBatchId() int64
- func (x *BatchArrowRecords) GetHeaders() []byte
- func (*BatchArrowRecords) ProtoMessage()
- func (x *BatchArrowRecords) ProtoReflect() protoreflect.Message
- func (x *BatchArrowRecords) Reset()
- func (x *BatchArrowRecords) String() string
- type BatchStatus
- func (*BatchStatus) Descriptor() ([]byte, []int)deprecated
- func (x *BatchStatus) GetBatchId() int64
- func (x *BatchStatus) GetStatusCode() StatusCode
- func (x *BatchStatus) GetStatusMessage() string
- func (*BatchStatus) ProtoMessage()
- func (x *BatchStatus) ProtoReflect() protoreflect.Message
- func (x *BatchStatus) Reset()
- func (x *BatchStatus) String() string
- type StatusCode
- type UnimplementedArrowLogsServiceServer
- type UnimplementedArrowMetricsServiceServer
- type UnimplementedArrowStreamServiceServer
- type UnimplementedArrowTracesServiceServer
- type UnsafeArrowLogsServiceServer
- type UnsafeArrowMetricsServiceServer
- type UnsafeArrowStreamServiceServer
- type UnsafeArrowTracesServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( ArrowPayloadType_name = map[int32]string{ 0: "UNKNOWN", 1: "RESOURCE_ATTRS", 2: "SCOPE_ATTRS", 10: "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", 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, "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, "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.
var ( StatusCode_name = map[int32]string{ 0: "OK", 1: "UNAVAILABLE", 2: "INVALID_ARGUMENT", } StatusCode_value = map[string]int32{ "OK": 0, "UNAVAILABLE": 1, "INVALID_ARGUMENT": 2, } )
Enum value maps for StatusCode.
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)
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)
var ArrowStreamService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "opentelemetry.proto.experimental.arrow.v1.ArrowStreamService", HandlerType: (*ArrowStreamServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "ArrowStream", Handler: _ArrowStreamService_ArrowStream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "opentelemetry/proto/experimental/arrow/v1/arrow_service.proto", }
ArrowStreamService_ServiceDesc is the grpc.ServiceDesc for ArrowStreamService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
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)
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 RegisterArrowStreamServiceServer ¶
func RegisterArrowStreamServiceServer(s grpc.ServiceRegistrar, srv ArrowStreamServiceServer)
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_METRICS ArrowPayloadType = 10 // Main 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 // 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 ArrowStreamServiceClient ¶
type ArrowStreamServiceClient interface { // The ArrowStream endpoint is a bi-directional stream used to send batch of // `BatchArrowRecords` from the exporter to the collector. The collector // returns `BatchStatus` messages to acknowledge the `BatchArrowRecords` // messages received. ArrowStream(ctx context.Context, opts ...grpc.CallOption) (ArrowStreamService_ArrowStreamClient, error) }
ArrowStreamServiceClient is the client API for ArrowStreamService 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 NewArrowStreamServiceClient ¶
func NewArrowStreamServiceClient(cc grpc.ClientConnInterface) ArrowStreamServiceClient
type ArrowStreamServiceServer ¶
type ArrowStreamServiceServer interface { // The ArrowStream endpoint is a bi-directional stream used to send batch of // `BatchArrowRecords` from the exporter to the collector. The collector // returns `BatchStatus` messages to acknowledge the `BatchArrowRecords` // messages received. ArrowStream(ArrowStreamService_ArrowStreamServer) error // contains filtered or unexported methods }
ArrowStreamServiceServer is the server API for ArrowStreamService service. All implementations must embed UnimplementedArrowStreamServiceServer for forward compatibility
type ArrowStreamService_ArrowStreamClient ¶
type ArrowStreamService_ArrowStreamClient interface { Send(*BatchArrowRecords) error Recv() (*BatchStatus, error) grpc.ClientStream }
type ArrowStreamService_ArrowStreamServer ¶
type ArrowStreamService_ArrowStreamServer interface { Send(*BatchStatus) error Recv() (*BatchArrowRecords, error) grpc.ServerStream }
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
const ( StatusCode_OK StatusCode = 0 StatusCode_UNAVAILABLE StatusCode = 1 StatusCode_INVALID_ARGUMENT StatusCode = 2 )
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 UnimplementedArrowStreamServiceServer ¶
type UnimplementedArrowStreamServiceServer struct { }
UnimplementedArrowStreamServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedArrowStreamServiceServer) ArrowStream ¶
func (UnimplementedArrowStreamServiceServer) ArrowStream(ArrowStreamService_ArrowStreamServer) 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 UnsafeArrowStreamServiceServer ¶
type UnsafeArrowStreamServiceServer interface {
// contains filtered or unexported methods
}
UnsafeArrowStreamServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ArrowStreamServiceServer 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.