Documentation ¶
Index ¶
- Variables
- func RegisterStorageServiceServer(s grpc.ServiceRegistrar, srv StorageServiceServer)
- type ArrowPayload
- func (*ArrowPayload) Descriptor() ([]byte, []int)deprecated
- func (x *ArrowPayload) GetCompression() ArrowPayload_Compression
- func (x *ArrowPayload) GetRecordBatches() [][]byte
- func (*ArrowPayload) ProtoMessage()
- func (x *ArrowPayload) ProtoReflect() protoreflect.Message
- func (x *ArrowPayload) Reset()
- func (x *ArrowPayload) String() string
- type ArrowPayload_Compression
- func (ArrowPayload_Compression) Descriptor() protoreflect.EnumDescriptor
- func (x ArrowPayload_Compression) Enum() *ArrowPayload_Compression
- func (ArrowPayload_Compression) EnumDescriptor() ([]byte, []int)deprecated
- func (x ArrowPayload_Compression) Number() protoreflect.EnumNumber
- func (x ArrowPayload_Compression) String() string
- func (ArrowPayload_Compression) Type() protoreflect.EnumType
- type Endpoint
- type Field
- type FieldGroup
- type PrometheusQueryRequest
- func (*PrometheusQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PrometheusQueryRequest) GetContext() *RequestContext
- func (x *PrometheusQueryRequest) GetDelta() int64
- func (x *PrometheusQueryRequest) GetExpr() *ceresprompb.Expr
- func (m *PrometheusQueryRequest) GetLookbackDelta() isPrometheusQueryRequest_LookbackDelta
- func (*PrometheusQueryRequest) ProtoMessage()
- func (x *PrometheusQueryRequest) ProtoReflect() protoreflect.Message
- func (x *PrometheusQueryRequest) Reset()
- func (x *PrometheusQueryRequest) String() string
- type PrometheusQueryRequest_Delta
- type PrometheusQueryResponse
- func (*PrometheusQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PrometheusQueryResponse) GetHeader() *commonpb.ResponseHeader
- func (x *PrometheusQueryResponse) GetTimeseries() []*ceresprompb.TimeSeries
- func (*PrometheusQueryResponse) ProtoMessage()
- func (x *PrometheusQueryResponse) ProtoReflect() protoreflect.Message
- func (x *PrometheusQueryResponse) Reset()
- func (x *PrometheusQueryResponse) String() string
- type PrometheusRemoteQueryRequest
- func (*PrometheusRemoteQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PrometheusRemoteQueryRequest) GetContext() *RequestContext
- func (x *PrometheusRemoteQueryRequest) GetQuery() []byte
- func (*PrometheusRemoteQueryRequest) ProtoMessage()
- func (x *PrometheusRemoteQueryRequest) ProtoReflect() protoreflect.Message
- func (x *PrometheusRemoteQueryRequest) Reset()
- func (x *PrometheusRemoteQueryRequest) String() string
- type PrometheusRemoteQueryResponse
- func (*PrometheusRemoteQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PrometheusRemoteQueryResponse) GetHeader() *commonpb.ResponseHeader
- func (x *PrometheusRemoteQueryResponse) GetResponse() []byte
- func (*PrometheusRemoteQueryResponse) ProtoMessage()
- func (x *PrometheusRemoteQueryResponse) ProtoReflect() protoreflect.Message
- func (x *PrometheusRemoteQueryResponse) Reset()
- func (x *PrometheusRemoteQueryResponse) String() string
- type RequestContext
- type Route
- type RouteRequest
- func (*RouteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RouteRequest) GetContext() *RequestContext
- func (x *RouteRequest) GetTables() []string
- func (*RouteRequest) ProtoMessage()
- func (x *RouteRequest) ProtoReflect() protoreflect.Message
- func (x *RouteRequest) Reset()
- func (x *RouteRequest) String() string
- type RouteResponse
- func (*RouteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RouteResponse) GetHeader() *commonpb.ResponseHeader
- func (x *RouteResponse) GetRoutes() []*Route
- func (*RouteResponse) ProtoMessage()
- func (x *RouteResponse) ProtoReflect() protoreflect.Message
- func (x *RouteResponse) Reset()
- func (x *RouteResponse) String() string
- type SqlQueryRequest
- func (*SqlQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SqlQueryRequest) GetContext() *RequestContext
- func (x *SqlQueryRequest) GetSql() string
- func (x *SqlQueryRequest) GetTables() []string
- func (*SqlQueryRequest) ProtoMessage()
- func (x *SqlQueryRequest) ProtoReflect() protoreflect.Message
- func (x *SqlQueryRequest) Reset()
- func (x *SqlQueryRequest) String() string
- type SqlQueryResponse
- func (*SqlQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SqlQueryResponse) GetAffectedRows() uint32
- func (x *SqlQueryResponse) GetArrow() *ArrowPayload
- func (x *SqlQueryResponse) GetHeader() *commonpb.ResponseHeader
- func (m *SqlQueryResponse) GetOutput() isSqlQueryResponse_Output
- func (*SqlQueryResponse) ProtoMessage()
- func (x *SqlQueryResponse) ProtoReflect() protoreflect.Message
- func (x *SqlQueryResponse) Reset()
- func (x *SqlQueryResponse) String() string
- type SqlQueryResponse_AffectedRows
- type SqlQueryResponse_Arrow
- type StorageServiceClient
- type StorageServiceServer
- type StorageService_StreamSqlQueryClient
- type StorageService_StreamSqlQueryServer
- type StorageService_StreamWriteClient
- type StorageService_StreamWriteServer
- type Tag
- type UnimplementedStorageServiceServer
- func (UnimplementedStorageServiceServer) PromQuery(context.Context, *PrometheusQueryRequest) (*PrometheusQueryResponse, error)
- func (UnimplementedStorageServiceServer) PromRemoteQuery(context.Context, *PrometheusRemoteQueryRequest) (*PrometheusRemoteQueryResponse, error)
- func (UnimplementedStorageServiceServer) Route(context.Context, *RouteRequest) (*RouteResponse, error)
- func (UnimplementedStorageServiceServer) SqlQuery(context.Context, *SqlQueryRequest) (*SqlQueryResponse, error)
- func (UnimplementedStorageServiceServer) StreamSqlQuery(*SqlQueryRequest, StorageService_StreamSqlQueryServer) error
- func (UnimplementedStorageServiceServer) StreamWrite(StorageService_StreamWriteServer) error
- func (UnimplementedStorageServiceServer) Write(context.Context, *WriteRequest) (*WriteResponse, error)
- type UnsafeStorageServiceServer
- type Value
- func (*Value) Descriptor() ([]byte, []int)deprecated
- func (x *Value) GetBoolValue() bool
- func (x *Value) GetFloat32Value() float32
- func (x *Value) GetFloat64Value() float64
- func (x *Value) GetInt16Value() int32
- func (x *Value) GetInt32Value() int32
- func (x *Value) GetInt64Value() int64
- func (x *Value) GetInt8Value() int32
- func (x *Value) GetStringValue() string
- func (x *Value) GetTimestampValue() int64
- func (x *Value) GetUint16Value() uint32
- func (x *Value) GetUint32Value() uint32
- func (x *Value) GetUint64Value() uint64
- func (x *Value) GetUint8Value() uint32
- func (m *Value) GetValue() isValue_Value
- func (x *Value) GetVarbinaryValue() []byte
- func (*Value) ProtoMessage()
- func (x *Value) ProtoReflect() protoreflect.Message
- func (x *Value) Reset()
- func (x *Value) String() string
- type Value_BoolValue
- type Value_Float32Value
- type Value_Float64Value
- type Value_Int16Value
- type Value_Int32Value
- type Value_Int64Value
- type Value_Int8Value
- type Value_StringValue
- type Value_TimestampValue
- type Value_Uint16Value
- type Value_Uint32Value
- type Value_Uint64Value
- type Value_Uint8Value
- type Value_VarbinaryValue
- type WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteRequest) GetContext() *RequestContext
- func (x *WriteRequest) GetTableRequests() []*WriteTableRequest
- func (*WriteRequest) ProtoMessage()
- func (x *WriteRequest) ProtoReflect() protoreflect.Message
- func (x *WriteRequest) Reset()
- func (x *WriteRequest) String() string
- type WriteResponse
- func (*WriteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WriteResponse) GetFailed() uint32
- func (x *WriteResponse) GetHeader() *commonpb.ResponseHeader
- func (x *WriteResponse) GetSuccess() uint32
- func (*WriteResponse) ProtoMessage()
- func (x *WriteResponse) ProtoReflect() protoreflect.Message
- func (x *WriteResponse) Reset()
- func (x *WriteResponse) String() string
- type WriteSeriesEntry
- func (*WriteSeriesEntry) Descriptor() ([]byte, []int)deprecated
- func (x *WriteSeriesEntry) GetFieldGroups() []*FieldGroup
- func (x *WriteSeriesEntry) GetTags() []*Tag
- func (*WriteSeriesEntry) ProtoMessage()
- func (x *WriteSeriesEntry) ProtoReflect() protoreflect.Message
- func (x *WriteSeriesEntry) Reset()
- func (x *WriteSeriesEntry) String() string
- type WriteTableRequest
- func (*WriteTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteTableRequest) GetEntries() []*WriteSeriesEntry
- func (x *WriteTableRequest) GetFieldNames() []string
- func (x *WriteTableRequest) GetTable() string
- func (x *WriteTableRequest) GetTagNames() []string
- func (*WriteTableRequest) ProtoMessage()
- func (x *WriteTableRequest) ProtoReflect() protoreflect.Message
- func (x *WriteTableRequest) Reset()
- func (x *WriteTableRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var ( ArrowPayload_Compression_name = map[int32]string{ 0: "NONE", 1: "ZSTD", } ArrowPayload_Compression_value = map[string]int32{ "NONE": 0, "ZSTD": 1, } )
Enum value maps for ArrowPayload_Compression.
var File_storage_proto protoreflect.FileDescriptor
var StorageService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "storage.StorageService", HandlerType: (*StorageServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Route", Handler: _StorageService_Route_Handler, }, { MethodName: "Write", Handler: _StorageService_Write_Handler, }, { MethodName: "SqlQuery", Handler: _StorageService_SqlQuery_Handler, }, { MethodName: "PromRemoteQuery", Handler: _StorageService_PromRemoteQuery_Handler, }, { MethodName: "PromQuery", Handler: _StorageService_PromQuery_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamWrite", Handler: _StorageService_StreamWrite_Handler, ClientStreams: true, }, { StreamName: "StreamSqlQuery", Handler: _StorageService_StreamSqlQuery_Handler, ServerStreams: true, }, }, Metadata: "storage.proto", }
StorageService_ServiceDesc is the grpc.ServiceDesc for StorageService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterStorageServiceServer ¶
func RegisterStorageServiceServer(s grpc.ServiceRegistrar, srv StorageServiceServer)
Types ¶
type ArrowPayload ¶
type ArrowPayload struct { RecordBatches [][]byte `protobuf:"bytes,1,rep,name=record_batches,json=recordBatches,proto3" json:"record_batches,omitempty"` Compression ArrowPayload_Compression `protobuf:"varint,2,opt,name=compression,proto3,enum=storage.ArrowPayload_Compression" json:"compression,omitempty"` // contains filtered or unexported fields }
func (*ArrowPayload) Descriptor
deprecated
func (*ArrowPayload) Descriptor() ([]byte, []int)
Deprecated: Use ArrowPayload.ProtoReflect.Descriptor instead.
func (*ArrowPayload) GetCompression ¶
func (x *ArrowPayload) GetCompression() ArrowPayload_Compression
func (*ArrowPayload) GetRecordBatches ¶
func (x *ArrowPayload) GetRecordBatches() [][]byte
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 ArrowPayload_Compression ¶
type ArrowPayload_Compression int32
const ( ArrowPayload_NONE ArrowPayload_Compression = 0 ArrowPayload_ZSTD ArrowPayload_Compression = 1 )
func (ArrowPayload_Compression) Descriptor ¶
func (ArrowPayload_Compression) Descriptor() protoreflect.EnumDescriptor
func (ArrowPayload_Compression) Enum ¶
func (x ArrowPayload_Compression) Enum() *ArrowPayload_Compression
func (ArrowPayload_Compression) EnumDescriptor
deprecated
func (ArrowPayload_Compression) EnumDescriptor() ([]byte, []int)
Deprecated: Use ArrowPayload_Compression.Descriptor instead.
func (ArrowPayload_Compression) Number ¶
func (x ArrowPayload_Compression) Number() protoreflect.EnumNumber
func (ArrowPayload_Compression) String ¶
func (x ArrowPayload_Compression) String() string
func (ArrowPayload_Compression) Type ¶
func (ArrowPayload_Compression) Type() protoreflect.EnumType
type Endpoint ¶
type Endpoint struct { Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"` Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*Endpoint) Descriptor
deprecated
func (*Endpoint) ProtoMessage ¶
func (*Endpoint) ProtoMessage()
func (*Endpoint) ProtoReflect ¶
func (x *Endpoint) ProtoReflect() protoreflect.Message
type Field ¶
type Field struct { NameIndex uint32 `protobuf:"varint,1,opt,name=name_index,json=nameIndex,proto3" json:"name_index,omitempty"` Value *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Field) Descriptor
deprecated
func (*Field) GetNameIndex ¶
func (*Field) ProtoMessage ¶
func (*Field) ProtoMessage()
func (*Field) ProtoReflect ¶
func (x *Field) ProtoReflect() protoreflect.Message
type FieldGroup ¶
type FieldGroup struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Fields []*Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"` // contains filtered or unexported fields }
func (*FieldGroup) Descriptor
deprecated
func (*FieldGroup) Descriptor() ([]byte, []int)
Deprecated: Use FieldGroup.ProtoReflect.Descriptor instead.
func (*FieldGroup) GetFields ¶
func (x *FieldGroup) GetFields() []*Field
func (*FieldGroup) GetTimestamp ¶
func (x *FieldGroup) GetTimestamp() int64
func (*FieldGroup) ProtoMessage ¶
func (*FieldGroup) ProtoMessage()
func (*FieldGroup) ProtoReflect ¶
func (x *FieldGroup) ProtoReflect() protoreflect.Message
func (*FieldGroup) Reset ¶
func (x *FieldGroup) Reset()
func (*FieldGroup) String ¶
func (x *FieldGroup) String() string
type PrometheusQueryRequest ¶
type PrometheusQueryRequest struct { Context *RequestContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Expr *ceresprompb.Expr `protobuf:"bytes,2,opt,name=expr,proto3" json:"expr,omitempty"` // use oneof to represent option for scalar value // https://github.com/protocolbuffers/protobuf/issues/1606 // // Types that are assignable to LookbackDelta: // // *PrometheusQueryRequest_Delta LookbackDelta isPrometheusQueryRequest_LookbackDelta `protobuf_oneof:"lookback_delta"` // contains filtered or unexported fields }
func (*PrometheusQueryRequest) Descriptor
deprecated
func (*PrometheusQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use PrometheusQueryRequest.ProtoReflect.Descriptor instead.
func (*PrometheusQueryRequest) GetContext ¶
func (x *PrometheusQueryRequest) GetContext() *RequestContext
func (*PrometheusQueryRequest) GetDelta ¶
func (x *PrometheusQueryRequest) GetDelta() int64
func (*PrometheusQueryRequest) GetExpr ¶
func (x *PrometheusQueryRequest) GetExpr() *ceresprompb.Expr
func (*PrometheusQueryRequest) GetLookbackDelta ¶
func (m *PrometheusQueryRequest) GetLookbackDelta() isPrometheusQueryRequest_LookbackDelta
func (*PrometheusQueryRequest) ProtoMessage ¶
func (*PrometheusQueryRequest) ProtoMessage()
func (*PrometheusQueryRequest) ProtoReflect ¶
func (x *PrometheusQueryRequest) ProtoReflect() protoreflect.Message
func (*PrometheusQueryRequest) Reset ¶
func (x *PrometheusQueryRequest) Reset()
func (*PrometheusQueryRequest) String ¶
func (x *PrometheusQueryRequest) String() string
type PrometheusQueryRequest_Delta ¶
type PrometheusQueryRequest_Delta struct {
Delta int64 `protobuf:"varint,3,opt,name=delta,proto3,oneof"`
}
type PrometheusQueryResponse ¶
type PrometheusQueryResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // Samples within a time series must be ordered by time. Timeseries []*ceresprompb.TimeSeries `protobuf:"bytes,2,rep,name=timeseries,proto3" json:"timeseries,omitempty"` // contains filtered or unexported fields }
func (*PrometheusQueryResponse) Descriptor
deprecated
func (*PrometheusQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use PrometheusQueryResponse.ProtoReflect.Descriptor instead.
func (*PrometheusQueryResponse) GetHeader ¶
func (x *PrometheusQueryResponse) GetHeader() *commonpb.ResponseHeader
func (*PrometheusQueryResponse) GetTimeseries ¶
func (x *PrometheusQueryResponse) GetTimeseries() []*ceresprompb.TimeSeries
func (*PrometheusQueryResponse) ProtoMessage ¶
func (*PrometheusQueryResponse) ProtoMessage()
func (*PrometheusQueryResponse) ProtoReflect ¶
func (x *PrometheusQueryResponse) ProtoReflect() protoreflect.Message
func (*PrometheusQueryResponse) Reset ¶
func (x *PrometheusQueryResponse) Reset()
func (*PrometheusQueryResponse) String ¶
func (x *PrometheusQueryResponse) String() string
type PrometheusRemoteQueryRequest ¶
type PrometheusRemoteQueryRequest struct { Context *RequestContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` // Encoded query for // https://github.com/prometheus/prometheus/blob/v2.43.0/prompb/remote.proto#L67 Query []byte `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*PrometheusRemoteQueryRequest) Descriptor
deprecated
func (*PrometheusRemoteQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use PrometheusRemoteQueryRequest.ProtoReflect.Descriptor instead.
func (*PrometheusRemoteQueryRequest) GetContext ¶
func (x *PrometheusRemoteQueryRequest) GetContext() *RequestContext
func (*PrometheusRemoteQueryRequest) GetQuery ¶
func (x *PrometheusRemoteQueryRequest) GetQuery() []byte
func (*PrometheusRemoteQueryRequest) ProtoMessage ¶
func (*PrometheusRemoteQueryRequest) ProtoMessage()
func (*PrometheusRemoteQueryRequest) ProtoReflect ¶
func (x *PrometheusRemoteQueryRequest) ProtoReflect() protoreflect.Message
func (*PrometheusRemoteQueryRequest) Reset ¶
func (x *PrometheusRemoteQueryRequest) Reset()
func (*PrometheusRemoteQueryRequest) String ¶
func (x *PrometheusRemoteQueryRequest) String() string
type PrometheusRemoteQueryResponse ¶
type PrometheusRemoteQueryResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // Encoded response for // https://github.com/prometheus/prometheus/blob/v2.43.0/prompb/remote.proto#L74 Response []byte `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"` // contains filtered or unexported fields }
func (*PrometheusRemoteQueryResponse) Descriptor
deprecated
func (*PrometheusRemoteQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use PrometheusRemoteQueryResponse.ProtoReflect.Descriptor instead.
func (*PrometheusRemoteQueryResponse) GetHeader ¶
func (x *PrometheusRemoteQueryResponse) GetHeader() *commonpb.ResponseHeader
func (*PrometheusRemoteQueryResponse) GetResponse ¶
func (x *PrometheusRemoteQueryResponse) GetResponse() []byte
func (*PrometheusRemoteQueryResponse) ProtoMessage ¶
func (*PrometheusRemoteQueryResponse) ProtoMessage()
func (*PrometheusRemoteQueryResponse) ProtoReflect ¶
func (x *PrometheusRemoteQueryResponse) ProtoReflect() protoreflect.Message
func (*PrometheusRemoteQueryResponse) Reset ¶
func (x *PrometheusRemoteQueryResponse) Reset()
func (*PrometheusRemoteQueryResponse) String ¶
func (x *PrometheusRemoteQueryResponse) String() string
type RequestContext ¶
type RequestContext struct { Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` // contains filtered or unexported fields }
func (*RequestContext) Descriptor
deprecated
func (*RequestContext) Descriptor() ([]byte, []int)
Deprecated: Use RequestContext.ProtoReflect.Descriptor instead.
func (*RequestContext) GetDatabase ¶
func (x *RequestContext) GetDatabase() string
func (*RequestContext) ProtoMessage ¶
func (*RequestContext) ProtoMessage()
func (*RequestContext) ProtoReflect ¶
func (x *RequestContext) ProtoReflect() protoreflect.Message
func (*RequestContext) Reset ¶
func (x *RequestContext) Reset()
func (*RequestContext) String ¶
func (x *RequestContext) String() string
type Route ¶
type Route struct { Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` Endpoint *Endpoint `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // contains filtered or unexported fields }
func (*Route) Descriptor
deprecated
func (*Route) GetEndpoint ¶
func (*Route) ProtoMessage ¶
func (*Route) ProtoMessage()
func (*Route) ProtoReflect ¶
func (x *Route) ProtoReflect() protoreflect.Message
type RouteRequest ¶
type RouteRequest struct { Context *RequestContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Tables []string `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"` // contains filtered or unexported fields }
func (*RouteRequest) Descriptor
deprecated
func (*RouteRequest) Descriptor() ([]byte, []int)
Deprecated: Use RouteRequest.ProtoReflect.Descriptor instead.
func (*RouteRequest) GetContext ¶
func (x *RouteRequest) GetContext() *RequestContext
func (*RouteRequest) GetTables ¶
func (x *RouteRequest) GetTables() []string
func (*RouteRequest) ProtoMessage ¶
func (*RouteRequest) ProtoMessage()
func (*RouteRequest) ProtoReflect ¶
func (x *RouteRequest) ProtoReflect() protoreflect.Message
func (*RouteRequest) Reset ¶
func (x *RouteRequest) Reset()
func (*RouteRequest) String ¶
func (x *RouteRequest) String() string
type RouteResponse ¶
type RouteResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Routes []*Route `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes,omitempty"` // contains filtered or unexported fields }
func (*RouteResponse) Descriptor
deprecated
func (*RouteResponse) Descriptor() ([]byte, []int)
Deprecated: Use RouteResponse.ProtoReflect.Descriptor instead.
func (*RouteResponse) GetHeader ¶
func (x *RouteResponse) GetHeader() *commonpb.ResponseHeader
func (*RouteResponse) GetRoutes ¶
func (x *RouteResponse) GetRoutes() []*Route
func (*RouteResponse) ProtoMessage ¶
func (*RouteResponse) ProtoMessage()
func (*RouteResponse) ProtoReflect ¶
func (x *RouteResponse) ProtoReflect() protoreflect.Message
func (*RouteResponse) Reset ¶
func (x *RouteResponse) Reset()
func (*RouteResponse) String ¶
func (x *RouteResponse) String() string
type SqlQueryRequest ¶
type SqlQueryRequest struct { Context *RequestContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Tables []string `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"` Sql string `protobuf:"bytes,3,opt,name=sql,proto3" json:"sql,omitempty"` // contains filtered or unexported fields }
func (*SqlQueryRequest) Descriptor
deprecated
func (*SqlQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use SqlQueryRequest.ProtoReflect.Descriptor instead.
func (*SqlQueryRequest) GetContext ¶
func (x *SqlQueryRequest) GetContext() *RequestContext
func (*SqlQueryRequest) GetSql ¶
func (x *SqlQueryRequest) GetSql() string
func (*SqlQueryRequest) GetTables ¶
func (x *SqlQueryRequest) GetTables() []string
func (*SqlQueryRequest) ProtoMessage ¶
func (*SqlQueryRequest) ProtoMessage()
func (*SqlQueryRequest) ProtoReflect ¶
func (x *SqlQueryRequest) ProtoReflect() protoreflect.Message
func (*SqlQueryRequest) Reset ¶
func (x *SqlQueryRequest) Reset()
func (*SqlQueryRequest) String ¶
func (x *SqlQueryRequest) String() string
type SqlQueryResponse ¶
type SqlQueryResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // Types that are assignable to Output: // // *SqlQueryResponse_AffectedRows // *SqlQueryResponse_Arrow Output isSqlQueryResponse_Output `protobuf_oneof:"output"` // contains filtered or unexported fields }
func (*SqlQueryResponse) Descriptor
deprecated
func (*SqlQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use SqlQueryResponse.ProtoReflect.Descriptor instead.
func (*SqlQueryResponse) GetAffectedRows ¶
func (x *SqlQueryResponse) GetAffectedRows() uint32
func (*SqlQueryResponse) GetArrow ¶
func (x *SqlQueryResponse) GetArrow() *ArrowPayload
func (*SqlQueryResponse) GetHeader ¶
func (x *SqlQueryResponse) GetHeader() *commonpb.ResponseHeader
func (*SqlQueryResponse) GetOutput ¶
func (m *SqlQueryResponse) GetOutput() isSqlQueryResponse_Output
func (*SqlQueryResponse) ProtoMessage ¶
func (*SqlQueryResponse) ProtoMessage()
func (*SqlQueryResponse) ProtoReflect ¶
func (x *SqlQueryResponse) ProtoReflect() protoreflect.Message
func (*SqlQueryResponse) Reset ¶
func (x *SqlQueryResponse) Reset()
func (*SqlQueryResponse) String ¶
func (x *SqlQueryResponse) String() string
type SqlQueryResponse_AffectedRows ¶
type SqlQueryResponse_AffectedRows struct {
AffectedRows uint32 `protobuf:"varint,2,opt,name=affected_rows,json=affectedRows,proto3,oneof"`
}
type SqlQueryResponse_Arrow ¶
type SqlQueryResponse_Arrow struct {
Arrow *ArrowPayload `protobuf:"bytes,3,opt,name=arrow,proto3,oneof"`
}
type StorageServiceClient ¶
type StorageServiceClient interface { Route(ctx context.Context, in *RouteRequest, opts ...grpc.CallOption) (*RouteResponse, error) Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error) StreamWrite(ctx context.Context, opts ...grpc.CallOption) (StorageService_StreamWriteClient, error) SqlQuery(ctx context.Context, in *SqlQueryRequest, opts ...grpc.CallOption) (*SqlQueryResponse, error) StreamSqlQuery(ctx context.Context, in *SqlQueryRequest, opts ...grpc.CallOption) (StorageService_StreamSqlQueryClient, error) PromRemoteQuery(ctx context.Context, in *PrometheusRemoteQueryRequest, opts ...grpc.CallOption) (*PrometheusRemoteQueryResponse, error) // This interface is mainly for testing now PromQuery(ctx context.Context, in *PrometheusQueryRequest, opts ...grpc.CallOption) (*PrometheusQueryResponse, error) }
StorageServiceClient is the client API for StorageService 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 NewStorageServiceClient ¶
func NewStorageServiceClient(cc grpc.ClientConnInterface) StorageServiceClient
type StorageServiceServer ¶
type StorageServiceServer interface { Route(context.Context, *RouteRequest) (*RouteResponse, error) Write(context.Context, *WriteRequest) (*WriteResponse, error) StreamWrite(StorageService_StreamWriteServer) error SqlQuery(context.Context, *SqlQueryRequest) (*SqlQueryResponse, error) StreamSqlQuery(*SqlQueryRequest, StorageService_StreamSqlQueryServer) error PromRemoteQuery(context.Context, *PrometheusRemoteQueryRequest) (*PrometheusRemoteQueryResponse, error) // This interface is mainly for testing now PromQuery(context.Context, *PrometheusQueryRequest) (*PrometheusQueryResponse, error) // contains filtered or unexported methods }
StorageServiceServer is the server API for StorageService service. All implementations must embed UnimplementedStorageServiceServer for forward compatibility
type StorageService_StreamSqlQueryClient ¶
type StorageService_StreamSqlQueryClient interface { Recv() (*SqlQueryResponse, error) grpc.ClientStream }
type StorageService_StreamSqlQueryServer ¶
type StorageService_StreamSqlQueryServer interface { Send(*SqlQueryResponse) error grpc.ServerStream }
type StorageService_StreamWriteClient ¶
type StorageService_StreamWriteClient interface { Send(*WriteRequest) error CloseAndRecv() (*WriteResponse, error) grpc.ClientStream }
type StorageService_StreamWriteServer ¶
type StorageService_StreamWriteServer interface { SendAndClose(*WriteResponse) error Recv() (*WriteRequest, error) grpc.ServerStream }
type Tag ¶
type Tag struct { NameIndex uint32 `protobuf:"varint,1,opt,name=name_index,json=nameIndex,proto3" json:"name_index,omitempty"` Value *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Tag) Descriptor
deprecated
func (*Tag) GetNameIndex ¶
func (*Tag) ProtoMessage ¶
func (*Tag) ProtoMessage()
func (*Tag) ProtoReflect ¶
func (x *Tag) ProtoReflect() protoreflect.Message
type UnimplementedStorageServiceServer ¶
type UnimplementedStorageServiceServer struct { }
UnimplementedStorageServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedStorageServiceServer) PromQuery ¶
func (UnimplementedStorageServiceServer) PromQuery(context.Context, *PrometheusQueryRequest) (*PrometheusQueryResponse, error)
func (UnimplementedStorageServiceServer) PromRemoteQuery ¶
func (UnimplementedStorageServiceServer) PromRemoteQuery(context.Context, *PrometheusRemoteQueryRequest) (*PrometheusRemoteQueryResponse, error)
func (UnimplementedStorageServiceServer) Route ¶
func (UnimplementedStorageServiceServer) Route(context.Context, *RouteRequest) (*RouteResponse, error)
func (UnimplementedStorageServiceServer) SqlQuery ¶
func (UnimplementedStorageServiceServer) SqlQuery(context.Context, *SqlQueryRequest) (*SqlQueryResponse, error)
func (UnimplementedStorageServiceServer) StreamSqlQuery ¶
func (UnimplementedStorageServiceServer) StreamSqlQuery(*SqlQueryRequest, StorageService_StreamSqlQueryServer) error
func (UnimplementedStorageServiceServer) StreamWrite ¶
func (UnimplementedStorageServiceServer) StreamWrite(StorageService_StreamWriteServer) error
func (UnimplementedStorageServiceServer) Write ¶
func (UnimplementedStorageServiceServer) Write(context.Context, *WriteRequest) (*WriteResponse, error)
type UnsafeStorageServiceServer ¶
type UnsafeStorageServiceServer interface {
// contains filtered or unexported methods
}
UnsafeStorageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StorageServiceServer will result in compilation errors.
type Value ¶
type Value struct { // Types that are assignable to Value: // // *Value_Float64Value // *Value_StringValue // *Value_Int64Value // *Value_Float32Value // *Value_Int32Value // *Value_Int16Value // *Value_Int8Value // *Value_BoolValue // *Value_Uint64Value // *Value_Uint32Value // *Value_Uint16Value // *Value_Uint8Value // *Value_TimestampValue // *Value_VarbinaryValue Value isValue_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
func (*Value) Descriptor
deprecated
func (*Value) GetBoolValue ¶
func (*Value) GetFloat32Value ¶
func (*Value) GetFloat64Value ¶
func (*Value) GetInt16Value ¶
func (*Value) GetInt32Value ¶
func (*Value) GetInt64Value ¶
func (*Value) GetInt8Value ¶
func (*Value) GetStringValue ¶
func (*Value) GetTimestampValue ¶
func (*Value) GetUint16Value ¶
func (*Value) GetUint32Value ¶
func (*Value) GetUint64Value ¶
func (*Value) GetUint8Value ¶
func (*Value) GetVarbinaryValue ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) ProtoReflect ¶
func (x *Value) ProtoReflect() protoreflect.Message
type Value_BoolValue ¶
type Value_BoolValue struct {
BoolValue bool `protobuf:"varint,8,opt,name=bool_value,json=boolValue,proto3,oneof"`
}
type Value_Float32Value ¶
type Value_Float32Value struct {
Float32Value float32 `protobuf:"fixed32,4,opt,name=float32_value,json=float32Value,proto3,oneof"`
}
type Value_Float64Value ¶
type Value_Float64Value struct {
Float64Value float64 `protobuf:"fixed64,1,opt,name=float64_value,json=float64Value,proto3,oneof"`
}
type Value_Int16Value ¶
type Value_Int16Value struct {
Int16Value int32 `protobuf:"varint,6,opt,name=int16_value,json=int16Value,proto3,oneof"`
}
type Value_Int32Value ¶
type Value_Int32Value struct {
Int32Value int32 `protobuf:"varint,5,opt,name=int32_value,json=int32Value,proto3,oneof"`
}
type Value_Int64Value ¶
type Value_Int64Value struct {
Int64Value int64 `protobuf:"varint,3,opt,name=int64_value,json=int64Value,proto3,oneof"`
}
type Value_Int8Value ¶
type Value_Int8Value struct {
Int8Value int32 `protobuf:"varint,7,opt,name=int8_value,json=int8Value,proto3,oneof"`
}
type Value_StringValue ¶
type Value_StringValue struct {
StringValue string `protobuf:"bytes,2,opt,name=string_value,json=stringValue,proto3,oneof"`
}
type Value_TimestampValue ¶
type Value_TimestampValue struct {
TimestampValue int64 `protobuf:"varint,13,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}
type Value_Uint16Value ¶
type Value_Uint16Value struct {
Uint16Value uint32 `protobuf:"varint,11,opt,name=uint16_value,json=uint16Value,proto3,oneof"`
}
type Value_Uint32Value ¶
type Value_Uint32Value struct {
Uint32Value uint32 `protobuf:"varint,10,opt,name=uint32_value,json=uint32Value,proto3,oneof"`
}
type Value_Uint64Value ¶
type Value_Uint64Value struct {
Uint64Value uint64 `protobuf:"varint,9,opt,name=uint64_value,json=uint64Value,proto3,oneof"`
}
type Value_Uint8Value ¶
type Value_Uint8Value struct {
Uint8Value uint32 `protobuf:"varint,12,opt,name=uint8_value,json=uint8Value,proto3,oneof"`
}
type Value_VarbinaryValue ¶
type Value_VarbinaryValue struct {
VarbinaryValue []byte `protobuf:"bytes,14,opt,name=varbinary_value,json=varbinaryValue,proto3,oneof"`
}
type WriteRequest ¶
type WriteRequest struct { Context *RequestContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` TableRequests []*WriteTableRequest `protobuf:"bytes,2,rep,name=table_requests,json=tableRequests,proto3" json:"table_requests,omitempty"` // contains filtered or unexported fields }
func (*WriteRequest) Descriptor
deprecated
func (*WriteRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.
func (*WriteRequest) GetContext ¶
func (x *WriteRequest) GetContext() *RequestContext
func (*WriteRequest) GetTableRequests ¶
func (x *WriteRequest) GetTableRequests() []*WriteTableRequest
func (*WriteRequest) ProtoMessage ¶
func (*WriteRequest) ProtoMessage()
func (*WriteRequest) ProtoReflect ¶
func (x *WriteRequest) ProtoReflect() protoreflect.Message
func (*WriteRequest) Reset ¶
func (x *WriteRequest) Reset()
func (*WriteRequest) String ¶
func (x *WriteRequest) String() string
type WriteResponse ¶
type WriteResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Success uint32 `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"` Failed uint32 `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"` // contains filtered or unexported fields }
func (*WriteResponse) Descriptor
deprecated
func (*WriteResponse) Descriptor() ([]byte, []int)
Deprecated: Use WriteResponse.ProtoReflect.Descriptor instead.
func (*WriteResponse) GetFailed ¶
func (x *WriteResponse) GetFailed() uint32
func (*WriteResponse) GetHeader ¶
func (x *WriteResponse) GetHeader() *commonpb.ResponseHeader
func (*WriteResponse) GetSuccess ¶
func (x *WriteResponse) GetSuccess() uint32
func (*WriteResponse) ProtoMessage ¶
func (*WriteResponse) ProtoMessage()
func (*WriteResponse) ProtoReflect ¶
func (x *WriteResponse) ProtoReflect() protoreflect.Message
func (*WriteResponse) Reset ¶
func (x *WriteResponse) Reset()
func (*WriteResponse) String ¶
func (x *WriteResponse) String() string
type WriteSeriesEntry ¶
type WriteSeriesEntry struct { Tags []*Tag `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"` FieldGroups []*FieldGroup `protobuf:"bytes,2,rep,name=field_groups,json=fieldGroups,proto3" json:"field_groups,omitempty"` // contains filtered or unexported fields }
func (*WriteSeriesEntry) Descriptor
deprecated
func (*WriteSeriesEntry) Descriptor() ([]byte, []int)
Deprecated: Use WriteSeriesEntry.ProtoReflect.Descriptor instead.
func (*WriteSeriesEntry) GetFieldGroups ¶
func (x *WriteSeriesEntry) GetFieldGroups() []*FieldGroup
func (*WriteSeriesEntry) GetTags ¶
func (x *WriteSeriesEntry) GetTags() []*Tag
func (*WriteSeriesEntry) ProtoMessage ¶
func (*WriteSeriesEntry) ProtoMessage()
func (*WriteSeriesEntry) ProtoReflect ¶
func (x *WriteSeriesEntry) ProtoReflect() protoreflect.Message
func (*WriteSeriesEntry) Reset ¶
func (x *WriteSeriesEntry) Reset()
func (*WriteSeriesEntry) String ¶
func (x *WriteSeriesEntry) String() string
type WriteTableRequest ¶
type WriteTableRequest struct { Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` TagNames []string `protobuf:"bytes,2,rep,name=tag_names,json=tagNames,proto3" json:"tag_names,omitempty"` FieldNames []string `protobuf:"bytes,3,rep,name=field_names,json=fieldNames,proto3" json:"field_names,omitempty"` Entries []*WriteSeriesEntry `protobuf:"bytes,4,rep,name=entries,proto3" json:"entries,omitempty"` // contains filtered or unexported fields }
func (*WriteTableRequest) Descriptor
deprecated
func (*WriteTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteTableRequest.ProtoReflect.Descriptor instead.
func (*WriteTableRequest) GetEntries ¶
func (x *WriteTableRequest) GetEntries() []*WriteSeriesEntry
func (*WriteTableRequest) GetFieldNames ¶
func (x *WriteTableRequest) GetFieldNames() []string
func (*WriteTableRequest) GetTable ¶
func (x *WriteTableRequest) GetTable() string
func (*WriteTableRequest) GetTagNames ¶
func (x *WriteTableRequest) GetTagNames() []string
func (*WriteTableRequest) ProtoMessage ¶
func (*WriteTableRequest) ProtoMessage()
func (*WriteTableRequest) ProtoReflect ¶
func (x *WriteTableRequest) ProtoReflect() protoreflect.Message
func (*WriteTableRequest) Reset ¶
func (x *WriteTableRequest) Reset()
func (*WriteTableRequest) String ¶
func (x *WriteTableRequest) String() string