sqlpb

package
v0.0.0-...-aac2b88 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ValueType_Enum_name = map[int32]string{
		0: "NULL",
		1: "BOOL",
		2: "INT",
		3: "FLOAT",
		4: "STRING",
	}
	ValueType_Enum_value = map[string]int32{
		"NULL":   0,
		"BOOL":   1,
		"INT":    2,
		"FLOAT":  3,
		"STRING": 4,
	}
)

Enum value maps for ValueType_Enum.

View Source 
var File_sql_sqlpb_sql_proto protoreflect.FileDescriptor
View Source 
var SQL_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "toydb.sqlpb.SQL",
	HandlerType: (*SQLServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Status",
			Handler:    _SQL_Status_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Execute",
			Handler:       _SQL_Execute_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "sql/sqlpb/sql.proto",
}

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

Functions

func RegisterSQLServer 

func RegisterSQLServer(s grpc.ServiceRegistrar, srv SQLServer)

Types

type Column 

type Column struct {
	Name       string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Datatype   ValueType_Enum `protobuf:"varint,2,opt,name=datatype,proto3,enum=toydb.sqlpb.ValueType_Enum" json:"datatype,omitempty"`
	PrimaryKey bool           `protobuf:"varint,3,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	Nullable   bool           `protobuf:"varint,4,opt,name=nullable,proto3" json:"nullable,omitempty"`
	Default    *Value         `protobuf:"bytes,5,opt,name=default,proto3" json:"default,omitempty"`
	Unique     bool           `protobuf:"varint,6,opt,name=unique,proto3" json:"unique,omitempty"`
	References string         `protobuf:"bytes,7,opt,name=references,proto3" json:"references,omitempty"`
	Index      bool           `protobuf:"varint,8,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetDatatype 

func (x *Column) GetDatatype() ValueType_Enum

func (*Column) GetDefault 

func (x *Column) GetDefault() *Value

func (*Column) GetIndex 

func (x *Column) GetIndex() bool

func (*Column) GetName 

func (x *Column) GetName() string

func (*Column) GetNullable 

func (x *Column) GetNullable() bool

func (*Column) GetPrimaryKey 

func (x *Column) GetPrimaryKey() bool

func (*Column) GetReferences 

func (x *Column) GetReferences() string

func (*Column) GetUnique 

func (x *Column) GetUnique() bool

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect 

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

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) String 

func (x *Column) String() string

type ExecuteRequest 

