storagev1alpha1

package
v0.0.0-...-3bf8ce9 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Op_name = map[int32]string{
		0:  "OP_UNKNOWN_UNSPECIFIED",
		1:  "OP_EQ",
		2:  "OP_NOT_EQ",
		3:  "OP_LT",
		4:  "OP_LT_EQ",
		5:  "OP_GT",
		6:  "OP_GT_EQ",
		7:  "OP_REGEX_MATCH",
		8:  "OP_REGEX_NOT_MATCH",
		9:  "OP_AND",
		10: "OP_OR",
		11: "OP_ADD",
		12: "OP_SUB",
		13: "OP_MUL",
		14: "OP_DIV",
		15: "OP_CONTAINS",
		16: "OP_NOT_CONTAINS",
	}
	Op_value = map[string]int32{
		"OP_UNKNOWN_UNSPECIFIED": 0,
		"OP_EQ":                  1,
		"OP_NOT_EQ":              2,
		"OP_LT":                  3,
		"OP_LT_EQ":               4,
		"OP_GT":                  5,
		"OP_GT_EQ":               6,
		"OP_REGEX_MATCH":         7,
		"OP_REGEX_NOT_MATCH":     8,
		"OP_AND":                 9,
		"OP_OR":                  10,
		"OP_ADD":                 11,
		"OP_SUB":                 12,
		"OP_MUL":                 13,
		"OP_DIV":                 14,
		"OP_CONTAINS":            15,
		"OP_NOT_CONTAINS":        16,
	}
)

Enum value maps for Op.

View Source 
var (
	Type_name = map[int32]string{
		0: "TYPE_UNKNOWN_UNSPECIFIED",
		1: "TYPE_FLOAT64",
	}
	Type_value = map[string]int32{
		"TYPE_UNKNOWN_UNSPECIFIED": 0,
		"TYPE_FLOAT64":             1,
	}
)

Enum value maps for Type.

View Source 
var (
	AggregationFunction_Type_name = map[int32]string{
		0: "TYPE_UNKNOWN_UNSPECIFIED",
		1: "TYPE_SUM",
		2: "TYPE_MIN",
		3: "TYPE_MAX",
		4: "TYPE_COUNT",
		5: "TYPE_AVG",
		6: "TYPE_UNIQUE",
		7: "TYPE_AND",
	}
	AggregationFunction_Type_value = map[string]int32{
		"TYPE_UNKNOWN_UNSPECIFIED": 0,
		"TYPE_SUM":                 1,
		"TYPE_MIN":                 2,
		"TYPE_MAX":                 3,
		"TYPE_COUNT":               4,
		"TYPE_AVG":                 5,
		"TYPE_UNIQUE":              6,
		"TYPE_AND":                 7,
	}
)

Enum value maps for AggregationFunction_Type.

View Source 
var File_frostdb_storage_v1alpha1_storage_proto protoreflect.FileDescriptor
View Source 
var FrostDBService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "frostdb.storage.v1alpha1.FrostDBService",
	HandlerType: (*FrostDBServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Query",
			Handler:       _FrostDBService_Query_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "frostdb/storage/v1alpha1/storage.proto",
}

FrostDBService_ServiceDesc is the grpc.ServiceDesc for FrostDBService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFrostDBServiceServer 

func RegisterFrostDBServiceServer(s grpc.ServiceRegistrar, srv FrostDBServiceServer)

Types

type Aggregation 

type Aggregation struct {

	// GroupExprs are the expressions to group by.
	GroupExprs []*Expr `protobuf:"bytes,1,rep,name=group_exprs,json=groupExprs,proto3" json:"group_exprs,omitempty"`
	// AggExprs are the aggregation functions applied to values of each group.
	AggExprs []*Expr `protobuf:"bytes,2,rep,name=agg_exprs,json=aggExprs,proto3" json:"agg_exprs,omitempty"`
	// contains filtered or unexported fields
}

Aggregation describes an aggregation node.

func (*Aggregation) Descriptor deprecated 

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

Deprecated: Use Aggregation.ProtoReflect.Descriptor instead.

func (*Aggregation) GetAggExprs 

func (x *Aggregation) GetAggExprs() []*Expr

func (*Aggregation) GetGroupExprs 

func (x *Aggregation) GetGroupExprs() []*Expr

func (*Aggregation) MarshalToSizedBufferVT 

func (m *Aggregation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Aggregation) MarshalToVT 

func (m *Aggregation) MarshalToVT(dAtA []byte) (int, error)

func (*Aggregation) MarshalVT 

func (m *Aggregation) MarshalVT() (dAtA []byte, err error)

func (*Aggregation) ProtoMessage 

func (*Aggregation) ProtoMessage()

func (*Aggregation) ProtoReflect 

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

func (*Aggregation) Reset 

func (x *Aggregation) Reset()

func (*Aggregation) SizeVT 

func (m *Aggregation) SizeVT() (n int)

func (*Aggregation) String 

func (x *Aggregation) String() string

func (*Aggregation) UnmarshalVT 

func (m *Aggregation) UnmarshalVT(dAtA []byte) error

type AggregationFunction 

type AggregationFunction struct {

	// type is the type of aggregation function.
	Type AggregationFunction_Type `protobuf:"varint,1,opt,name=type,proto3,enum=frostdb.storage.v1alpha1.AggregationFunction_Type" json:"type,omitempty"`
	// expr is the expression to aggregate.
	Expr *Expr `protobuf:"bytes,2,opt,name=expr,proto3" json:"expr,omitempty"`
	// contains filtered or unexported fields
}

AggregationFunction is an aggregation function.

func (*AggregationFunction) Descriptor deprecated 

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

Deprecated: Use AggregationFunction.ProtoReflect.Descriptor instead.

func (*AggregationFunction) GetExpr 

func (x *AggregationFunction) GetExpr() *Expr

func (*AggregationFunction) GetType 

func (x *AggregationFunction) GetType() AggregationFunction_Type

func (*AggregationFunction) MarshalToSizedBufferVT 

func (m *AggregationFunction) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AggregationFunction) MarshalToVT 

func (m *AggregationFunction) MarshalToVT(dAtA []byte) (int, error)

func (*AggregationFunction) MarshalVT 

func (m *AggregationFunction) MarshalVT() (dAtA []byte, err error)

func (*AggregationFunction) ProtoMessage 

func (*AggregationFunction) ProtoMessage()

func (*AggregationFunction) ProtoReflect 

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

func (*AggregationFunction) Reset 

func (x *AggregationFunction) Reset()

func (*AggregationFunction) SizeVT 

func (m *AggregationFunction) SizeVT() (n int)

func (*AggregationFunction) String 

func (x *AggregationFunction) String() string

func (*AggregationFunction) UnmarshalVT 

func (m *AggregationFunction) UnmarshalVT(dAtA []byte) error

type AggregationFunction_Type 

type AggregationFunction_Type int32

Type is the type of aggregation function. 

const (
	// UNKNOWN_UNSPECIFIED is the default value. It should not be used.
	AggregationFunction_TYPE_UNKNOWN_UNSPECIFIED AggregationFunction_Type = 0
	// SUM is the sum aggregation function.
	AggregationFunction_TYPE_SUM AggregationFunction_Type = 1
	// MIN is the min aggregation function.
	AggregationFunction_TYPE_MIN AggregationFunction_Type = 2
	// MAX is the max aggregation function.
	AggregationFunction_TYPE_MAX AggregationFunction_Type = 3
	// COUNT is the count aggregation function.
	AggregationFunction_TYPE_COUNT AggregationFunction_Type = 4
	// AVG is the avg aggregation function.
	AggregationFunction_TYPE_AVG AggregationFunction_Type = 5
	// UNIQUE is the unique aggregation function.
	AggregationFunction_TYPE_UNIQUE AggregationFunction_Type = 6
	// AND is the and aggregation function.
	AggregationFunction_TYPE_AND AggregationFunction_Type = 7
)

