querypb

package
v0.446.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TransactionStatus_name = map[int32]string{
		0: "TRANSACTION_STATUS_UNSPECIFIED",
		1: "TRANSACTION_STATUS_SUCCESS",
		2: "TRANSACTION_STATUS_FAILED",
	}
	TransactionStatus_value = map[string]int32{
		"TRANSACTION_STATUS_UNSPECIFIED": 0,
		"TRANSACTION_STATUS_SUCCESS":     1,
		"TRANSACTION_STATUS_FAILED":      2,
	}
)

Enum value maps for TransactionStatus.

View Source 
var (
	CommandType_name = map[int32]string{
		0: "COMMAND_TYPE_UNSPECIFIED",
		1: "COMMAND_TYPE_EXEC",
		2: "COMMAND_TYPE_ONE",
		3: "COMMAND_TYPE_MANY",
	}
	CommandType_value = map[string]int32{
		"COMMAND_TYPE_UNSPECIFIED": 0,
		"COMMAND_TYPE_EXEC":        1,
		"COMMAND_TYPE_ONE":         2,
		"COMMAND_TYPE_MANY":        3,
	}
)

Enum value maps for CommandType.

View Source 
var File_xyz_block_ftl_query_v1_query_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BeginTransactionRequest 

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

func (*BeginTransactionRequest) Descriptor deprecated 

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

Deprecated: Use BeginTransactionRequest.ProtoReflect.Descriptor instead.

func (*BeginTransactionRequest) ProtoMessage 

func (*BeginTransactionRequest) ProtoMessage()

func (*BeginTransactionRequest) ProtoReflect 

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

func (*BeginTransactionRequest) Reset 

func (x *BeginTransactionRequest) Reset()

func (*BeginTransactionRequest) String 

func (x *BeginTransactionRequest) String() string

type BeginTransactionResponse 