type ExecuteRequest struct {
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetQuery 

func (x *ExecuteRequest) GetQuery() string

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect 

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

func (*ExecuteRequest) Reset 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

type ExecuteResponse 

type ExecuteResponse struct {

	// Types that are assignable to Result:
	//
	//	*ExecuteResponse_MutateResult
	//	*ExecuteResponse_QueryResult
	//	*ExecuteResponse_Error
	Result isExecuteResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*ExecuteResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetError 

func (x *ExecuteResponse) GetError() string

func (*ExecuteResponse) GetMutateResult 

func (x *ExecuteResponse) GetMutateResult() *MutateResult

func (*ExecuteResponse) GetQueryResult 

func (x *ExecuteResponse) GetQueryResult() *QueryResult

func (*ExecuteResponse) GetResult 

func (m *ExecuteResponse) GetResult() isExecuteResponse_Result

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect 

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

func (*ExecuteResponse) Reset 

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (x *ExecuteResponse) String() string

type ExecuteResponse_Error 

type ExecuteResponse_Error struct {
	Error string `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}

type ExecuteResponse_MutateResult 

type ExecuteResponse_MutateResult struct {
	MutateResult *MutateResult `protobuf:"bytes,1,opt,name=mutate_result,json=mutateResult,proto3,oneof"`
}

type ExecuteResponse_QueryResult 

type ExecuteResponse_QueryResult struct {
	QueryResult *QueryResult `protobuf:"bytes,2,opt,name=query_result,json=queryResult,proto3,oneof"`
}

type MutateResult 

type MutateResult struct {
	LastInsertId int64 `protobuf:"varint,1,opt,name=last_insert_id,json=lastInsertId,proto3" json:"last_insert_id,omitempty"`
	RowsAffected int64 `protobuf:"varint,2,opt,name=rows_affected,json=rowsAffected,proto3" json:"rows_affected,omitempty"`
	// contains filtered or unexported fields
}

func (*MutateResult) Descriptor deprecated 

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

Deprecated: Use MutateResult.ProtoReflect.Descriptor instead.

func (*MutateResult) GetLastInsertId 

func (x *MutateResult) GetLastInsertId() int64

func (*MutateResult) GetRowsAffected 

func (x *MutateResult) GetRowsAffected() int64

func (*MutateResult) ProtoMessage 

func (*MutateResult) ProtoMessage()

func (*MutateResult) ProtoReflect 

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

func (*MutateResult) Reset 

func (x *MutateResult) Reset()

func (*MutateResult) String 

func (x *MutateResult) String() string

type Mutation 

type Mutation struct {

	// Types that are assignable to Command:
	//
	//	*Mutation_Begin_
	//	*Mutation_Commit_
	//	*Mutation_Rollback_
	//	*Mutation_Create_
	//	*Mutation_Delete_
	//	*Mutation_Update_
	//	*Mutation_CreateTable_
	//	*Mutation_DeleteTable_
	Command isMutation_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

func (*Mutation) Descriptor deprecated 

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

Deprecated: Use Mutation.ProtoReflect.Descriptor instead.

func (*Mutation) GetBegin 

func (x *Mutation) GetBegin() *Mutation_Begin

func (*Mutation) GetCommand 

func (m *Mutation) GetCommand() isMutation_Command

func (*Mutation) GetCommit 

func (x *Mutation) GetCommit() *Mutation_Commit

func (*Mutation) GetCreate 

func (x *Mutation) GetCreate() *Mutation_Create

func (*Mutation) GetCreateTable 

func (x *Mutation) GetCreateTable() *Mutation_CreateTable

func (*Mutation) GetDelete 

func (x *Mutation) GetDelete() *Mutation_Delete

func (*Mutation) GetDeleteTable 

func (x *Mutation) GetDeleteTable() *Mutation_DeleteTable

func (*Mutation) GetRollback 

func (x *Mutation) GetRollback() *Mutation_Rollback

func (*Mutation) GetUpdate 

func (x *Mutation) GetUpdate() *Mutation_Update

func (*Mutation) ProtoMessage 

func (*Mutation) ProtoMessage()

func (*Mutation) ProtoReflect 

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

func (*Mutation) Reset 

func (x *Mutation) Reset()

func (*Mutation) String 

func (x *Mutation) String() string

type Mutation_Begin 

type Mutation_Begin struct {
	ReadOnly bool   `protobuf:"varint,1,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	AsOf     uint64 `protobuf:"varint,2,opt,name=as_of,json=asOf,proto3" json:"as_of,omitempty"`
	// contains filtered or unexported fields
}

func (*Mutation_Begin) Descriptor deprecated 

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

Deprecated: Use Mutation_Begin.ProtoReflect.Descriptor instead.

func (*Mutation_Begin) GetAsOf 

func (x *Mutation_Begin) GetAsOf() uint64

func (*Mutation_Begin) GetReadOnly 

func (x *Mutation_Begin) GetReadOnly() bool

func (*Mutation_Begin) ProtoMessage 

func (*Mutation_Begin) ProtoMessage()

func (*Mutation_Begin) ProtoReflect 

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

func (*Mutation_Begin) Reset 

func (x *Mutation_Begin) Reset()

func (*Mutation_Begin) String 

func (x *Mutation_Begin) String() string

type Mutation_Begin_ 

type Mutation_Begin_ struct {
	Begin *Mutation_Begin `protobuf:"bytes,1,opt,name=begin,proto3,oneof"`
}

type Mutation_Commit 

type Mutation_Commit struct {
	Txn *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	// contains filtered or unexported fields
}

func (*Mutation_Commit) Descriptor deprecated 

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

Deprecated: Use Mutation_Commit.ProtoReflect.Descriptor instead.

func (*Mutation_Commit) GetTxn 

func (x *Mutation_Commit) GetTxn() *storagepb.MVCCTxnState

func (*Mutation_Commit) ProtoMessage 

func (*Mutation_Commit) ProtoMessage()

func (*Mutation_Commit) ProtoReflect 

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

func (*Mutation_Commit) Reset 

func (x *Mutation_Commit) Reset()

func (*Mutation_Commit) String 

func (x *Mutation_Commit) String() string

type Mutation_Commit_ 

type Mutation_Commit_ struct {
	Commit *Mutation_Commit `protobuf:"bytes,2,opt,name=commit,proto3,oneof"`
}

type Mutation_Create 

type Mutation_Create struct {
	Txn   *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	Table string                  `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Row   *Row                    `protobuf:"bytes,3,opt,name=row,proto3" json:"row,omitempty"`
	// contains filtered or unexported fields
}

func (*Mutation_Create) Descriptor deprecated 

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

Deprecated: Use Mutation_Create.ProtoReflect.Descriptor instead.

func (*Mutation_Create) GetRow 

func (x *Mutation_Create) GetRow() *Row

func (*Mutation_Create) GetTable 

func (x *Mutation_Create) GetTable() string

func (*Mutation_Create) GetTxn 

func (x *Mutation_Create) GetTxn() *storagepb.MVCCTxnState

func (*Mutation_Create) ProtoMessage 

func (*Mutation_Create) ProtoMessage()

func (*Mutation_Create) ProtoReflect 

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

func (*Mutation_Create) Reset 

func (x *Mutation_Create) Reset()

func (*Mutation_Create) String 

func (x *Mutation_Create) String() string

type Mutation_CreateTable 

type Mutation_CreateTable struct {
	Txn   *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	Table *Table                  `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*Mutation_CreateTable) Descriptor deprecated 

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

Deprecated: Use Mutation_CreateTable.ProtoReflect.Descriptor instead.

func (*Mutation_CreateTable) GetTable 

func (x *Mutation_CreateTable) GetTable() *Table

func (*Mutation_CreateTable) GetTxn 

func (x *Mutation_CreateTable) GetTxn() *storagepb.MVCCTxnState

func (*Mutation_CreateTable) ProtoMessage 

func (*Mutation_CreateTable) ProtoMessage()

func (*Mutation_CreateTable) ProtoReflect 

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

func (*Mutation_CreateTable) Reset 

func (x *Mutation_CreateTable) Reset()

func (*Mutation_CreateTable) String 

func (x *Mutation_CreateTable) String() string

type Mutation_CreateTable_ 

type Mutation_CreateTable_ struct {
	CreateTable *Mutation_CreateTable `protobuf:"bytes,7,opt,name=create_table,json=createTable,proto3,oneof"`
}

type Mutation_Create_ 

type Mutation_Create_ struct {
	Create *Mutation_Create `protobuf:"bytes,4,opt,name=create,proto3,oneof"`
}

type Mutation_Delete 

type Mutation_Delete struct {
	Txn   *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	Table string                  `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Id    *Value                  `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*Mutation_Delete) Descriptor deprecated 

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

Deprecated: Use Mutation_Delete.ProtoReflect.Descriptor instead.

func (*Mutation_Delete) GetId 

func (x *Mutation_Delete) GetId() *Value

func (*Mutation_Delete) GetTable 

func (x *Mutation_Delete) GetTable() string

func (*Mutation_Delete) GetTxn 

func (x *Mutation_Delete) GetTxn() *storagepb.MVCCTxnState

func (*Mutation_Delete) ProtoMessage 

func (*Mutation_Delete) ProtoMessage()

func (*Mutation_Delete) ProtoReflect 

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

func (*Mutation_Delete) Reset 

func (x *Mutation_Delete) Reset()

func (*Mutation_Delete) String 

func (x *Mutation_Delete) String() string

type Mutation_DeleteTable 

type Mutation_DeleteTable struct {
	Txn   *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	Table string                  `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*Mutation_DeleteTable) Descriptor deprecated 

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

Deprecated: Use Mutation_DeleteTable.ProtoReflect.Descriptor instead.

func (*Mutation_DeleteTable) GetTable 

func (x *Mutation_DeleteTable) GetTable() string

func (*Mutation_DeleteTable) GetTxn 

func (x *Mutation_DeleteTable) GetTxn() *storagepb.MVCCTxnState

func (*Mutation_DeleteTable) ProtoMessage 

func (*Mutation_DeleteTable) ProtoMessage()

func (*Mutation_DeleteTable) ProtoReflect 

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

func (*Mutation_DeleteTable) Reset 

func (x *Mutation_DeleteTable) Reset()

func (*Mutation_DeleteTable) String 

func (x *Mutation_DeleteTable) String() string

type Mutation_DeleteTable_ 

type Mutation_DeleteTable_ struct {
	DeleteTable *Mutation_DeleteTable `protobuf:"bytes,8,opt,name=delete_table,json=deleteTable,proto3,oneof"`
}

type Mutation_Delete_ 

type Mutation_Delete_ struct {
	Delete *Mutation_Delete `protobuf:"bytes,5,opt,name=delete,proto3,oneof"`
}

type Mutation_Rollback 

type Mutation_Rollback struct {
	Txn *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	// contains filtered or unexported fields
}

func (*Mutation_Rollback) Descriptor deprecated 

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

Deprecated: Use Mutation_Rollback.ProtoReflect.Descriptor instead.

func (*Mutation_Rollback) GetTxn 

func (x *Mutation_Rollback) GetTxn() *storagepb.MVCCTxnState

func (*Mutation_Rollback) ProtoMessage 

func (*Mutation_Rollback) ProtoMessage()

func (*Mutation_Rollback) ProtoReflect 

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

func (*Mutation_Rollback) Reset 

func (x *Mutation_Rollback) Reset()

func (*Mutation_Rollback) String 

func (x *Mutation_Rollback) String() string

type Mutation_Rollback_ 

type Mutation_Rollback_ struct {
	Rollback *Mutation_Rollback `protobuf:"bytes,3,opt,name=rollback,proto3,oneof"`
}

type Mutation_Update 

type Mutation_Update struct {
	Txn   *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	Table string                  `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Id    *Value                  `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Row   *Row                    `protobuf:"bytes,4,opt,name=row,proto3" json:"row,omitempty"`
	// contains filtered or unexported fields
}

func (*Mutation_Update) Descriptor deprecated 

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

Deprecated: Use Mutation_Update.ProtoReflect.Descriptor instead.

func (*Mutation_Update) GetId 

func (x *Mutation_Update) GetId() *Value

func (*Mutation_Update) GetRow 

func (x *Mutation_Update) GetRow() *Row

func (*Mutation_Update) GetTable 

func (x *Mutation_Update) GetTable() string

func (*Mutation_Update) GetTxn 

func (x *Mutation_Update) GetTxn() *storagepb.MVCCTxnState

func (*Mutation_Update) ProtoMessage 

func (*Mutation_Update) ProtoMessage()

func (*Mutation_Update) ProtoReflect 

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

func (*Mutation_Update) Reset 

func (x *Mutation_Update) Reset()

func (*Mutation_Update) String 

func (x *Mutation_Update) String() string

type Mutation_Update_ 

type Mutation_Update_ struct {
	Update *Mutation_Update `protobuf:"bytes,6,opt,name=update,proto3,oneof"`
}

type Query 

type Query struct {

	// Types that are assignable to Command:
	//
	//	*Query_Status_
	//	*Query_Read_
	//	*Query_ReadIndex_
	//	*Query_Scan_
	//	*Query_ScanIndex_
	//	*Query_ScanTables_
	//	*Query_ReadTable_
	Command isQuery_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated 

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetCommand 

func (m *Query) GetCommand() isQuery_Command

func (*Query) GetRead 

func (x *Query) GetRead() *Query_Read

func (*Query) GetReadIndex 

func (x *Query) GetReadIndex() *Query_ReadIndex

func (*Query) GetReadTable 

func (x *Query) GetReadTable() *Query_ReadTable

func (*Query) GetScan 

func (x *Query) GetScan() *Query_Scan

func (*Query) GetScanIndex 

func (x *Query) GetScanIndex() *Query_ScanIndex

func (*Query) GetScanTables 

func (x *Query) GetScanTables() *Query_ScanTables

func (*Query) GetStatus 

func (x *Query) GetStatus() *Query_Status

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

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

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) String 

func (x *Query) String() string

type QueryResult 

type QueryResult struct {
	Columns []string `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	Rows    []*Row   `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResult) Descriptor deprecated 

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

Deprecated: Use QueryResult.ProtoReflect.Descriptor instead.

func (*QueryResult) GetColumns 

func (x *QueryResult) GetColumns() []string

func (*QueryResult) GetRows 

func (x *QueryResult) GetRows() []*Row

func (*QueryResult) ProtoMessage 

func (*QueryResult) ProtoMessage()

func (*QueryResult) ProtoReflect 

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

func (*QueryResult) Reset 

func (x *QueryResult) Reset()

func (*QueryResult) String 

func (x *QueryResult) String() string

type Query_Read 

type Query_Read struct {
	Txn   *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	Table string                  `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Id    *Value                  `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*Query_Read) Descriptor deprecated 

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

Deprecated: Use Query_Read.ProtoReflect.Descriptor instead.

func (*Query_Read) GetId 

func (x *Query_Read) GetId() *Value

func (*Query_Read) GetTable 

func (x *Query_Read) GetTable() string

func (*Query_Read) GetTxn 

func (x *Query_Read) GetTxn() *storagepb.MVCCTxnState

func (*Query_Read) ProtoMessage 

func (*Query_Read) ProtoMessage()

func (*Query_Read) ProtoReflect 

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

func (*Query_Read) Reset 

func (x *Query_Read) Reset()

func (*Query_Read) String 

func (x *Query_Read) String() string

type Query_ReadIndex 

type Query_ReadIndex struct {
	Txn    *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	Table  string                  `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Column string                  `protobuf:"bytes,3,opt,name=column,proto3" json:"column,omitempty"`
	Value  *Value                  `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Query_ReadIndex) Descriptor deprecated 

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

Deprecated: Use Query_ReadIndex.ProtoReflect.Descriptor instead.

func (*Query_ReadIndex) GetColumn 

func (x *Query_ReadIndex) GetColumn() string

func (*Query_ReadIndex) GetTable 

func (x *Query_ReadIndex) GetTable() string

func (*Query_ReadIndex) GetTxn 

func (x *Query_ReadIndex) GetTxn() *storagepb.MVCCTxnState

func (*Query_ReadIndex) GetValue 

func (x *Query_ReadIndex) GetValue() *Value

func (*Query_ReadIndex) ProtoMessage 

func (*Query_ReadIndex) ProtoMessage()

func (*Query_ReadIndex) ProtoReflect 

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

func (*Query_ReadIndex) Reset 

func (x *Query_ReadIndex) Reset()

func (*Query_ReadIndex) String 

func (x *Query_ReadIndex) String() string

type Query_ReadIndex_ 

type Query_ReadIndex_ struct {
	ReadIndex *Query_ReadIndex `protobuf:"bytes,3,opt,name=read_index,json=readIndex,proto3,oneof"`
}

type Query_ReadTable 

type Query_ReadTable struct {
	Txn   *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	Table string                  `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*Query_ReadTable) Descriptor deprecated 

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

Deprecated: Use Query_ReadTable.ProtoReflect.Descriptor instead.

func (*Query_ReadTable) GetTable 

func (x *Query_ReadTable) GetTable() string

func (*Query_ReadTable) GetTxn 

func (x *Query_ReadTable) GetTxn() *storagepb.MVCCTxnState

func (*Query_ReadTable) ProtoMessage 

func (*Query_ReadTable) ProtoMessage()

func (*Query_ReadTable) ProtoReflect 

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

func (*Query_ReadTable) Reset 

func (x *Query_ReadTable) Reset()

func (*Query_ReadTable) String 

func (x *Query_ReadTable) String() string

type Query_ReadTable_ 

type Query_ReadTable_ struct {
	ReadTable *Query_ReadTable `protobuf:"bytes,7,opt,name=read_table,json=readTable,proto3,oneof"`
}

type Query_Read_ 

type Query_Read_ struct {
	Read *Query_Read `protobuf:"bytes,2,opt,name=read,proto3,oneof"`
}

type Query_Scan 

type Query_Scan struct {
	Txn    *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	Table  string                  `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Filter string                  `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*Query_Scan) Descriptor deprecated 

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

Deprecated: Use Query_Scan.ProtoReflect.Descriptor instead.

func (*Query_Scan) GetFilter 

func (x *Query_Scan) GetFilter() string

func (*Query_Scan) GetTable 

func (x *Query_Scan) GetTable() string

func (*Query_Scan) GetTxn 

func (x *Query_Scan) GetTxn() *storagepb.MVCCTxnState

func (*Query_Scan) ProtoMessage 

func (*Query_Scan) ProtoMessage()

func (*Query_Scan) ProtoReflect 

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

func (*Query_Scan) Reset 

func (x *Query_Scan) Reset()

func (*Query_Scan) String 

func (x *Query_Scan) String() string

type Query_ScanIndex 

type Query_ScanIndex struct {
	Txn    *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	Table  string                  `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Column string                  `protobuf:"bytes,3,opt,name=column,proto3" json:"column,omitempty"`
	// contains filtered or unexported fields
}

func (*Query_ScanIndex) Descriptor deprecated 

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

Deprecated: Use Query_ScanIndex.ProtoReflect.Descriptor instead.

func (*Query_ScanIndex) GetColumn 

func (x *Query_ScanIndex) GetColumn() string

func (*Query_ScanIndex) GetTable 

func (x *Query_ScanIndex) GetTable() string

func (*Query_ScanIndex) GetTxn 

func (x *Query_ScanIndex) GetTxn() *storagepb.MVCCTxnState

func (*Query_ScanIndex) ProtoMessage 

func (*Query_ScanIndex) ProtoMessage()

func (*Query_ScanIndex) ProtoReflect 

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

func (*Query_ScanIndex) Reset 

func (x *Query_ScanIndex) Reset()

func (*Query_ScanIndex) String 

func (x *Query_ScanIndex) String() string

type Query_ScanIndex_ 

type Query_ScanIndex_ struct {
	ScanIndex *Query_ScanIndex `protobuf:"bytes,5,opt,name=scan_index,json=scanIndex,proto3,oneof"`
}

type Query_ScanTables 

type Query_ScanTables struct {
	Txn *storagepb.MVCCTxnState `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	// contains filtered or unexported fields
}

func (*Query_ScanTables) Descriptor deprecated 

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

Deprecated: Use Query_ScanTables.ProtoReflect.Descriptor instead.

func (*Query_ScanTables) GetTxn 

func (x *Query_ScanTables) GetTxn() *storagepb.MVCCTxnState

func (*Query_ScanTables) ProtoMessage 

func (*Query_ScanTables) ProtoMessage()

func (*Query_ScanTables) ProtoReflect 

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

func (*Query_ScanTables) Reset 

func (x *Query_ScanTables) Reset()

func (*Query_ScanTables) String 

func (x *Query_ScanTables) String() string

type Query_ScanTables_ 

type Query_ScanTables_ struct {
	ScanTables *Query_ScanTables `protobuf:"bytes,6,opt,name=scan_tables,json=scanTables,proto3,oneof"`
}

type Query_Scan_ 

type Query_Scan_ struct {
	Scan *Query_Scan `protobuf:"bytes,4,opt,name=scan,proto3,oneof"`
}

type Query_Status 

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

func (*Query_Status) Descriptor deprecated 

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

Deprecated: Use Query_Status.ProtoReflect.Descriptor instead.

func (*Query_Status) ProtoMessage 

func (*Query_Status) ProtoMessage()

func (*Query_Status) ProtoReflect 

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

func (*Query_Status) Reset 

func (x *Query_Status) Reset()

func (*Query_Status) String 

func (x *Query_Status) String() string

type Query_Status_ 

type Query_Status_ struct {
	Status *Query_Status `protobuf:"bytes,1,opt,name=status,proto3,oneof"`
}

type Row 

type Row struct {
	Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Row) Descriptor deprecated 

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

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetValues 

func (x *Row) GetValues() []*Value

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect 

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

func (*Row) Reset 

func (x *Row) Reset()

func (*Row) String 

func (x *Row) String() string

type SQLClient 

type SQLClient interface {
	Execute(ctx context.Context, opts ...grpc.CallOption) (SQL_ExecuteClient, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

SQLClient is the client API for SQL 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 NewSQLClient 

func NewSQLClient(cc grpc.ClientConnInterface) SQLClient

type SQLServer 

type SQLServer interface {
	Execute(SQL_ExecuteServer) error
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
}

SQLServer is the server API for SQL service. All implementations should embed UnimplementedSQLServer for forward compatibility

type SQL_ExecuteClient 

type SQL_ExecuteClient interface {
	Send(*ExecuteRequest) error
	Recv() (*ExecuteResponse, error)
	grpc.ClientStream
}

type SQL_ExecuteServer 

type SQL_ExecuteServer interface {
	Send(*ExecuteResponse) error
	Recv() (*ExecuteRequest, error)
	grpc.ServerStream
}

type StatusRequest 

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

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	Raft *raftpb.Status `protobuf:"bytes,1,opt,name=raft,proto3" json:"raft,omitempty"`
	Mvcc string         `protobuf:"bytes,2,opt,name=mvcc,proto3" json:"mvcc,omitempty"` // TODO: Use concrete type
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetMvcc 

func (x *StatusResponse) GetMvcc() string

func (*StatusResponse) GetRaft 

func (x *StatusResponse) GetRaft() *raftpb.Status

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type Table 

type Table struct {
	Name    string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Columns []*Column `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*Table) Descriptor deprecated 

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetColumns 

func (x *Table) GetColumns() []*Column

func (*Table) GetName 

func (x *Table) GetName() string

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect 

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

func (*Table) Reset 

func (x *Table) Reset()

func (*Table) String 

func (x *Table) String() string

type UnimplementedSQLServer 

type UnimplementedSQLServer struct {
}

UnimplementedSQLServer should be embedded to have forward compatible implementations.

func (UnimplementedSQLServer) Execute 

func (UnimplementedSQLServer) Execute(SQL_ExecuteServer) error

func (UnimplementedSQLServer) Status 

func (UnimplementedSQLServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

type UnsafeSQLServer 

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

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

type Value 

type Value struct {

	// Types that are assignable to Union:
	//
	//	*Value_Null
	//	*Value_Bool
	//	*Value_Int
	//	*Value_Float
	//	*Value_String_
	Union isValue_Union `protobuf_oneof:"union"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBool 

func (x *Value) GetBool() bool

func (*Value) GetFloat 

func (x *Value) GetFloat() float64

func (*Value) GetInt 

func (x *Value) GetInt() int64

func (*Value) GetNull 

func (x *Value) GetNull() bool

func (*Value) GetString_ 

func (x *Value) GetString_() string

func (*Value) GetUnion 

func (m *Value) GetUnion() isValue_Union

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

func (*Value) Type 

func (v *Value) Type() ValueType_Enum

type ValueType 

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

func (*ValueType) Descriptor deprecated 

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

Deprecated: Use ValueType.ProtoReflect.Descriptor instead.

func (*ValueType) ProtoMessage 

func (*ValueType) ProtoMessage()

func (*ValueType) ProtoReflect 

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

func (*ValueType) Reset 

func (x *ValueType) Reset()

func (*ValueType) String 

func (x *ValueType) String() string

type ValueType_Enum 

type ValueType_Enum int32
const (
	ValueType_NULL   ValueType_Enum = 0
	ValueType_BOOL   ValueType_Enum = 1
	ValueType_INT    ValueType_Enum = 2
	ValueType_FLOAT  ValueType_Enum = 3
	ValueType_STRING ValueType_Enum = 4
)

func (ValueType_Enum) Descriptor 

func (ValueType_Enum) Descriptor() protoreflect.EnumDescriptor

func (ValueType_Enum) Enum 

func (x ValueType_Enum) Enum() *ValueType_Enum

func (ValueType_Enum) EnumDescriptor deprecated 

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

Deprecated: Use ValueType_Enum.Descriptor instead.

func (ValueType_Enum) Number 

func (x ValueType_Enum) Number() protoreflect.EnumNumber

func (ValueType_Enum) String 

func (x ValueType_Enum) String() string

func (ValueType_Enum) Type 

func (ValueType_Enum) Type() protoreflect.EnumType

type Value_Bool 

type Value_Bool struct {
	Bool bool `protobuf:"varint,2,opt,name=bool,proto3,oneof"`
}

type Value_Float 

type Value_Float struct {
	Float float64 `protobuf:"fixed64,4,opt,name=float,proto3,oneof"`
}

type Value_Int 

type Value_Int struct {
	Int int64 `protobuf:"varint,3,opt,name=int,proto3,oneof"`
}

type Value_Null 

type Value_Null struct {
	Null bool `protobuf:"varint,1,opt,name=null,proto3,oneof"`
}

type Value_String_ 

type Value_String_ struct {
	String_ string `protobuf:"bytes,5,opt,name=string,proto3,oneof"`
}

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.