func (AggregationFunction_Type) Descriptor 

func (AggregationFunction_Type) Descriptor() protoreflect.EnumDescriptor

func (AggregationFunction_Type) Enum 

func (x AggregationFunction_Type) Enum() *AggregationFunction_Type

func (AggregationFunction_Type) EnumDescriptor deprecated 

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

Deprecated: Use AggregationFunction_Type.Descriptor instead.

func (AggregationFunction_Type) Number 

func (x AggregationFunction_Type) Number() protoreflect.EnumNumber

func (AggregationFunction_Type) String 

func (x AggregationFunction_Type) String() string

func (AggregationFunction_Type) Type 

func (AggregationFunction_Type) Type() protoreflect.EnumType

type Alias 

type Alias struct {

	// name is the name of the alias.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// expr is the expression to alias.
	Expr *Expr `protobuf:"bytes,2,opt,name=expr,proto3" json:"expr,omitempty"`
	// contains filtered or unexported fields
}

Alias is an alias for an expression.

func (*Alias) Descriptor deprecated 

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

Deprecated: Use Alias.ProtoReflect.Descriptor instead.

func (*Alias) GetExpr 

func (x *Alias) GetExpr() *Expr

func (*Alias) GetName 

func (x *Alias) GetName() string

func (*Alias) MarshalToSizedBufferVT 

func (m *Alias) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Alias) MarshalToVT 

func (m *Alias) MarshalToVT(dAtA []byte) (int, error)

func (*Alias) MarshalVT 

func (m *Alias) MarshalVT() (dAtA []byte, err error)

func (*Alias) ProtoMessage 

func (*Alias) ProtoMessage()

func (*Alias) ProtoReflect 

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

func (*Alias) Reset 

func (x *Alias) Reset()

func (*Alias) SizeVT 

func (m *Alias) SizeVT() (n int)

func (*Alias) String 

func (x *Alias) String() string

func (*Alias) UnmarshalVT 

func (m *Alias) UnmarshalVT(dAtA []byte) error

type BinaryExpr 

type BinaryExpr struct {

	// left is the left operand.
	Left *Expr `protobuf:"bytes,1,opt,name=left,proto3" json:"left,omitempty"`
	// right is the right operand.
	Right *Expr `protobuf:"bytes,2,opt,name=right,proto3" json:"right,omitempty"`
	// op is the operator.
	Op Op `protobuf:"varint,3,opt,name=op,proto3,enum=frostdb.storage.v1alpha1.Op" json:"op,omitempty"`
	// contains filtered or unexported fields
}

BinaryExpression is a binary expression.

func (*BinaryExpr) Descriptor deprecated 

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

Deprecated: Use BinaryExpr.ProtoReflect.Descriptor instead.

func (*BinaryExpr) GetLeft 

func (x *BinaryExpr) GetLeft() *Expr

func (*BinaryExpr) GetOp 

func (x *BinaryExpr) GetOp() Op

func (*BinaryExpr) GetRight 

func (x *BinaryExpr) GetRight() *Expr

func (*BinaryExpr) MarshalToSizedBufferVT 

func (m *BinaryExpr) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BinaryExpr) MarshalToVT 

func (m *BinaryExpr) MarshalToVT(dAtA []byte) (int, error)

func (*BinaryExpr) MarshalVT 

func (m *BinaryExpr) MarshalVT() (dAtA []byte, err error)

func (*BinaryExpr) ProtoMessage 

func (*BinaryExpr) ProtoMessage()

func (*BinaryExpr) ProtoReflect 

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

func (*BinaryExpr) Reset 

func (x *BinaryExpr) Reset()

func (*BinaryExpr) SizeVT 

func (m *BinaryExpr) SizeVT() (n int)

func (*BinaryExpr) String 

func (x *BinaryExpr) String() string

func (*BinaryExpr) UnmarshalVT 

func (m *BinaryExpr) UnmarshalVT(dAtA []byte) error

type Column 

type Column struct {

	// name is the name of the column.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Column is an explicit column in a table.

func (*Column) Descriptor deprecated 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetName 

func (x *Column) GetName() string

func (*Column) MarshalToSizedBufferVT 

func (m *Column) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Column) MarshalToVT 

func (m *Column) MarshalToVT(dAtA []byte) (int, error)

func (*Column) MarshalVT 

func (m *Column) MarshalVT() (dAtA []byte, err error)

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect 

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

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) SizeVT 

func (m *Column) SizeVT() (n int)

func (*Column) String 

func (x *Column) String() string

func (*Column) UnmarshalVT 

func (m *Column) UnmarshalVT(dAtA []byte) error

type ConvertExpr 

type ConvertExpr struct {

	// the expression to convert
	Expr *Expr `protobuf:"bytes,1,opt,name=expr,proto3" json:"expr,omitempty"`
	// the type to convert to
	Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=frostdb.storage.v1alpha1.Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

ConvertExpr is an expression to convert an expression to another type.

func (*ConvertExpr) Descriptor deprecated 

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

Deprecated: Use ConvertExpr.ProtoReflect.Descriptor instead.

func (*ConvertExpr) GetExpr 

func (x *ConvertExpr) GetExpr() *Expr

func (*ConvertExpr) GetType 

func (x *ConvertExpr) GetType() Type

func (*ConvertExpr) MarshalToSizedBufferVT 

func (m *ConvertExpr) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ConvertExpr) MarshalToVT 

func (m *ConvertExpr) MarshalToVT(dAtA []byte) (int, error)

func (*ConvertExpr) MarshalVT 

func (m *ConvertExpr) MarshalVT() (dAtA []byte, err error)

func (*ConvertExpr) ProtoMessage 

func (*ConvertExpr) ProtoMessage()

func (*ConvertExpr) ProtoReflect 

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

func (*ConvertExpr) Reset 

func (x *ConvertExpr) Reset()

func (*ConvertExpr) SizeVT 

func (m *ConvertExpr) SizeVT() (n int)

func (*ConvertExpr) String 

func (x *ConvertExpr) String() string

func (*ConvertExpr) UnmarshalVT 

func (m *ConvertExpr) UnmarshalVT(dAtA []byte) error

type Distinct 

type Distinct struct {

	// Exprs are the expressions to distinct by.
	Exprs []*Expr `protobuf:"bytes,1,rep,name=exprs,proto3" json:"exprs,omitempty"`
	// contains filtered or unexported fields
}

Distinct describes a distinct node.

func (*Distinct) Descriptor deprecated 

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

Deprecated: Use Distinct.ProtoReflect.Descriptor instead.

func (*Distinct) GetExprs 

func (x *Distinct) GetExprs() []*Expr

func (*Distinct) MarshalToSizedBufferVT 

func (m *Distinct) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Distinct) MarshalToVT 

func (m *Distinct) MarshalToVT(dAtA []byte) (int, error)

func (*Distinct) MarshalVT 

func (m *Distinct) MarshalVT() (dAtA []byte, err error)

func (*Distinct) ProtoMessage 

func (*Distinct) ProtoMessage()

func (*Distinct) ProtoReflect 

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

func (*Distinct) Reset 

func (x *Distinct) Reset()

func (*Distinct) SizeVT 

func (m *Distinct) SizeVT() (n int)

func (*Distinct) String 

func (x *Distinct) String() string

func (*Distinct) UnmarshalVT 

func (m *Distinct) UnmarshalVT(dAtA []byte) error

type DurationExpr 