type BeginTransactionResponse struct {
	TransactionId string            `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	Status        TransactionStatus `protobuf:"varint,2,opt,name=status,proto3,enum=xyz.block.ftl.query.v1.TransactionStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*BeginTransactionResponse) Descriptor deprecated 

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

Deprecated: Use BeginTransactionResponse.ProtoReflect.Descriptor instead.

func (*BeginTransactionResponse) GetStatus 

func (x *BeginTransactionResponse) GetStatus() TransactionStatus

func (*BeginTransactionResponse) GetTransactionId 

func (x *BeginTransactionResponse) GetTransactionId() string

func (*BeginTransactionResponse) ProtoMessage 

func (*BeginTransactionResponse) ProtoMessage()

func (*BeginTransactionResponse) ProtoReflect 

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

func (*BeginTransactionResponse) Reset 

func (x *BeginTransactionResponse) Reset()

func (*BeginTransactionResponse) String 

func (x *BeginTransactionResponse) String() string

type CommandType 

type CommandType int32
const (
	CommandType_COMMAND_TYPE_UNSPECIFIED CommandType = 0
	CommandType_COMMAND_TYPE_EXEC        CommandType = 1
	CommandType_COMMAND_TYPE_ONE         CommandType = 2
	CommandType_COMMAND_TYPE_MANY        CommandType = 3
)

func (CommandType) Descriptor 

func (CommandType) Descriptor() protoreflect.EnumDescriptor

func (CommandType) Enum 

func (x CommandType) Enum() *CommandType

func (CommandType) EnumDescriptor deprecated 

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

Deprecated: Use CommandType.Descriptor instead.

func (CommandType) Number 

func (x CommandType) Number() protoreflect.EnumNumber

func (CommandType) String 

func (x CommandType) String() string

func (CommandType) Type 

func (CommandType) Type() protoreflect.EnumType

type CommitTransactionRequest 

type CommitTransactionRequest struct {
	TransactionId string `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitTransactionRequest) Descriptor deprecated 

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

Deprecated: Use CommitTransactionRequest.ProtoReflect.Descriptor instead.

func (*CommitTransactionRequest) GetTransactionId 

func (x *CommitTransactionRequest) GetTransactionId() string

func (*CommitTransactionRequest) ProtoMessage 

func (*CommitTransactionRequest) ProtoMessage()

func (*CommitTransactionRequest) ProtoReflect 

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

func (*CommitTransactionRequest) Reset 

func (x *CommitTransactionRequest) Reset()

func (*CommitTransactionRequest) String 

func (x *CommitTransactionRequest) String() string

type CommitTransactionResponse 

type CommitTransactionResponse struct {
	Status TransactionStatus `protobuf:"varint,1,opt,name=status,proto3,enum=xyz.block.ftl.query.v1.TransactionStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitTransactionResponse) Descriptor deprecated 

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

Deprecated: Use CommitTransactionResponse.ProtoReflect.Descriptor instead.

func (*CommitTransactionResponse) GetStatus 

func (x *CommitTransactionResponse) GetStatus() TransactionStatus

func (*CommitTransactionResponse) ProtoMessage 

func (*CommitTransactionResponse) ProtoMessage()

func (*CommitTransactionResponse) ProtoReflect 

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

func (*CommitTransactionResponse) Reset 

func (x *CommitTransactionResponse) Reset()

func (*CommitTransactionResponse) String 

func (x *CommitTransactionResponse) String() string

type ExecResult 

type ExecResult struct {
	RowsAffected int64  `protobuf:"varint,1,opt,name=rows_affected,json=rowsAffected,proto3" json:"rows_affected,omitempty"`
	LastInsertId *int64 `protobuf:"varint,2,opt,name=last_insert_id,json=lastInsertId,proto3,oneof" json:"last_insert_id,omitempty"` // Only for some databases like MySQL
	// contains filtered or unexported fields
}

func (*ExecResult) Descriptor deprecated 

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

Deprecated: Use ExecResult.ProtoReflect.Descriptor instead.

func (*ExecResult) GetLastInsertId 

func (x *ExecResult) GetLastInsertId() int64

func (*ExecResult) GetRowsAffected 

func (x *ExecResult) GetRowsAffected() int64

func (*ExecResult) ProtoMessage 

func (*ExecResult) ProtoMessage()

func (*ExecResult) ProtoReflect 

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

func (*ExecResult) Reset 

func (x *ExecResult) Reset()

func (*ExecResult) String 

func (x *ExecResult) String() string

type ExecuteQueryRequest 

type ExecuteQueryRequest struct {
	RawSql         string          `protobuf:"bytes,1,opt,name=raw_sql,json=rawSql,proto3" json:"raw_sql,omitempty"`
	CommandType    CommandType     ``                                                                                                        /* 135-byte string literal not displayed */
	ParametersJson string          `protobuf:"bytes,3,opt,name=parameters_json,json=parametersJson,proto3" json:"parameters_json,omitempty"` // JSON array of parameter values in order
	ResultColumns  []*ResultColumn `protobuf:"bytes,6,rep,name=result_columns,json=resultColumns,proto3" json:"result_columns,omitempty"`    // Column names to scan for the result type
	TransactionId  *string         `protobuf:"bytes,4,opt,name=transaction_id,json=transactionId,proto3,oneof" json:"transaction_id,omitempty"`
	BatchSize      *int32          `protobuf:"varint,5,opt,name=batch_size,json=batchSize,proto3,oneof" json:"batch_size,omitempty"` // Default 100 if not set
	// contains filtered or unexported fields
}

func (*ExecuteQueryRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteQueryRequest) GetBatchSize 

func (x *ExecuteQueryRequest) GetBatchSize() int32

func (*ExecuteQueryRequest) GetCommandType 

func (x *ExecuteQueryRequest) GetCommandType() CommandType

func (*ExecuteQueryRequest) GetParametersJson added in v0.435.0 

func (x *ExecuteQueryRequest) GetParametersJson() string

func (*ExecuteQueryRequest) GetRawSql 

func (x *ExecuteQueryRequest) GetRawSql() string

func (*ExecuteQueryRequest) GetResultColumns 

func (x *ExecuteQueryRequest) GetResultColumns() []*ResultColumn

func (*ExecuteQueryRequest) GetTransactionId 

func (x *ExecuteQueryRequest) GetTransactionId() string

func (*ExecuteQueryRequest) ProtoMessage 

func (*ExecuteQueryRequest) ProtoMessage()

func (*ExecuteQueryRequest) ProtoReflect 

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

func (*ExecuteQueryRequest) Reset 

func (x *ExecuteQueryRequest) Reset()

func (*ExecuteQueryRequest) String 

func (x *ExecuteQueryRequest) String() string

type ExecuteQueryResponse 

type ExecuteQueryResponse struct {

	// Types that are valid to be assigned to Result:
	//
	//	*ExecuteQueryResponse_ExecResult
	//	*ExecuteQueryResponse_RowResults
	Result isExecuteQueryResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*ExecuteQueryResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteQueryResponse.ProtoReflect.Descriptor instead.

func (*ExecuteQueryResponse) GetExecResult 

func (x *ExecuteQueryResponse) GetExecResult() *ExecResult

func (*ExecuteQueryResponse) GetResult 

func (x *ExecuteQueryResponse) GetResult() isExecuteQueryResponse_Result

func (*ExecuteQueryResponse) GetRowResults 

func (x *ExecuteQueryResponse) GetRowResults() *RowResults

func (*ExecuteQueryResponse) ProtoMessage 

func (*ExecuteQueryResponse) ProtoMessage()

func (*ExecuteQueryResponse) ProtoReflect 

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

func (*ExecuteQueryResponse) Reset 

func (x *ExecuteQueryResponse) Reset()

func (*ExecuteQueryResponse) String 

func (x *ExecuteQueryResponse) String() string

type ExecuteQueryResponse_ExecResult 

type ExecuteQueryResponse_ExecResult struct {
	// For EXEC commands
	ExecResult *ExecResult `protobuf:"bytes,1,opt,name=exec_result,json=execResult,proto3,oneof"`
}

type ExecuteQueryResponse_RowResults 

type ExecuteQueryResponse_RowResults struct {
	// For ONE/MANY commands
	RowResults *RowResults `protobuf:"bytes,2,opt,name=row_results,json=rowResults,proto3,oneof"`
}

type ResultColumn added in v0.435.0 

type ResultColumn struct {
	TypeName string `protobuf:"bytes,1,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"` // The name in the FTL-generated type
	SqlName  string `protobuf:"bytes,2,opt,name=sql_name,json=sqlName,proto3" json:"sql_name,omitempty"`    // The database column name
	// contains filtered or unexported fields
}

func (*ResultColumn) Descriptor deprecated added in v0.435.0 

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

Deprecated: Use ResultColumn.ProtoReflect.Descriptor instead.

func (*ResultColumn) GetSqlName added in v0.435.0 

func (x *ResultColumn) GetSqlName() string

func (*ResultColumn) GetTypeName added in v0.435.0 

func (x *ResultColumn) GetTypeName() string

func (*ResultColumn) ProtoMessage added in v0.435.0 

func (*ResultColumn) ProtoMessage()

func (*ResultColumn) ProtoReflect added in v0.435.0 

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

func (*ResultColumn) Reset added in v0.435.0 

func (x *ResultColumn) Reset()

func (*ResultColumn) String added in v0.435.0 

func (x *ResultColumn) String() string

type RollbackTransactionRequest 

type RollbackTransactionRequest struct {
	TransactionId string `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RollbackTransactionRequest) Descriptor deprecated 

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

Deprecated: Use RollbackTransactionRequest.ProtoReflect.Descriptor instead.

func (*RollbackTransactionRequest) GetTransactionId 

func (x *RollbackTransactionRequest) GetTransactionId() string

func (*RollbackTransactionRequest) ProtoMessage 

func (*RollbackTransactionRequest) ProtoMessage()

func (*RollbackTransactionRequest) ProtoReflect 

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

func (*RollbackTransactionRequest) Reset 

func (x *RollbackTransactionRequest) Reset()

func (*RollbackTransactionRequest) String 

func (x *RollbackTransactionRequest) String() string

type RollbackTransactionResponse 

type RollbackTransactionResponse struct {
	Status TransactionStatus `protobuf:"varint,1,opt,name=status,proto3,enum=xyz.block.ftl.query.v1.TransactionStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RollbackTransactionResponse) Descriptor deprecated 

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

Deprecated: Use RollbackTransactionResponse.ProtoReflect.Descriptor instead.

func (*RollbackTransactionResponse) GetStatus 

func (x *RollbackTransactionResponse) GetStatus() TransactionStatus

func (*RollbackTransactionResponse) ProtoMessage 

func (*RollbackTransactionResponse) ProtoMessage()

func (*RollbackTransactionResponse) ProtoReflect 

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

func (*RollbackTransactionResponse) Reset 

func (x *RollbackTransactionResponse) Reset()

func (*RollbackTransactionResponse) String 

func (x *RollbackTransactionResponse) String() string

type RowResults 

type RowResults struct {
	JsonRows string `protobuf:"bytes,1,opt,name=json_rows,json=jsonRows,proto3" json:"json_rows,omitempty"` // JSON object mapping column names to values
	HasMore  bool   `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`   // Indicates if there are more rows to fetch
	// contains filtered or unexported fields
}

func (*RowResults) Descriptor deprecated 

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

Deprecated: Use RowResults.ProtoReflect.Descriptor instead.

func (*RowResults) GetHasMore 

func (x *RowResults) GetHasMore() bool

func (*RowResults) GetJsonRows added in v0.435.0 

func (x *RowResults) GetJsonRows() string

func (*RowResults) ProtoMessage 

func (*RowResults) ProtoMessage()

func (*RowResults) ProtoReflect 

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

func (*RowResults) Reset 

func (x *RowResults) Reset()

func (*RowResults) String 

func (x *RowResults) String() string

type TransactionStatus 

type TransactionStatus int32
const (
	TransactionStatus_TRANSACTION_STATUS_UNSPECIFIED TransactionStatus = 0
	TransactionStatus_TRANSACTION_STATUS_SUCCESS     TransactionStatus = 1
	TransactionStatus_TRANSACTION_STATUS_FAILED      TransactionStatus = 2
)

func (TransactionStatus) Descriptor 

func (TransactionStatus) Descriptor() protoreflect.EnumDescriptor

func (TransactionStatus) Enum 

func (x TransactionStatus) Enum() *TransactionStatus

func (TransactionStatus) EnumDescriptor deprecated 

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

Deprecated: Use TransactionStatus.Descriptor instead.

func (TransactionStatus) Number 

func (x TransactionStatus) Number() protoreflect.EnumNumber

func (TransactionStatus) String 

func (x TransactionStatus) String() string

func (TransactionStatus) Type 

func (TransactionStatus) Type() protoreflect.EnumType

Source Files

View all Source files

Directories

Path Synopsis

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.