storagepb

package
v0.0.0-...-b5a6581 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

View Source 
var File_storage_proto protoreflect.FileDescriptor
View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetIp 

func (x *Endpoint) GetIp() string

func (*Endpoint) GetPort 

func (x *Endpoint) GetPort() uint32

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect 

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

func (*Endpoint) Reset 

func (x *Endpoint) Reset()

func (*Endpoint) String 

func (x *Endpoint) String() string

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

Deprecated: Use Field.ProtoReflect.Descriptor instead.

func (*Field) GetNameIndex 

func (x *Field) GetNameIndex() uint32

func (*Field) GetValue 

func (x *Field) GetValue() *Value

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) ProtoReflect 

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

func (*Field) Reset 

func (x *Field) Reset()

func (*Field) String 

func (x *Field) String() string

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

Deprecated: Use Route.ProtoReflect.Descriptor instead.

func (*Route) GetEndpoint 

func (x *Route) GetEndpoint() *Endpoint

func (*Route) GetTable 

func (x *Route) GetTable() string

func (*Route) ProtoMessage 

func (*Route) ProtoMessage()

func (*Route) ProtoReflect 

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

func (*Route) Reset 

func (x *Route) Reset()

func (*Route) String 

func (x *Route) String() string

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

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetNameIndex 

func (x *Tag) GetNameIndex() uint32

func (*Tag) GetValue 

func (x *Tag) GetValue() *Value

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect 

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

func (*Tag) Reset 

func (x *Tag) Reset()

func (*Tag) String 

func (x *Tag) String() string

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBoolValue 

func (x *Value) GetBoolValue() bool

func (*Value) GetFloat32Value 

func (x *Value) GetFloat32Value() float32

func (*Value) GetFloat64Value 

func (x *Value) GetFloat64Value() float64

func (*Value) GetInt16Value 

func (x *Value) GetInt16Value() int32

func (*Value) GetInt32Value 

func (x *Value) GetInt32Value() int32

func (*Value) GetInt64Value 

func (x *Value) GetInt64Value() int64

func (*Value) GetInt8Value 

func (x *Value) GetInt8Value() int32

func (*Value) GetStringValue 

func (x *Value) GetStringValue() string

func (*Value) GetTimestampValue 

func (x *Value) GetTimestampValue() int64

func (*Value) GetUint16Value 

func (x *Value) GetUint16Value() uint32

func (*Value) GetUint32Value 

func (x *Value) GetUint32Value() uint32

func (*Value) GetUint64Value 

func (x *Value) GetUint64Value() uint64

func (*Value) GetUint8Value 

func (x *Value) GetUint8Value() uint32

func (*Value) GetValue 

func (m *Value) GetValue() isValue_Value

func (*Value) GetVarbinaryValue 

func (x *Value) GetVarbinaryValue() []byte

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

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

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.