type DurationExpr struct {

	// milliseconds is the duration in milliseconds.
	Milliseconds int64 `protobuf:"varint,1,opt,name=milliseconds,proto3" json:"milliseconds,omitempty"`
	// contains filtered or unexported fields
}

DurationExpr is a duration expressed in milliseconds.

func (*DurationExpr) Descriptor deprecated 

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

Deprecated: Use DurationExpr.ProtoReflect.Descriptor instead.

func (*DurationExpr) GetMilliseconds 

func (x *DurationExpr) GetMilliseconds() int64

func (*DurationExpr) MarshalToSizedBufferVT 

func (m *DurationExpr) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DurationExpr) MarshalToVT 

func (m *DurationExpr) MarshalToVT(dAtA []byte) (int, error)

func (*DurationExpr) MarshalVT 

func (m *DurationExpr) MarshalVT() (dAtA []byte, err error)

func (*DurationExpr) ProtoMessage 

func (*DurationExpr) ProtoMessage()

func (*DurationExpr) ProtoReflect 

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

func (*DurationExpr) Reset 

func (x *DurationExpr) Reset()

func (*DurationExpr) SizeVT 

func (m *DurationExpr) SizeVT() (n int)

func (*DurationExpr) String 

func (x *DurationExpr) String() string

func (*DurationExpr) UnmarshalVT 

func (m *DurationExpr) UnmarshalVT(dAtA []byte) error

type DynamicColumn 

type DynamicColumn struct {

	// name is the name of the dynamic column.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DynamicColumn is a dynamic column.

func (*DynamicColumn) Descriptor deprecated 

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

Deprecated: Use DynamicColumn.ProtoReflect.Descriptor instead.

func (*DynamicColumn) GetName 

func (x *DynamicColumn) GetName() string

func (*DynamicColumn) MarshalToSizedBufferVT 

func (m *DynamicColumn) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DynamicColumn) MarshalToVT 

func (m *DynamicColumn) MarshalToVT(dAtA []byte) (int, error)

func (*DynamicColumn) MarshalVT 

func (m *DynamicColumn) MarshalVT() (dAtA []byte, err error)

func (*DynamicColumn) ProtoMessage 

func (*DynamicColumn) ProtoMessage()

func (*DynamicColumn) ProtoReflect 

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

func (*DynamicColumn) Reset 

func (x *DynamicColumn) Reset()

func (*DynamicColumn) SizeVT 

func (m *DynamicColumn) SizeVT() (n int)

func (*DynamicColumn) String 

func (x *DynamicColumn) String() string

func (*DynamicColumn) UnmarshalVT 

func (m *DynamicColumn) UnmarshalVT(dAtA []byte) error

type Expr 

type Expr struct {

	// def is the definition of the expression.
	Def *ExprDef `protobuf:"bytes,1,opt,name=def,proto3" json:"def,omitempty"`
	// contains filtered or unexported fields
}

Expr is the base type for all expressions.

func (*Expr) Descriptor deprecated 

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

Deprecated: Use Expr.ProtoReflect.Descriptor instead.

func (*Expr) GetDef 

func (x *Expr) GetDef() *ExprDef

func (*Expr) MarshalToSizedBufferVT 

func (m *Expr) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Expr) MarshalToVT 

func (m *Expr) MarshalToVT(dAtA []byte) (int, error)

func (*Expr) MarshalVT 

func (m *Expr) MarshalVT() (dAtA []byte, err error)

func (*Expr) ProtoMessage 

func (*Expr) ProtoMessage()

func (*Expr) ProtoReflect 

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

func (*Expr) Reset 

func (x *Expr) Reset()

func (*Expr) SizeVT 

func (m *Expr) SizeVT() (n int)

func (*Expr) String 

func (x *Expr) String() string

func (*Expr) UnmarshalVT 

func (m *Expr) UnmarshalVT(dAtA []byte) error

type ExprDef 

type ExprDef struct {

	// content is the content of the expression definition.
	//
	// Types that are assignable to Content:
	//
	//	*ExprDef_BinaryExpr
	//	*ExprDef_Column
	//	*ExprDef_Literal
	//	*ExprDef_DynamicColumn
	//	*ExprDef_AggregationFunction
	//	*ExprDef_Alias
	//	*ExprDef_Duration
	//	*ExprDef_Convert
	//	*ExprDef_If
	Content isExprDef_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

ExprDefinition is a definition of an expression. It is intentionally only a single field that is a oneof to maintain forward compatibility when changing fields in each of the oneofs. This message should never have any other fields for forward compatibility.

func (*ExprDef) Descriptor deprecated 

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

Deprecated: Use ExprDef.ProtoReflect.Descriptor instead.

func (*ExprDef) GetAggregationFunction 

func (x *ExprDef) GetAggregationFunction() *AggregationFunction

func (*ExprDef) GetAlias 

func (x *ExprDef) GetAlias() *Alias

func (*ExprDef) GetBinaryExpr 

func (x *ExprDef) GetBinaryExpr() *BinaryExpr

func (*ExprDef) GetColumn 

func (x *ExprDef) GetColumn() *Column

func (*ExprDef) GetContent 

func (m *ExprDef) GetContent() isExprDef_Content

func (*ExprDef) GetConvert 

func (x *ExprDef) GetConvert() *ConvertExpr

func (*ExprDef) GetDuration 

func (x *ExprDef) GetDuration() *DurationExpr

func (*ExprDef) GetDynamicColumn 

func (x *ExprDef) GetDynamicColumn() *DynamicColumn

func (*ExprDef) GetIf 

func (x *ExprDef) GetIf() *IfExpr

func (*ExprDef) GetLiteral 

func (x *ExprDef) GetLiteral() *Literal

func (*ExprDef) MarshalToSizedBufferVT 

func (m *ExprDef) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExprDef) MarshalToVT 

func (m *ExprDef) MarshalToVT(dAtA []byte) (int, error)

func (*ExprDef) MarshalVT 

func (m *ExprDef) MarshalVT() (dAtA []byte, err error)

func (*ExprDef) ProtoMessage 

func (*ExprDef) ProtoMessage()

func (*ExprDef) ProtoReflect 

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

func (*ExprDef) Reset 

func (x *ExprDef) Reset()

func (*ExprDef) SizeVT 

func (m *ExprDef) SizeVT() (n int)

func (*ExprDef) String 

func (x *ExprDef) String() string

func (*ExprDef) UnmarshalVT 

func (m *ExprDef) UnmarshalVT(dAtA []byte) error

type ExprDef_AggregationFunction 

type ExprDef_AggregationFunction struct {
	// AggregationFunction is an aggregation function expression.
	AggregationFunction *AggregationFunction `protobuf:"bytes,5,opt,name=aggregation_function,json=aggregationFunction,proto3,oneof"`
}

func (*ExprDef_AggregationFunction) MarshalToSizedBufferVT 

func (m *ExprDef_AggregationFunction) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExprDef_AggregationFunction) MarshalToVT 

func (m *ExprDef_AggregationFunction) MarshalToVT(dAtA []byte) (int, error)

func (*ExprDef_AggregationFunction) SizeVT 

func (m *ExprDef_AggregationFunction) SizeVT() (n int)

type ExprDef_Alias 

type ExprDef_Alias struct {
	// Alias is an alias expression.
	Alias *Alias `protobuf:"bytes,6,opt,name=alias,proto3,oneof"`
}

func (*ExprDef_Alias) MarshalToSizedBufferVT 

func (m *ExprDef_Alias) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExprDef_Alias) MarshalToVT 

func (m *ExprDef_Alias) MarshalToVT(dAtA []byte) (int, error)

func (*ExprDef_Alias) SizeVT 

func (m *ExprDef_Alias) SizeVT() (n int)

type ExprDef_BinaryExpr 

type ExprDef_BinaryExpr struct {
	// BinaryExpr is a binary expression.
	BinaryExpr *BinaryExpr `protobuf:"bytes,1,opt,name=binary_expr,json=binaryExpr,proto3,oneof"`
}

func (*ExprDef_BinaryExpr) MarshalToSizedBufferVT 

func (m *ExprDef_BinaryExpr) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExprDef_BinaryExpr) MarshalToVT 

func (m *ExprDef_BinaryExpr) MarshalToVT(dAtA []byte) (int, error)

func (*ExprDef_BinaryExpr) SizeVT 

func (m *ExprDef_BinaryExpr) SizeVT() (n int)

type ExprDef_Column 

type ExprDef_Column struct {
	// Column is a column expression.
	Column *Column `protobuf:"bytes,2,opt,name=column,proto3,oneof"`
}

func (*ExprDef_Column) MarshalToSizedBufferVT 

func (m *ExprDef_Column) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExprDef_Column) MarshalToVT 

func (m *ExprDef_Column) MarshalToVT(dAtA []byte) (int, error)

func (*ExprDef_Column) SizeVT 

func (m *ExprDef_Column) SizeVT() (n int)

type ExprDef_Convert 

type ExprDef_Convert struct {
	// ConvertExpr is an expression to convert a column from one type to another.
	Convert *ConvertExpr `protobuf:"bytes,8,opt,name=convert,proto3,oneof"`
}

func (*ExprDef_Convert) MarshalToSizedBufferVT 

func (m *ExprDef_Convert) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExprDef_Convert) MarshalToVT 

func (m *ExprDef_Convert) MarshalToVT(dAtA []byte) (int, error)

func (*ExprDef_Convert) SizeVT 

func (m *ExprDef_Convert) SizeVT() (n int)

type ExprDef_Duration 

type ExprDef_Duration struct {
	// DurationExpr is a duration expression to group by.
	Duration *DurationExpr `protobuf:"bytes,7,opt,name=duration,proto3,oneof"`
}

func (*ExprDef_Duration) MarshalToSizedBufferVT 

func (m *ExprDef_Duration) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExprDef_Duration) MarshalToVT 

func (m *ExprDef_Duration) MarshalToVT(dAtA []byte) (int, error)

func (*ExprDef_Duration) SizeVT 

func (m *ExprDef_Duration) SizeVT() (n int)

type ExprDef_DynamicColumn 

type ExprDef_DynamicColumn struct {
	// DynamicColumn is a dynamic column expression.
	DynamicColumn *DynamicColumn `protobuf:"bytes,4,opt,name=dynamic_column,json=dynamicColumn,proto3,oneof"`
}

func (*ExprDef_DynamicColumn) MarshalToSizedBufferVT 

func (m *ExprDef_DynamicColumn) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExprDef_DynamicColumn) MarshalToVT 

func (m *ExprDef_DynamicColumn) MarshalToVT(dAtA []byte) (int, error)

func (*ExprDef_DynamicColumn) SizeVT 

func (m *ExprDef_DynamicColumn) SizeVT() (n int)

type ExprDef_If 

type ExprDef_If struct {
	// IfExpr is an if expression.
	If *IfExpr `protobuf:"bytes,9,opt,name=if,proto3,oneof"`
}

func (*ExprDef_If) MarshalToSizedBufferVT 

func (m *ExprDef_If) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExprDef_If) MarshalToVT 

func (m *ExprDef_If) MarshalToVT(dAtA []byte) (int, error)

func (*ExprDef_If) SizeVT 

func (m *ExprDef_If) SizeVT() (n int)

type ExprDef_Literal 

type ExprDef_Literal struct {
	// Literal is a literal expression.
	Literal *Literal `protobuf:"bytes,3,opt,name=literal,proto3,oneof"`
}

func (*ExprDef_Literal) MarshalToSizedBufferVT 

func (m *ExprDef_Literal) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExprDef_Literal) MarshalToVT 

func (m *ExprDef_Literal) MarshalToVT(dAtA []byte) (int, error)

func (*ExprDef_Literal) SizeVT 

func (m *ExprDef_Literal) SizeVT() (n int)

type Filter 

type Filter struct {

	// Expr is the filter expression.
	Expr *Expr `protobuf:"bytes,1,opt,name=expr,proto3" json:"expr,omitempty"`
	// contains filtered or unexported fields
}

Filter describes a filter.

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetExpr 

func (x *Filter) GetExpr() *Expr

func (*Filter) MarshalToSizedBufferVT 

func (m *Filter) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Filter) MarshalToVT 

func (m *Filter) MarshalToVT(dAtA []byte) (int, error)

func (*Filter) MarshalVT 

func (m *Filter) MarshalVT() (dAtA []byte, err error)

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) SizeVT 

func (m *Filter) SizeVT() (n int)

func (*Filter) String 

func (x *Filter) String() string

func (*Filter) UnmarshalVT 

func (m *Filter) UnmarshalVT(dAtA []byte) error

type FrostDBServiceClient 

type FrostDBServiceClient interface {
	// Query executes the query plan contained in the request and returns back
	// the results as arrow records in IPC format.
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (FrostDBService_QueryClient, error)
}

FrostDBServiceClient is the client API for FrostDBService 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 NewFrostDBServiceClient 

func NewFrostDBServiceClient(cc grpc.ClientConnInterface) FrostDBServiceClient

type FrostDBServiceServer 

type FrostDBServiceServer interface {
	// Query executes the query plan contained in the request and returns back
	// the results as arrow records in IPC format.
	Query(*QueryRequest, FrostDBService_QueryServer) error
	// contains filtered or unexported methods
}

FrostDBServiceServer is the server API for FrostDBService service. All implementations must embed UnimplementedFrostDBServiceServer for forward compatibility

type FrostDBService_QueryClient 

type FrostDBService_QueryClient interface {
	Recv() (*QueryResponse, error)
	grpc.ClientStream
}

type FrostDBService_QueryServer 

type FrostDBService_QueryServer interface {
	Send(*QueryResponse) error
	grpc.ServerStream
}

type IfExpr 

type IfExpr struct {

	// the condition
	Condition *Expr `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"`
	// the true branch
	Then *Expr `protobuf:"bytes,2,opt,name=then,proto3" json:"then,omitempty"`
	// the false branch
	Else *Expr `protobuf:"bytes,3,opt,name=else,proto3" json:"else,omitempty"`
	// contains filtered or unexported fields
}

IfExpr represents an if expression.

func (*IfExpr) Descriptor deprecated 

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

Deprecated: Use IfExpr.ProtoReflect.Descriptor instead.

func (*IfExpr) GetCondition 

func (x *IfExpr) GetCondition() *Expr

func (*IfExpr) GetElse 

func (x *IfExpr) GetElse() *Expr

func (*IfExpr) GetThen 

func (x *IfExpr) GetThen() *Expr

func (*IfExpr) MarshalToSizedBufferVT 

func (m *IfExpr) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*IfExpr) MarshalToVT 

func (m *IfExpr) MarshalToVT(dAtA []byte) (int, error)

func (*IfExpr) MarshalVT 

func (m *IfExpr) MarshalVT() (dAtA []byte, err error)

func (*IfExpr) ProtoMessage 

func (*IfExpr) ProtoMessage()

func (*IfExpr) ProtoReflect 

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

func (*IfExpr) Reset 

func (x *IfExpr) Reset()

func (*IfExpr) SizeVT 

func (m *IfExpr) SizeVT() (n int)

func (*IfExpr) String 

func (x *IfExpr) String() string

func (*IfExpr) UnmarshalVT 

func (m *IfExpr) UnmarshalVT(dAtA []byte) error

type Limit 

type Limit struct {

	// Expr is the expression to limit by.
	Expr *Expr `protobuf:"bytes,1,opt,name=expr,proto3" json:"expr,omitempty"`
	// contains filtered or unexported fields
}

Limit describes a limit node.

func (*Limit) Descriptor deprecated 

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

Deprecated: Use Limit.ProtoReflect.Descriptor instead.

func (*Limit) GetExpr 

func (x *Limit) GetExpr() *Expr

func (*Limit) MarshalToSizedBufferVT 

func (m *Limit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Limit) MarshalToVT 

func (m *Limit) MarshalToVT(dAtA []byte) (int, error)

func (*Limit) MarshalVT 

func (m *Limit) MarshalVT() (dAtA []byte, err error)

func (*Limit) ProtoMessage 

func (*Limit) ProtoMessage()

func (*Limit) ProtoReflect 

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

func (*Limit) Reset 

func (x *Limit) Reset()

func (*Limit) SizeVT 

func (m *Limit) SizeVT() (n int)

func (*Limit) String 

func (x *Limit) String() string

func (*Limit) UnmarshalVT 

func (m *Limit) UnmarshalVT(dAtA []byte) error

type Literal 

type Literal struct {

	// content is the content of the literal.
	Content *LiteralContent `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

Literal is a literal value.

func (*Literal) Descriptor deprecated 

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

Deprecated: Use Literal.ProtoReflect.Descriptor instead.

func (*Literal) GetContent 

func (x *Literal) GetContent() *LiteralContent

func (*Literal) MarshalToSizedBufferVT 

func (m *Literal) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Literal) MarshalToVT 

func (m *Literal) MarshalToVT(dAtA []byte) (int, error)

func (*Literal) MarshalVT 

func (m *Literal) MarshalVT() (dAtA []byte, err error)

func (*Literal) ProtoMessage 

func (*Literal) ProtoMessage()

func (*Literal) ProtoReflect 

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

func (*Literal) Reset 

func (x *Literal) Reset()

func (*Literal) SizeVT 

func (m *Literal) SizeVT() (n int)

func (*Literal) String 

func (x *Literal) String() string

func (*Literal) UnmarshalVT 

func (m *Literal) UnmarshalVT(dAtA []byte) error

type LiteralContent 

type LiteralContent struct {

	// value is the value of the literal.
	//
	// Types that are assignable to Value:
	//
	//	*LiteralContent_NullValue
	//	*LiteralContent_BoolValue
	//	*LiteralContent_Int32Value
	//	*LiteralContent_Uint32Value
	//	*LiteralContent_Int64Value
	//	*LiteralContent_Uint64Value
	//	*LiteralContent_FloatValue
	//	*LiteralContent_DoubleValue
	//	*LiteralContent_BinaryValue
	//	*LiteralContent_StringValue
	Value isLiteralContent_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

LiteralContent is the content of a literal.

func (*LiteralContent) Descriptor deprecated 

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

Deprecated: Use LiteralContent.ProtoReflect.Descriptor instead.

func (*LiteralContent) GetBinaryValue 

func (x *LiteralContent) GetBinaryValue() []byte

func (*LiteralContent) GetBoolValue 

func (x *LiteralContent) GetBoolValue() bool

func (*LiteralContent) GetDoubleValue 

func (x *LiteralContent) GetDoubleValue() float64

func (*LiteralContent) GetFloatValue 

func (x *LiteralContent) GetFloatValue() float32

func (*LiteralContent) GetInt32Value 

func (x *LiteralContent) GetInt32Value() int32

func (*LiteralContent) GetInt64Value 

func (x *LiteralContent) GetInt64Value() int64

func (*LiteralContent) GetNullValue 

func (x *LiteralContent) GetNullValue() *Null

func (*LiteralContent) GetStringValue 

func (x *LiteralContent) GetStringValue() string

func (*LiteralContent) GetUint32Value 

func (x *LiteralContent) GetUint32Value() uint32

func (*LiteralContent) GetUint64Value 

func (x *LiteralContent) GetUint64Value() uint64

func (*LiteralContent) GetValue 

func (m *LiteralContent) GetValue() isLiteralContent_Value

func (*LiteralContent) MarshalToSizedBufferVT 

func (m *LiteralContent) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LiteralContent) MarshalToVT 

func (m *LiteralContent) MarshalToVT(dAtA []byte) (int, error)

func (*LiteralContent) MarshalVT 

func (m *LiteralContent) MarshalVT() (dAtA []byte, err error)

func (*LiteralContent) ProtoMessage 

func (*LiteralContent) ProtoMessage()

func (*LiteralContent) ProtoReflect 

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

func (*LiteralContent) Reset 

func (x *LiteralContent) Reset()

func (*LiteralContent) SizeVT 

func (m *LiteralContent) SizeVT() (n int)

func (*LiteralContent) String 

func (x *LiteralContent) String() string

func (*LiteralContent) UnmarshalVT 

func (m *LiteralContent) UnmarshalVT(dAtA []byte) error

type LiteralContent_BinaryValue 

type LiteralContent_BinaryValue struct {
	// binary_value is the binary value.
	BinaryValue []byte `protobuf:"bytes,9,opt,name=binary_value,json=binaryValue,proto3,oneof"`
}

func (*LiteralContent_BinaryValue) MarshalToSizedBufferVT 

func (m *LiteralContent_BinaryValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LiteralContent_BinaryValue) MarshalToVT 

func (m *LiteralContent_BinaryValue) MarshalToVT(dAtA []byte) (int, error)

func (*LiteralContent_BinaryValue) SizeVT 

func (m *LiteralContent_BinaryValue) SizeVT() (n int)

type LiteralContent_BoolValue 

type LiteralContent_BoolValue struct {
	// bool_value is the bool value.
	BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

func (*LiteralContent_BoolValue) MarshalToSizedBufferVT 

func (m *LiteralContent_BoolValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LiteralContent_BoolValue) MarshalToVT 

func (m *LiteralContent_BoolValue) MarshalToVT(dAtA []byte) (int, error)

func (*LiteralContent_BoolValue) SizeVT 

func (m *LiteralContent_BoolValue) SizeVT() (n int)

type LiteralContent_DoubleValue 

type LiteralContent_DoubleValue struct {
	// double_value is the double value.
	DoubleValue float64 `protobuf:"fixed64,8,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

func (*LiteralContent_DoubleValue) MarshalToSizedBufferVT 

func (m *LiteralContent_DoubleValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LiteralContent_DoubleValue) MarshalToVT 

func (m *LiteralContent_DoubleValue) MarshalToVT(dAtA []byte) (int, error)

func (*LiteralContent_DoubleValue) SizeVT 

func (m *LiteralContent_DoubleValue) SizeVT() (n int)

type LiteralContent_FloatValue 

type LiteralContent_FloatValue struct {
	// float_value is the float value.
	FloatValue float32 `protobuf:"fixed32,7,opt,name=float_value,json=floatValue,proto3,oneof"`
}

func (*LiteralContent_FloatValue) MarshalToSizedBufferVT 

func (m *LiteralContent_FloatValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LiteralContent_FloatValue) MarshalToVT 

func (m *LiteralContent_FloatValue) MarshalToVT(dAtA []byte) (int, error)

func (*LiteralContent_FloatValue) SizeVT 

func (m *LiteralContent_FloatValue) SizeVT() (n int)

type LiteralContent_Int32Value 

type LiteralContent_Int32Value struct {
	// int32_value is the int32 value.
	Int32Value int32 `protobuf:"varint,3,opt,name=int32_value,json=int32Value,proto3,oneof"`
}

func (*LiteralContent_Int32Value) MarshalToSizedBufferVT 

func (m *LiteralContent_Int32Value) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LiteralContent_Int32Value) MarshalToVT 

func (m *LiteralContent_Int32Value) MarshalToVT(dAtA []byte) (int, error)

func (*LiteralContent_Int32Value) SizeVT 

func (m *LiteralContent_Int32Value) SizeVT() (n int)

type LiteralContent_Int64Value 

type LiteralContent_Int64Value struct {
	// int64_value is the int64 value.
	Int64Value int64 `protobuf:"varint,5,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

func (*LiteralContent_Int64Value) MarshalToSizedBufferVT 

func (m *LiteralContent_Int64Value) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LiteralContent_Int64Value) MarshalToVT 

func (m *LiteralContent_Int64Value) MarshalToVT(dAtA []byte) (int, error)

func (*LiteralContent_Int64Value) SizeVT 

func (m *LiteralContent_Int64Value) SizeVT() (n int)

type LiteralContent_NullValue 

type LiteralContent_NullValue struct {
	// null whether the value is the null value.
	NullValue *Null `protobuf:"bytes,1,opt,name=null_value,json=nullValue,proto3,oneof"`
}

func (*LiteralContent_NullValue) MarshalToSizedBufferVT 

func (m *LiteralContent_NullValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LiteralContent_NullValue) MarshalToVT 

func (m *LiteralContent_NullValue) MarshalToVT(dAtA []byte) (int, error)

func (*LiteralContent_NullValue) SizeVT 

func (m *LiteralContent_NullValue) SizeVT() (n int)

type LiteralContent_StringValue 

type LiteralContent_StringValue struct {
	// string_value is the string value.
	StringValue string `protobuf:"bytes,10,opt,name=string_value,json=stringValue,proto3,oneof"`
}

func (*LiteralContent_StringValue) MarshalToSizedBufferVT 

func (m *LiteralContent_StringValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LiteralContent_StringValue) MarshalToVT 

func (m *LiteralContent_StringValue) MarshalToVT(dAtA []byte) (int, error)

func (*LiteralContent_StringValue) SizeVT 

func (m *LiteralContent_StringValue) SizeVT() (n int)

type LiteralContent_Uint32Value 

type LiteralContent_Uint32Value struct {
	// uint32_value is the uint32 value.
	Uint32Value uint32 `protobuf:"varint,4,opt,name=uint32_value,json=uint32Value,proto3,oneof"`
}

func (*LiteralContent_Uint32Value) MarshalToSizedBufferVT 

func (m *LiteralContent_Uint32Value) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LiteralContent_Uint32Value) MarshalToVT 

func (m *LiteralContent_Uint32Value) MarshalToVT(dAtA []byte) (int, error)

func (*LiteralContent_Uint32Value) SizeVT 

func (m *LiteralContent_Uint32Value) SizeVT() (n int)

type LiteralContent_Uint64Value 

type LiteralContent_Uint64Value struct {
	// uint64_value is the uint64 value.
	Uint64Value uint64 `protobuf:"varint,6,opt,name=uint64_value,json=uint64Value,proto3,oneof"`
}

func (*LiteralContent_Uint64Value) MarshalToSizedBufferVT 

func (m *LiteralContent_Uint64Value) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LiteralContent_Uint64Value) MarshalToVT 

func (m *LiteralContent_Uint64Value) MarshalToVT(dAtA []byte) (int, error)

func (*LiteralContent_Uint64Value) SizeVT 

func (m *LiteralContent_Uint64Value) SizeVT() (n int)

type Null 

type Null struct {
	// contains filtered or unexported fields
}

Null is the null value.

func (*Null) Descriptor deprecated 

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

Deprecated: Use Null.ProtoReflect.Descriptor instead.

func (*Null) MarshalToSizedBufferVT 

func (m *Null) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Null) MarshalToVT 

func (m *Null) MarshalToVT(dAtA []byte) (int, error)

func (*Null) MarshalVT 

func (m *Null) MarshalVT() (dAtA []byte, err error)

func (*Null) ProtoMessage 

func (*Null) ProtoMessage()

func (*Null) ProtoReflect 

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

func (*Null) Reset 

func (x *Null) Reset()

func (*Null) SizeVT 

func (m *Null) SizeVT() (n int)

func (*Null) String 

func (x *Null) String() string

func (*Null) UnmarshalVT 

func (m *Null) UnmarshalVT(dAtA []byte) error

type Op 

type Op int32

Op describes a binary operator. 

const (
	// OP_UNKNOWN_UNSPECIFIED is the default value. It should not be used.
	Op_OP_UNKNOWN_UNSPECIFIED Op = 0
	// OP_EQ is the equality operator (`==`).
	Op_OP_EQ Op = 1
	// OP_NOT_EQ is the not-equality operator (`!=`).
	Op_OP_NOT_EQ Op = 2
	// OP_LT is the less-than operator (`<`).
	Op_OP_LT Op = 3
	// OP_LT_EQ is the less-than-or-equal operator (`<=`).
	Op_OP_LT_EQ Op = 4
	// OP_GT is the greater-than operator (`>`).
	Op_OP_GT Op = 5
	// OP_GT_EQ is the greater-than-or-equal operator (`>=`).
	Op_OP_GT_EQ Op = 6
	// OP_REGEX_MATCH is the regular expression match operator (`=~`).
	Op_OP_REGEX_MATCH Op = 7
	// OP_REGEX_NOT_MATCH is the regular expression not-match operator (`!~`).
	Op_OP_REGEX_NOT_MATCH Op = 8
	// OP_AND is the logical and operator (`&&`).
	Op_OP_AND Op = 9
	// OP_OR is the logical or operator (`||`).
	Op_OP_OR Op = 10
	// OP_ADD is the arithmetric addition (`+`).
	Op_OP_ADD Op = 11
	// OP_SUB is the arithmetric subtraction (`-`).
	Op_OP_SUB Op = 12
	// OP_MUL is the arithmetric multiplication (`*`).
	Op_OP_MUL Op = 13
	// OP_DIV is the arithmetric division (`/`).
	Op_OP_DIV Op = 14
	// OP_CONTAINS performs substring matches.
	Op_OP_CONTAINS Op = 15
	// OP_NOT_CONTAINS performs substring matches.
	Op_OP_NOT_CONTAINS Op = 16
)

func (Op) Descriptor 

func (Op) Descriptor() protoreflect.EnumDescriptor

func (Op) Enum 

func (x Op) Enum() *Op

func (Op) EnumDescriptor deprecated 

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

Deprecated: Use Op.Descriptor instead.

func (Op) Number 

func (x Op) Number() protoreflect.EnumNumber

func (Op) String 

func (x Op) String() string

func (Op) Type 

func (Op) Type() protoreflect.EnumType

type PlanNode 

type PlanNode struct {

	// Next is the next PlanNode in the plan, i.e. the node that this node should
	// push data to.
	Next *PlanNode `protobuf:"bytes,1,opt,name=next,proto3" json:"next,omitempty"`
	// Spec is this PlanNode's spec.
	Spec *PlanNodeSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

PlanNode describes a query plan.

func (*PlanNode) Descriptor deprecated 

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

Deprecated: Use PlanNode.ProtoReflect.Descriptor instead.

func (*PlanNode) GetNext 

func (x *PlanNode) GetNext() *PlanNode

func (*PlanNode) GetSpec 

func (x *PlanNode) GetSpec() *PlanNodeSpec

func (*PlanNode) MarshalToSizedBufferVT 

func (m *PlanNode) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PlanNode) MarshalToVT 

func (m *PlanNode) MarshalToVT(dAtA []byte) (int, error)

func (*PlanNode) MarshalVT 

func (m *PlanNode) MarshalVT() (dAtA []byte, err error)

func (*PlanNode) ProtoMessage 

func (*PlanNode) ProtoMessage()

func (*PlanNode) ProtoReflect 

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

func (*PlanNode) Reset 

func (x *PlanNode) Reset()

func (*PlanNode) SizeVT 

func (m *PlanNode) SizeVT() (n int)

func (*PlanNode) String 

func (x *PlanNode) String() string

func (*PlanNode) UnmarshalVT 

func (m *PlanNode) UnmarshalVT(dAtA []byte) error

type PlanNodeSpec 

type PlanNodeSpec struct {

	// Spec is this PlanNode's information.
	//
	// Types that are assignable to Spec:
	//
	//	*PlanNodeSpec_TableScan
	//	*PlanNodeSpec_SchemaScan
	//	*PlanNodeSpec_Filter
	//	*PlanNodeSpec_Projection
	//	*PlanNodeSpec_Distinct
	//	*PlanNodeSpec_Aggregation
	//	*PlanNodeSpec_Limit
	Spec isPlanNodeSpec_Spec `protobuf_oneof:"spec"`
	// contains filtered or unexported fields
}

PlanNodeSpec is a PlanNode's information. This is a message that wraps oneof to ensure forward compatibility: https://developers.google.com/protocol-buffers/docs/proto3#backwards-compatibility_issues

func (*PlanNodeSpec) Descriptor deprecated 

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

Deprecated: Use PlanNodeSpec.ProtoReflect.Descriptor instead.

func (*PlanNodeSpec) GetAggregation 

func (x *PlanNodeSpec) GetAggregation() *Aggregation

func (*PlanNodeSpec) GetDistinct 

func (x *PlanNodeSpec) GetDistinct() *Distinct

func (*PlanNodeSpec) GetFilter 

func (x *PlanNodeSpec) GetFilter() *Filter

func (*PlanNodeSpec) GetLimit 

func (x *PlanNodeSpec) GetLimit() *Limit

func (*PlanNodeSpec) GetProjection 

func (x *PlanNodeSpec) GetProjection() *Projection

func (*PlanNodeSpec) GetSchemaScan 

func (x *PlanNodeSpec) GetSchemaScan() *SchemaScan

func (*PlanNodeSpec) GetSpec 

func (m *PlanNodeSpec) GetSpec() isPlanNodeSpec_Spec

func (*PlanNodeSpec) GetTableScan 

func (x *PlanNodeSpec) GetTableScan() *TableScan

func (*PlanNodeSpec) MarshalToSizedBufferVT 

func (m *PlanNodeSpec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PlanNodeSpec) MarshalToVT 

func (m *PlanNodeSpec) MarshalToVT(dAtA []byte) (int, error)

func (*PlanNodeSpec) MarshalVT 

func (m *PlanNodeSpec) MarshalVT() (dAtA []byte, err error)

func (*PlanNodeSpec) ProtoMessage 

func (*PlanNodeSpec) ProtoMessage()

func (*PlanNodeSpec) ProtoReflect 

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

func (*PlanNodeSpec) Reset 

func (x *PlanNodeSpec) Reset()

func (*PlanNodeSpec) SizeVT 

func (m *PlanNodeSpec) SizeVT() (n int)

func (*PlanNodeSpec) String 

func (x *PlanNodeSpec) String() string

func (*PlanNodeSpec) UnmarshalVT 

func (m *PlanNodeSpec) UnmarshalVT(dAtA []byte) error

type PlanNodeSpec_Aggregation 

type PlanNodeSpec_Aggregation struct {
	// Aggregation is specified if this PlanNode represents an aggregation.
	Aggregation *Aggregation `protobuf:"bytes,6,opt,name=aggregation,proto3,oneof"`
}

func (*PlanNodeSpec_Aggregation) MarshalToSizedBufferVT 

func (m *PlanNodeSpec_Aggregation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_Aggregation) MarshalToVT 

func (m *PlanNodeSpec_Aggregation) MarshalToVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_Aggregation) SizeVT 

func (m *PlanNodeSpec_Aggregation) SizeVT() (n int)

type PlanNodeSpec_Distinct 

type PlanNodeSpec_Distinct struct {
	// Distinct is specified if this PlanNode represents a distinct.
	Distinct *Distinct `protobuf:"bytes,5,opt,name=distinct,proto3,oneof"`
}

func (*PlanNodeSpec_Distinct) MarshalToSizedBufferVT 

func (m *PlanNodeSpec_Distinct) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_Distinct) MarshalToVT 

func (m *PlanNodeSpec_Distinct) MarshalToVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_Distinct) SizeVT 

func (m *PlanNodeSpec_Distinct) SizeVT() (n int)

type PlanNodeSpec_Filter 

type PlanNodeSpec_Filter struct {
	// Filter is specified if this PlanNode represents a filter.
	Filter *Filter `protobuf:"bytes,3,opt,name=filter,proto3,oneof"`
}

func (*PlanNodeSpec_Filter) MarshalToSizedBufferVT 

func (m *PlanNodeSpec_Filter) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_Filter) MarshalToVT 

func (m *PlanNodeSpec_Filter) MarshalToVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_Filter) SizeVT 

func (m *PlanNodeSpec_Filter) SizeVT() (n int)

type PlanNodeSpec_Limit 

type PlanNodeSpec_Limit struct {
	// Limit is specified if this PlanNode represents a limit.
	Limit *Limit `protobuf:"bytes,7,opt,name=limit,proto3,oneof"`
}

func (*PlanNodeSpec_Limit) MarshalToSizedBufferVT 

func (m *PlanNodeSpec_Limit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_Limit) MarshalToVT 

func (m *PlanNodeSpec_Limit) MarshalToVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_Limit) SizeVT 

func (m *PlanNodeSpec_Limit) SizeVT() (n int)

type PlanNodeSpec_Projection 

type PlanNodeSpec_Projection struct {
	// Projections is specified if this PlanNode represents a projection.
	Projection *Projection `protobuf:"bytes,4,opt,name=projection,proto3,oneof"`
}

func (*PlanNodeSpec_Projection) MarshalToSizedBufferVT 

func (m *PlanNodeSpec_Projection) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_Projection) MarshalToVT 

func (m *PlanNodeSpec_Projection) MarshalToVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_Projection) SizeVT 

func (m *PlanNodeSpec_Projection) SizeVT() (n int)

type PlanNodeSpec_SchemaScan 

type PlanNodeSpec_SchemaScan struct {
	// SchemaScan is specified if this PlanNode represents a table scan.
	SchemaScan *SchemaScan `protobuf:"bytes,2,opt,name=schema_scan,json=schemaScan,proto3,oneof"`
}

func (*PlanNodeSpec_SchemaScan) MarshalToSizedBufferVT 

func (m *PlanNodeSpec_SchemaScan) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_SchemaScan) MarshalToVT 

func (m *PlanNodeSpec_SchemaScan) MarshalToVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_SchemaScan) SizeVT 

func (m *PlanNodeSpec_SchemaScan) SizeVT() (n int)

type PlanNodeSpec_TableScan 

type PlanNodeSpec_TableScan struct {
	// TableScan is specified if this PlanNode represents a table scan.
	TableScan *TableScan `protobuf:"bytes,1,opt,name=table_scan,json=tableScan,proto3,oneof"`
}

func (*PlanNodeSpec_TableScan) MarshalToSizedBufferVT 

func (m *PlanNodeSpec_TableScan) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_TableScan) MarshalToVT 

func (m *PlanNodeSpec_TableScan) MarshalToVT(dAtA []byte) (int, error)

func (*PlanNodeSpec_TableScan) SizeVT 

func (m *PlanNodeSpec_TableScan) SizeVT() (n int)

type Projection 

type Projection struct {

	// Exprs are the expressions to project.
	Exprs []*Expr `protobuf:"bytes,1,rep,name=exprs,proto3" json:"exprs,omitempty"`
	// contains filtered or unexported fields
}

Projection describes a projection node.

func (*Projection) Descriptor deprecated 

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

Deprecated: Use Projection.ProtoReflect.Descriptor instead.

func (*Projection) GetExprs 

func (x *Projection) GetExprs() []*Expr

func (*Projection) MarshalToSizedBufferVT 

func (m *Projection) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Projection) MarshalToVT 

func (m *Projection) MarshalToVT(dAtA []byte) (int, error)

func (*Projection) MarshalVT 

func (m *Projection) MarshalVT() (dAtA []byte, err error)

func (*Projection) ProtoMessage 

func (*Projection) ProtoMessage()

func (*Projection) ProtoReflect 

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

func (*Projection) Reset 

func (x *Projection) Reset()

func (*Projection) SizeVT 

func (m *Projection) SizeVT() (n int)

func (*Projection) String 

func (x *Projection) String() string

func (*Projection) UnmarshalVT 

func (m *Projection) UnmarshalVT(dAtA []byte) error

type QueryRequest 

type QueryRequest struct {

	// PlanRoot is the root of the query plan (i.e. a scan node).
	PlanRoot *PlanNode `protobuf:"bytes,1,opt,name=plan_root,json=planRoot,proto3" json:"plan_root,omitempty"`
	// description describes the query.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

QueryRequest is the message sent to the Query gRPC endpoint.

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetDescription 

func (x *QueryRequest) GetDescription() string

func (*QueryRequest) GetPlanRoot 

func (x *QueryRequest) GetPlanRoot() *PlanNode

func (*QueryRequest) MarshalToSizedBufferVT 

func (m *QueryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryRequest) MarshalToVT 

func (m *QueryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*QueryRequest) MarshalVT 

func (m *QueryRequest) MarshalVT() (dAtA []byte, err error)

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) SizeVT 

func (m *QueryRequest) SizeVT() (n int)

func (*QueryRequest) String 

func (x *QueryRequest) String() string

func (*QueryRequest) UnmarshalVT 

func (m *QueryRequest) UnmarshalVT(dAtA []byte) error

type QueryResponse 

type QueryResponse struct {

	// The resulting arrow record as bytes.
	Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

QueryResponse is the message received from the Query gRPC endpoint.

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetRecord 

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

func (*QueryResponse) MarshalToSizedBufferVT 

func (m *QueryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryResponse) MarshalToVT 

func (m *QueryResponse) MarshalToVT(dAtA []byte) (int, error)

func (*QueryResponse) MarshalVT 

func (m *QueryResponse) MarshalVT() (dAtA []byte, err error)

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

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

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) SizeVT 

func (m *QueryResponse) SizeVT() (n int)

func (*QueryResponse) String 

func (x *QueryResponse) String() string

func (*QueryResponse) UnmarshalVT 

func (m *QueryResponse) UnmarshalVT(dAtA []byte) error

type ScanBase 

type ScanBase struct {

	// Database is the name of the database to scan.
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Table is the name of the table to scan.
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

ScanBase is a collection of fields shared by scans.

func (*ScanBase) Descriptor deprecated 

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

Deprecated: Use ScanBase.ProtoReflect.Descriptor instead.

func (*ScanBase) GetDatabase 

func (x *ScanBase) GetDatabase() string

func (*ScanBase) GetTable 

func (x *ScanBase) GetTable() string

func (*ScanBase) MarshalToSizedBufferVT 

func (m *ScanBase) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ScanBase) MarshalToVT 

func (m *ScanBase) MarshalToVT(dAtA []byte) (int, error)

func (*ScanBase) MarshalVT 

func (m *ScanBase) MarshalVT() (dAtA []byte, err error)

func (*ScanBase) ProtoMessage 

func (*ScanBase) ProtoMessage()

func (*ScanBase) ProtoReflect 

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

func (*ScanBase) Reset 

func (x *ScanBase) Reset()

func (*ScanBase) SizeVT 

func (m *ScanBase) SizeVT() (n int)

func (*ScanBase) String 

func (x *ScanBase) String() string

func (*ScanBase) UnmarshalVT 

func (m *ScanBase) UnmarshalVT(dAtA []byte) error

type SchemaScan 

type SchemaScan struct {

	// Base specifies the fields shared with TableScan.
	Base *ScanBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// contains filtered or unexported fields
}

SchemaScan describes scanning a table to obtain the schema.

func (*SchemaScan) Descriptor deprecated 

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

Deprecated: Use SchemaScan.ProtoReflect.Descriptor instead.

func (*SchemaScan) GetBase 

func (x *SchemaScan) GetBase() *ScanBase

func (*SchemaScan) MarshalToSizedBufferVT 

func (m *SchemaScan) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SchemaScan) MarshalToVT 

func (m *SchemaScan) MarshalToVT(dAtA []byte) (int, error)

func (*SchemaScan) MarshalVT 

func (m *SchemaScan) MarshalVT() (dAtA []byte, err error)

func (*SchemaScan) ProtoMessage 

func (*SchemaScan) ProtoMessage()

func (*SchemaScan) ProtoReflect 

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

func (*SchemaScan) Reset 

func (x *SchemaScan) Reset()

func (*SchemaScan) SizeVT 

func (m *SchemaScan) SizeVT() (n int)

func (*SchemaScan) String 

func (x *SchemaScan) String() string

func (*SchemaScan) UnmarshalVT 

func (m *SchemaScan) UnmarshalVT(dAtA []byte) error

type TableScan 

type TableScan struct {

	// Base specifies the fields shared with SchemaScan.
	Base *ScanBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// contains filtered or unexported fields
}

TableScan describes scanning a table to obtain rows.

func (*TableScan) Descriptor deprecated 

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

Deprecated: Use TableScan.ProtoReflect.Descriptor instead.

func (*TableScan) GetBase 

func (x *TableScan) GetBase() *ScanBase

func (*TableScan) MarshalToSizedBufferVT 

func (m *TableScan) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TableScan) MarshalToVT 

func (m *TableScan) MarshalToVT(dAtA []byte) (int, error)

func (*TableScan) MarshalVT 

func (m *TableScan) MarshalVT() (dAtA []byte, err error)

func (*TableScan) ProtoMessage 

func (*TableScan) ProtoMessage()

func (*TableScan) ProtoReflect 

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

func (*TableScan) Reset 

func (x *TableScan) Reset()

func (*TableScan) SizeVT 

func (m *TableScan) SizeVT() (n int)

func (*TableScan) String 

func (x *TableScan) String() string

func (*TableScan) UnmarshalVT 

func (m *TableScan) UnmarshalVT(dAtA []byte) error

type Type 

type Type int32

Apache Arrow type. 

const (
	// The default value, this must not occur.
	Type_TYPE_UNKNOWN_UNSPECIFIED Type = 0
	// Float64
	Type_TYPE_FLOAT64 Type = 1
)

func (Type) Descriptor 

func (Type) Descriptor() protoreflect.EnumDescriptor

func (Type) Enum 

func (x Type) Enum() *Type

func (Type) EnumDescriptor deprecated 

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

Deprecated: Use Type.Descriptor instead.

func (Type) Number 

func (x Type) Number() protoreflect.EnumNumber

func (Type) String 

func (x Type) String() string

func (Type) Type 

func (Type) Type() protoreflect.EnumType

type UnimplementedFrostDBServiceServer 

type UnimplementedFrostDBServiceServer struct {
}

UnimplementedFrostDBServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFrostDBServiceServer) Query 

func (UnimplementedFrostDBServiceServer) Query(*QueryRequest, FrostDBService_QueryServer) error

type UnsafeFrostDBServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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