Documentation ¶
Index ¶
- Variables
- type AttachSessionRequest
- func (*AttachSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AttachSessionRequest) GetSessionId() string
- func (*AttachSessionRequest) ProtoMessage()
- func (x *AttachSessionRequest) ProtoReflect() protoreflect.Message
- func (x *AttachSessionRequest) Reset()
- func (x *AttachSessionRequest) String() string
- type BeginTransactionRequest
- func (*BeginTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BeginTransactionRequest) GetSessionId() string
- func (x *BeginTransactionRequest) GetTxSettings() *TransactionSettings
- func (*BeginTransactionRequest) ProtoMessage()
- func (x *BeginTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *BeginTransactionRequest) Reset()
- func (x *BeginTransactionRequest) String() string
- type BeginTransactionResponse
- func (*BeginTransactionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BeginTransactionResponse) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *BeginTransactionResponse) GetStatus() Ydb.StatusIds_StatusCode
- func (x *BeginTransactionResponse) GetTxMeta() *TransactionMeta
- func (*BeginTransactionResponse) ProtoMessage()
- func (x *BeginTransactionResponse) ProtoReflect() protoreflect.Message
- func (x *BeginTransactionResponse) Reset()
- func (x *BeginTransactionResponse) String() string
- type CommitTransactionRequest
- func (*CommitTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CommitTransactionRequest) GetSessionId() string
- func (x *CommitTransactionRequest) GetTxId() string
- func (*CommitTransactionRequest) ProtoMessage()
- func (x *CommitTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *CommitTransactionRequest) Reset()
- func (x *CommitTransactionRequest) String() string
- type CommitTransactionResponse
- func (*CommitTransactionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CommitTransactionResponse) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *CommitTransactionResponse) GetStatus() Ydb.StatusIds_StatusCode
- func (*CommitTransactionResponse) ProtoMessage()
- func (x *CommitTransactionResponse) ProtoReflect() protoreflect.Message
- func (x *CommitTransactionResponse) Reset()
- func (x *CommitTransactionResponse) String() string
- type CreateSessionRequest
- type CreateSessionResponse
- func (*CreateSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSessionResponse) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *CreateSessionResponse) GetNodeId() int64
- func (x *CreateSessionResponse) GetSessionId() string
- func (x *CreateSessionResponse) GetStatus() Ydb.StatusIds_StatusCode
- func (*CreateSessionResponse) ProtoMessage()
- func (x *CreateSessionResponse) ProtoReflect() protoreflect.Message
- func (x *CreateSessionResponse) Reset()
- func (x *CreateSessionResponse) String() string
- type DeleteSessionRequest
- func (*DeleteSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSessionRequest) GetSessionId() string
- func (*DeleteSessionRequest) ProtoMessage()
- func (x *DeleteSessionRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSessionRequest) Reset()
- func (x *DeleteSessionRequest) String() string
- type DeleteSessionResponse
- func (*DeleteSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSessionResponse) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *DeleteSessionResponse) GetStatus() Ydb.StatusIds_StatusCode
- func (*DeleteSessionResponse) ProtoMessage()
- func (x *DeleteSessionResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteSessionResponse) Reset()
- func (x *DeleteSessionResponse) String() string
- type ExecMode
- type ExecStatus
- type ExecuteQueryRequest
- func (*ExecuteQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteQueryRequest) GetConcurrentResultSets() bool
- func (x *ExecuteQueryRequest) GetExecMode() ExecMode
- func (x *ExecuteQueryRequest) GetParameters() map[string]*Ydb.TypedValue
- func (x *ExecuteQueryRequest) GetPoolId() string
- func (m *ExecuteQueryRequest) GetQuery() isExecuteQueryRequest_Query
- func (x *ExecuteQueryRequest) GetQueryContent() *QueryContent
- func (x *ExecuteQueryRequest) GetResponsePartLimitBytes() int64
- func (x *ExecuteQueryRequest) GetSessionId() string
- func (x *ExecuteQueryRequest) GetStatsMode() StatsMode
- func (x *ExecuteQueryRequest) GetTxControl() *TransactionControl
- func (*ExecuteQueryRequest) ProtoMessage()
- func (x *ExecuteQueryRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteQueryRequest) Reset()
- func (x *ExecuteQueryRequest) String() string
- type ExecuteQueryRequest_QueryContent
- type ExecuteQueryResponsePart
- func (*ExecuteQueryResponsePart) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteQueryResponsePart) GetExecStats() *Ydb_TableStats.QueryStats
- func (x *ExecuteQueryResponsePart) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *ExecuteQueryResponsePart) GetResultSet() *Ydb.ResultSet
- func (x *ExecuteQueryResponsePart) GetResultSetIndex() int64
- func (x *ExecuteQueryResponsePart) GetStatus() Ydb.StatusIds_StatusCode
- func (x *ExecuteQueryResponsePart) GetTxMeta() *TransactionMeta
- func (*ExecuteQueryResponsePart) ProtoMessage()
- func (x *ExecuteQueryResponsePart) ProtoReflect() protoreflect.Message
- func (x *ExecuteQueryResponsePart) Reset()
- func (x *ExecuteQueryResponsePart) String() string
- type ExecuteScriptMetadata
- func (*ExecuteScriptMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteScriptMetadata) GetExecMode() ExecMode
- func (x *ExecuteScriptMetadata) GetExecStats() *Ydb_TableStats.QueryStats
- func (x *ExecuteScriptMetadata) GetExecStatus() ExecStatus
- func (x *ExecuteScriptMetadata) GetExecutionId() string
- func (x *ExecuteScriptMetadata) GetResultSetsMeta() []*ResultSetMeta
- func (x *ExecuteScriptMetadata) GetScriptContent() *QueryContent
- func (*ExecuteScriptMetadata) ProtoMessage()
- func (x *ExecuteScriptMetadata) ProtoReflect() protoreflect.Message
- func (x *ExecuteScriptMetadata) Reset()
- func (x *ExecuteScriptMetadata) String() string
- type ExecuteScriptRequest
- func (*ExecuteScriptRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteScriptRequest) GetExecMode() ExecMode
- func (x *ExecuteScriptRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *ExecuteScriptRequest) GetParameters() map[string]*Ydb.TypedValue
- func (x *ExecuteScriptRequest) GetPoolId() string
- func (x *ExecuteScriptRequest) GetResultsTtl() *durationpb.Duration
- func (x *ExecuteScriptRequest) GetScriptContent() *QueryContent
- func (x *ExecuteScriptRequest) GetStatsMode() StatsMode
- func (*ExecuteScriptRequest) ProtoMessage()
- func (x *ExecuteScriptRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteScriptRequest) Reset()
- func (x *ExecuteScriptRequest) String() string
- type FetchScriptResultsRequest
- func (*FetchScriptResultsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FetchScriptResultsRequest) GetFetchToken() string
- func (x *FetchScriptResultsRequest) GetOperationId() string
- func (x *FetchScriptResultsRequest) GetResultSetIndex() int64
- func (x *FetchScriptResultsRequest) GetRowsLimit() int64
- func (*FetchScriptResultsRequest) ProtoMessage()
- func (x *FetchScriptResultsRequest) ProtoReflect() protoreflect.Message
- func (x *FetchScriptResultsRequest) Reset()
- func (x *FetchScriptResultsRequest) String() string
- type FetchScriptResultsResponse
- func (*FetchScriptResultsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchScriptResultsResponse) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *FetchScriptResultsResponse) GetNextFetchToken() string
- func (x *FetchScriptResultsResponse) GetResultSet() *Ydb.ResultSet
- func (x *FetchScriptResultsResponse) GetResultSetIndex() int64
- func (x *FetchScriptResultsResponse) GetStatus() Ydb.StatusIds_StatusCode
- func (*FetchScriptResultsResponse) ProtoMessage()
- func (x *FetchScriptResultsResponse) ProtoReflect() protoreflect.Message
- func (x *FetchScriptResultsResponse) Reset()
- func (x *FetchScriptResultsResponse) String() string
- type OnlineModeSettings
- func (*OnlineModeSettings) Descriptor() ([]byte, []int)deprecated
- func (x *OnlineModeSettings) GetAllowInconsistentReads() bool
- func (*OnlineModeSettings) ProtoMessage()
- func (x *OnlineModeSettings) ProtoReflect() protoreflect.Message
- func (x *OnlineModeSettings) Reset()
- func (x *OnlineModeSettings) String() string
- type QueryContent
- func (*QueryContent) Descriptor() ([]byte, []int)deprecated
- func (x *QueryContent) GetSyntax() Syntax
- func (x *QueryContent) GetText() string
- func (*QueryContent) ProtoMessage()
- func (x *QueryContent) ProtoReflect() protoreflect.Message
- func (x *QueryContent) Reset()
- func (x *QueryContent) String() string
- type ResultSetMeta
- type RollbackTransactionRequest
- func (*RollbackTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RollbackTransactionRequest) GetSessionId() string
- func (x *RollbackTransactionRequest) GetTxId() string
- func (*RollbackTransactionRequest) ProtoMessage()
- func (x *RollbackTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *RollbackTransactionRequest) Reset()
- func (x *RollbackTransactionRequest) String() string
- type RollbackTransactionResponse
- func (*RollbackTransactionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RollbackTransactionResponse) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *RollbackTransactionResponse) GetStatus() Ydb.StatusIds_StatusCode
- func (*RollbackTransactionResponse) ProtoMessage()
- func (x *RollbackTransactionResponse) ProtoReflect() protoreflect.Message
- func (x *RollbackTransactionResponse) Reset()
- func (x *RollbackTransactionResponse) String() string
- type Script
- type SerializableModeSettings
- type SessionState
- func (*SessionState) Descriptor() ([]byte, []int)deprecated
- func (x *SessionState) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *SessionState) GetStatus() Ydb.StatusIds_StatusCode
- func (*SessionState) ProtoMessage()
- func (x *SessionState) ProtoReflect() protoreflect.Message
- func (x *SessionState) Reset()
- func (x *SessionState) String() string
- type SnapshotModeSettings
- type StaleModeSettings
- type StatsMode
- type Syntax
- type TransactionControl
- func (*TransactionControl) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionControl) GetBeginTx() *TransactionSettings
- func (x *TransactionControl) GetCommitTx() bool
- func (x *TransactionControl) GetTxId() string
- func (m *TransactionControl) GetTxSelector() isTransactionControl_TxSelector
- func (*TransactionControl) ProtoMessage()
- func (x *TransactionControl) ProtoReflect() protoreflect.Message
- func (x *TransactionControl) Reset()
- func (x *TransactionControl) String() string
- type TransactionControl_BeginTx
- type TransactionControl_TxId
- type TransactionMeta
- type TransactionSettings
- func (*TransactionSettings) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionSettings) GetOnlineReadOnly() *OnlineModeSettings
- func (x *TransactionSettings) GetSerializableReadWrite() *SerializableModeSettings
- func (x *TransactionSettings) GetSnapshotReadOnly() *SnapshotModeSettings
- func (x *TransactionSettings) GetStaleReadOnly() *StaleModeSettings
- func (m *TransactionSettings) GetTxMode() isTransactionSettings_TxMode
- func (*TransactionSettings) ProtoMessage()
- func (x *TransactionSettings) ProtoReflect() protoreflect.Message
- func (x *TransactionSettings) Reset()
- func (x *TransactionSettings) String() string
- type TransactionSettings_OnlineReadOnly
- type TransactionSettings_SerializableReadWrite
- type TransactionSettings_SnapshotReadOnly
- type TransactionSettings_StaleReadOnly
Constants ¶
This section is empty.
Variables ¶
var ( Syntax_name = map[int32]string{ 0: "SYNTAX_UNSPECIFIED", 1: "SYNTAX_YQL_V1", 2: "SYNTAX_PG", } Syntax_value = map[string]int32{ "SYNTAX_UNSPECIFIED": 0, "SYNTAX_YQL_V1": 1, "SYNTAX_PG": 2, } )
Enum value maps for Syntax.
var ( ExecMode_name = map[int32]string{ 0: "EXEC_MODE_UNSPECIFIED", 10: "EXEC_MODE_PARSE", 20: "EXEC_MODE_VALIDATE", 30: "EXEC_MODE_EXPLAIN", 50: "EXEC_MODE_EXECUTE", } ExecMode_value = map[string]int32{ "EXEC_MODE_UNSPECIFIED": 0, "EXEC_MODE_PARSE": 10, "EXEC_MODE_VALIDATE": 20, "EXEC_MODE_EXPLAIN": 30, "EXEC_MODE_EXECUTE": 50, } )
Enum value maps for ExecMode.
var ( StatsMode_name = map[int32]string{ 0: "STATS_MODE_UNSPECIFIED", 10: "STATS_MODE_NONE", 20: "STATS_MODE_BASIC", 30: "STATS_MODE_FULL", 40: "STATS_MODE_PROFILE", } StatsMode_value = map[string]int32{ "STATS_MODE_UNSPECIFIED": 0, "STATS_MODE_NONE": 10, "STATS_MODE_BASIC": 20, "STATS_MODE_FULL": 30, "STATS_MODE_PROFILE": 40, } )
Enum value maps for StatsMode.
var ( ExecStatus_name = map[int32]string{ 0: "EXEC_STATUS_UNSPECIFIED", 10: "EXEC_STATUS_STARTING", 20: "EXEC_STATUS_ABORTED", 30: "EXEC_STATUS_CANCELLED", 40: "EXEC_STATUS_COMPLETED", 50: "EXEC_STATUS_FAILED", } ExecStatus_value = map[string]int32{ "EXEC_STATUS_UNSPECIFIED": 0, "EXEC_STATUS_STARTING": 10, "EXEC_STATUS_ABORTED": 20, "EXEC_STATUS_CANCELLED": 30, "EXEC_STATUS_COMPLETED": 40, "EXEC_STATUS_FAILED": 50, } )
Enum value maps for ExecStatus.
var File_protos_ydb_query_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AttachSessionRequest ¶
type AttachSessionRequest struct { // Identifier of session to attach (required) SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // contains filtered or unexported fields }
func (*AttachSessionRequest) Descriptor
deprecated
func (*AttachSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use AttachSessionRequest.ProtoReflect.Descriptor instead.
func (*AttachSessionRequest) GetSessionId ¶
func (x *AttachSessionRequest) GetSessionId() string
func (*AttachSessionRequest) ProtoMessage ¶
func (*AttachSessionRequest) ProtoMessage()
func (*AttachSessionRequest) ProtoReflect ¶
func (x *AttachSessionRequest) ProtoReflect() protoreflect.Message
func (*AttachSessionRequest) Reset ¶
func (x *AttachSessionRequest) Reset()
func (*AttachSessionRequest) String ¶
func (x *AttachSessionRequest) String() string
type BeginTransactionRequest ¶
type BeginTransactionRequest struct { // Session identifier (required) SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` TxSettings *TransactionSettings `protobuf:"bytes,2,opt,name=tx_settings,json=txSettings,proto3" json:"tx_settings,omitempty"` // contains filtered or unexported fields }
func (*BeginTransactionRequest) Descriptor
deprecated
func (*BeginTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use BeginTransactionRequest.ProtoReflect.Descriptor instead.
func (*BeginTransactionRequest) GetSessionId ¶
func (x *BeginTransactionRequest) GetSessionId() string
func (*BeginTransactionRequest) GetTxSettings ¶
func (x *BeginTransactionRequest) GetTxSettings() *TransactionSettings
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 { Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"` Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"` TxMeta *TransactionMeta `protobuf:"bytes,3,opt,name=tx_meta,json=txMeta,proto3" json:"tx_meta,omitempty"` // contains filtered or unexported fields }
func (*BeginTransactionResponse) Descriptor
deprecated
func (*BeginTransactionResponse) Descriptor() ([]byte, []int)
Deprecated: Use BeginTransactionResponse.ProtoReflect.Descriptor instead.
func (*BeginTransactionResponse) GetIssues ¶
func (x *BeginTransactionResponse) GetIssues() []*Ydb_Issue.IssueMessage
func (*BeginTransactionResponse) GetStatus ¶
func (x *BeginTransactionResponse) GetStatus() Ydb.StatusIds_StatusCode
func (*BeginTransactionResponse) GetTxMeta ¶
func (x *BeginTransactionResponse) GetTxMeta() *TransactionMeta
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 CommitTransactionRequest ¶
type CommitTransactionRequest struct { // Session identifier (required) SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Transaction identifier (required) TxId string `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // contains filtered or unexported fields }
func (*CommitTransactionRequest) Descriptor
deprecated
func (*CommitTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CommitTransactionRequest.ProtoReflect.Descriptor instead.
func (*CommitTransactionRequest) GetSessionId ¶
func (x *CommitTransactionRequest) GetSessionId() string
func (*CommitTransactionRequest) GetTxId ¶
func (x *CommitTransactionRequest) GetTxId() 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 Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"` Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"` // contains filtered or unexported fields }
func (*CommitTransactionResponse) Descriptor
deprecated
func (*CommitTransactionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CommitTransactionResponse.ProtoReflect.Descriptor instead.
func (*CommitTransactionResponse) GetIssues ¶
func (x *CommitTransactionResponse) GetIssues() []*Ydb_Issue.IssueMessage
func (*CommitTransactionResponse) GetStatus ¶
func (x *CommitTransactionResponse) GetStatus() Ydb.StatusIds_StatusCode
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 CreateSessionRequest ¶
type CreateSessionRequest struct {
// contains filtered or unexported fields
}
func (*CreateSessionRequest) Descriptor
deprecated
func (*CreateSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSessionRequest.ProtoReflect.Descriptor instead.
func (*CreateSessionRequest) ProtoMessage ¶
func (*CreateSessionRequest) ProtoMessage()
func (*CreateSessionRequest) ProtoReflect ¶
func (x *CreateSessionRequest) ProtoReflect() protoreflect.Message
func (*CreateSessionRequest) Reset ¶
func (x *CreateSessionRequest) Reset()
func (*CreateSessionRequest) String ¶
func (x *CreateSessionRequest) String() string
type CreateSessionResponse ¶
type CreateSessionResponse struct { Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"` Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"` // Identifier of created session SessionId string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Identifier node where session was created NodeId int64 `protobuf:"varint,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // contains filtered or unexported fields }
func (*CreateSessionResponse) Descriptor
deprecated
func (*CreateSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateSessionResponse.ProtoReflect.Descriptor instead.
func (*CreateSessionResponse) GetIssues ¶
func (x *CreateSessionResponse) GetIssues() []*Ydb_Issue.IssueMessage
func (*CreateSessionResponse) GetNodeId ¶
func (x *CreateSessionResponse) GetNodeId() int64
func (*CreateSessionResponse) GetSessionId ¶
func (x *CreateSessionResponse) GetSessionId() string
func (*CreateSessionResponse) GetStatus ¶
func (x *CreateSessionResponse) GetStatus() Ydb.StatusIds_StatusCode
func (*CreateSessionResponse) ProtoMessage ¶
func (*CreateSessionResponse) ProtoMessage()
func (*CreateSessionResponse) ProtoReflect ¶
func (x *CreateSessionResponse) ProtoReflect() protoreflect.Message
func (*CreateSessionResponse) Reset ¶
func (x *CreateSessionResponse) Reset()
func (*CreateSessionResponse) String ¶
func (x *CreateSessionResponse) String() string
type DeleteSessionRequest ¶
type DeleteSessionRequest struct { // Identifier of session to delete (required) SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // contains filtered or unexported fields }
func (*DeleteSessionRequest) Descriptor
deprecated
func (*DeleteSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSessionRequest.ProtoReflect.Descriptor instead.
func (*DeleteSessionRequest) GetSessionId ¶
func (x *DeleteSessionRequest) GetSessionId() string
func (*DeleteSessionRequest) ProtoMessage ¶
func (*DeleteSessionRequest) ProtoMessage()
func (*DeleteSessionRequest) ProtoReflect ¶
func (x *DeleteSessionRequest) ProtoReflect() protoreflect.Message
func (*DeleteSessionRequest) Reset ¶
func (x *DeleteSessionRequest) Reset()
func (*DeleteSessionRequest) String ¶
func (x *DeleteSessionRequest) String() string
type DeleteSessionResponse ¶
type DeleteSessionResponse struct { Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"` Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"` // contains filtered or unexported fields }
func (*DeleteSessionResponse) Descriptor
deprecated
func (*DeleteSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSessionResponse.ProtoReflect.Descriptor instead.
func (*DeleteSessionResponse) GetIssues ¶
func (x *DeleteSessionResponse) GetIssues() []*Ydb_Issue.IssueMessage
func (*DeleteSessionResponse) GetStatus ¶
func (x *DeleteSessionResponse) GetStatus() Ydb.StatusIds_StatusCode
func (*DeleteSessionResponse) ProtoMessage ¶
func (*DeleteSessionResponse) ProtoMessage()
func (*DeleteSessionResponse) ProtoReflect ¶
func (x *DeleteSessionResponse) ProtoReflect() protoreflect.Message
func (*DeleteSessionResponse) Reset ¶
func (x *DeleteSessionResponse) Reset()
func (*DeleteSessionResponse) String ¶
func (x *DeleteSessionResponse) String() string
type ExecMode ¶
type ExecMode int32
func (ExecMode) Descriptor ¶
func (ExecMode) Descriptor() protoreflect.EnumDescriptor
func (ExecMode) EnumDescriptor
deprecated
func (ExecMode) Number ¶
func (x ExecMode) Number() protoreflect.EnumNumber
func (ExecMode) Type ¶
func (ExecMode) Type() protoreflect.EnumType
type ExecStatus ¶
type ExecStatus int32
const ( ExecStatus_EXEC_STATUS_UNSPECIFIED ExecStatus = 0 ExecStatus_EXEC_STATUS_STARTING ExecStatus = 10 ExecStatus_EXEC_STATUS_ABORTED ExecStatus = 20 ExecStatus_EXEC_STATUS_CANCELLED ExecStatus = 30 ExecStatus_EXEC_STATUS_COMPLETED ExecStatus = 40 ExecStatus_EXEC_STATUS_FAILED ExecStatus = 50 )
func (ExecStatus) Descriptor ¶
func (ExecStatus) Descriptor() protoreflect.EnumDescriptor
func (ExecStatus) Enum ¶
func (x ExecStatus) Enum() *ExecStatus
func (ExecStatus) EnumDescriptor
deprecated
func (ExecStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ExecStatus.Descriptor instead.
func (ExecStatus) Number ¶
func (x ExecStatus) Number() protoreflect.EnumNumber
func (ExecStatus) String ¶
func (x ExecStatus) String() string
func (ExecStatus) Type ¶
func (ExecStatus) Type() protoreflect.EnumType
type ExecuteQueryRequest ¶
type ExecuteQueryRequest struct { // Session identifier (required) SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` ExecMode ExecMode `protobuf:"varint,2,opt,name=exec_mode,json=execMode,proto3,enum=Ydb.Query.ExecMode" json:"exec_mode,omitempty"` TxControl *TransactionControl `protobuf:"bytes,3,opt,name=tx_control,json=txControl,proto3" json:"tx_control,omitempty"` // Types that are assignable to Query: // // *ExecuteQueryRequest_QueryContent Query isExecuteQueryRequest_Query `protobuf_oneof:"query"` Parameters map[string]*Ydb.TypedValue `` /* 161-byte string literal not displayed */ StatsMode StatsMode `protobuf:"varint,7,opt,name=stats_mode,json=statsMode,proto3,enum=Ydb.Query.StatsMode" json:"stats_mode,omitempty"` // For queries with multiple result sets, some of them may be computed concurrently. // If true, parts of different results sets may be interleaved in response stream. ConcurrentResultSets bool `protobuf:"varint,8,opt,name=concurrent_result_sets,json=concurrentResultSets,proto3" json:"concurrent_result_sets,omitempty"` // Allows to set size limitation (in bytes) for one result part ResponsePartLimitBytes int64 `` /* 132-byte string literal not displayed */ PoolId string `protobuf:"bytes,10,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"` // Workload manager pool id // contains filtered or unexported fields }
func (*ExecuteQueryRequest) Descriptor
deprecated
func (*ExecuteQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteQueryRequest.ProtoReflect.Descriptor instead.
func (*ExecuteQueryRequest) GetConcurrentResultSets ¶
func (x *ExecuteQueryRequest) GetConcurrentResultSets() bool
func (*ExecuteQueryRequest) GetExecMode ¶
func (x *ExecuteQueryRequest) GetExecMode() ExecMode
func (*ExecuteQueryRequest) GetParameters ¶
func (x *ExecuteQueryRequest) GetParameters() map[string]*Ydb.TypedValue
func (*ExecuteQueryRequest) GetPoolId ¶
func (x *ExecuteQueryRequest) GetPoolId() string
func (*ExecuteQueryRequest) GetQuery ¶
func (m *ExecuteQueryRequest) GetQuery() isExecuteQueryRequest_Query
func (*ExecuteQueryRequest) GetQueryContent ¶
func (x *ExecuteQueryRequest) GetQueryContent() *QueryContent
func (*ExecuteQueryRequest) GetResponsePartLimitBytes ¶
func (x *ExecuteQueryRequest) GetResponsePartLimitBytes() int64
func (*ExecuteQueryRequest) GetSessionId ¶
func (x *ExecuteQueryRequest) GetSessionId() string
func (*ExecuteQueryRequest) GetStatsMode ¶
func (x *ExecuteQueryRequest) GetStatsMode() StatsMode
func (*ExecuteQueryRequest) GetTxControl ¶
func (x *ExecuteQueryRequest) GetTxControl() *TransactionControl
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 ExecuteQueryRequest_QueryContent ¶
type ExecuteQueryRequest_QueryContent struct {
QueryContent *QueryContent `protobuf:"bytes,4,opt,name=query_content,json=queryContent,proto3,oneof"`
}
type ExecuteQueryResponsePart ¶
type ExecuteQueryResponsePart struct { Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"` Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"` // Index of current result set ResultSetIndex int64 `protobuf:"varint,3,opt,name=result_set_index,json=resultSetIndex,proto3" json:"result_set_index,omitempty"` // Result set part ResultSet *Ydb.ResultSet `protobuf:"bytes,4,opt,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"` // Execution statistics (last part only) ExecStats *Ydb_TableStats.QueryStats `protobuf:"bytes,5,opt,name=exec_stats,json=execStats,proto3" json:"exec_stats,omitempty"` TxMeta *TransactionMeta `protobuf:"bytes,6,opt,name=tx_meta,json=txMeta,proto3" json:"tx_meta,omitempty"` // contains filtered or unexported fields }
func (*ExecuteQueryResponsePart) Descriptor
deprecated
func (*ExecuteQueryResponsePart) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteQueryResponsePart.ProtoReflect.Descriptor instead.
func (*ExecuteQueryResponsePart) GetExecStats ¶
func (x *ExecuteQueryResponsePart) GetExecStats() *Ydb_TableStats.QueryStats
func (*ExecuteQueryResponsePart) GetIssues ¶
func (x *ExecuteQueryResponsePart) GetIssues() []*Ydb_Issue.IssueMessage
func (*ExecuteQueryResponsePart) GetResultSet ¶
func (x *ExecuteQueryResponsePart) GetResultSet() *Ydb.ResultSet
func (*ExecuteQueryResponsePart) GetResultSetIndex ¶
func (x *ExecuteQueryResponsePart) GetResultSetIndex() int64
func (*ExecuteQueryResponsePart) GetStatus ¶
func (x *ExecuteQueryResponsePart) GetStatus() Ydb.StatusIds_StatusCode
func (*ExecuteQueryResponsePart) GetTxMeta ¶
func (x *ExecuteQueryResponsePart) GetTxMeta() *TransactionMeta
func (*ExecuteQueryResponsePart) ProtoMessage ¶
func (*ExecuteQueryResponsePart) ProtoMessage()
func (*ExecuteQueryResponsePart) ProtoReflect ¶
func (x *ExecuteQueryResponsePart) ProtoReflect() protoreflect.Message
func (*ExecuteQueryResponsePart) Reset ¶
func (x *ExecuteQueryResponsePart) Reset()
func (*ExecuteQueryResponsePart) String ¶
func (x *ExecuteQueryResponsePart) String() string
type ExecuteScriptMetadata ¶
type ExecuteScriptMetadata struct { ExecutionId string `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"` ExecStatus ExecStatus `protobuf:"varint,2,opt,name=exec_status,json=execStatus,proto3,enum=Ydb.Query.ExecStatus" json:"exec_status,omitempty"` ScriptContent *QueryContent `protobuf:"bytes,3,opt,name=script_content,json=scriptContent,proto3" json:"script_content,omitempty"` ResultSetsMeta []*ResultSetMeta `protobuf:"bytes,4,rep,name=result_sets_meta,json=resultSetsMeta,proto3" json:"result_sets_meta,omitempty"` ExecMode ExecMode `protobuf:"varint,5,opt,name=exec_mode,json=execMode,proto3,enum=Ydb.Query.ExecMode" json:"exec_mode,omitempty"` // Execution statistics ExecStats *Ydb_TableStats.QueryStats `protobuf:"bytes,6,opt,name=exec_stats,json=execStats,proto3" json:"exec_stats,omitempty"` // contains filtered or unexported fields }
func (*ExecuteScriptMetadata) Descriptor
deprecated
func (*ExecuteScriptMetadata) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteScriptMetadata.ProtoReflect.Descriptor instead.
func (*ExecuteScriptMetadata) GetExecMode ¶
func (x *ExecuteScriptMetadata) GetExecMode() ExecMode
func (*ExecuteScriptMetadata) GetExecStats ¶
func (x *ExecuteScriptMetadata) GetExecStats() *Ydb_TableStats.QueryStats
func (*ExecuteScriptMetadata) GetExecStatus ¶
func (x *ExecuteScriptMetadata) GetExecStatus() ExecStatus
func (*ExecuteScriptMetadata) GetExecutionId ¶
func (x *ExecuteScriptMetadata) GetExecutionId() string
func (*ExecuteScriptMetadata) GetResultSetsMeta ¶
func (x *ExecuteScriptMetadata) GetResultSetsMeta() []*ResultSetMeta
func (*ExecuteScriptMetadata) GetScriptContent ¶
func (x *ExecuteScriptMetadata) GetScriptContent() *QueryContent
func (*ExecuteScriptMetadata) ProtoMessage ¶
func (*ExecuteScriptMetadata) ProtoMessage()
func (*ExecuteScriptMetadata) ProtoReflect ¶
func (x *ExecuteScriptMetadata) ProtoReflect() protoreflect.Message
func (*ExecuteScriptMetadata) Reset ¶
func (x *ExecuteScriptMetadata) Reset()
func (*ExecuteScriptMetadata) String ¶
func (x *ExecuteScriptMetadata) String() string
type ExecuteScriptRequest ¶
type ExecuteScriptRequest struct { OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"` ExecMode ExecMode `protobuf:"varint,2,opt,name=exec_mode,json=execMode,proto3,enum=Ydb.Query.ExecMode" json:"exec_mode,omitempty"` ScriptContent *QueryContent `protobuf:"bytes,3,opt,name=script_content,json=scriptContent,proto3" json:"script_content,omitempty"` Parameters map[string]*Ydb.TypedValue `` /* 161-byte string literal not displayed */ StatsMode StatsMode `protobuf:"varint,5,opt,name=stats_mode,json=statsMode,proto3,enum=Ydb.Query.StatsMode" json:"stats_mode,omitempty"` // After script execution operation finishes, TTL will start counting. // After this TTL the results will be removed from database. ResultsTtl *durationpb.Duration `protobuf:"bytes,6,opt,name=results_ttl,json=resultsTtl,proto3" json:"results_ttl,omitempty"` PoolId string `protobuf:"bytes,7,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"` // Workload manager pool id // contains filtered or unexported fields }
func (*ExecuteScriptRequest) Descriptor
deprecated
func (*ExecuteScriptRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteScriptRequest.ProtoReflect.Descriptor instead.
func (*ExecuteScriptRequest) GetExecMode ¶
func (x *ExecuteScriptRequest) GetExecMode() ExecMode
func (*ExecuteScriptRequest) GetOperationParams ¶
func (x *ExecuteScriptRequest) GetOperationParams() *Ydb_Operations.OperationParams
func (*ExecuteScriptRequest) GetParameters ¶
func (x *ExecuteScriptRequest) GetParameters() map[string]*Ydb.TypedValue
func (*ExecuteScriptRequest) GetPoolId ¶
func (x *ExecuteScriptRequest) GetPoolId() string
func (*ExecuteScriptRequest) GetResultsTtl ¶
func (x *ExecuteScriptRequest) GetResultsTtl() *durationpb.Duration
func (*ExecuteScriptRequest) GetScriptContent ¶
func (x *ExecuteScriptRequest) GetScriptContent() *QueryContent
func (*ExecuteScriptRequest) GetStatsMode ¶
func (x *ExecuteScriptRequest) GetStatsMode() StatsMode
func (*ExecuteScriptRequest) ProtoMessage ¶
func (*ExecuteScriptRequest) ProtoMessage()
func (*ExecuteScriptRequest) ProtoReflect ¶
func (x *ExecuteScriptRequest) ProtoReflect() protoreflect.Message
func (*ExecuteScriptRequest) Reset ¶
func (x *ExecuteScriptRequest) Reset()
func (*ExecuteScriptRequest) String ¶
func (x *ExecuteScriptRequest) String() string
type FetchScriptResultsRequest ¶
type FetchScriptResultsRequest struct { OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` ResultSetIndex int64 `protobuf:"varint,2,opt,name=result_set_index,json=resultSetIndex,proto3" json:"result_set_index,omitempty"` FetchToken string `protobuf:"bytes,3,opt,name=fetch_token,json=fetchToken,proto3" json:"fetch_token,omitempty"` RowsLimit int64 `protobuf:"varint,4,opt,name=rows_limit,json=rowsLimit,proto3" json:"rows_limit,omitempty"` // contains filtered or unexported fields }
func (*FetchScriptResultsRequest) Descriptor
deprecated
func (*FetchScriptResultsRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchScriptResultsRequest.ProtoReflect.Descriptor instead.
func (*FetchScriptResultsRequest) GetFetchToken ¶
func (x *FetchScriptResultsRequest) GetFetchToken() string
func (*FetchScriptResultsRequest) GetOperationId ¶
func (x *FetchScriptResultsRequest) GetOperationId() string
func (*FetchScriptResultsRequest) GetResultSetIndex ¶
func (x *FetchScriptResultsRequest) GetResultSetIndex() int64
func (*FetchScriptResultsRequest) GetRowsLimit ¶
func (x *FetchScriptResultsRequest) GetRowsLimit() int64
func (*FetchScriptResultsRequest) ProtoMessage ¶
func (*FetchScriptResultsRequest) ProtoMessage()
func (*FetchScriptResultsRequest) ProtoReflect ¶
func (x *FetchScriptResultsRequest) ProtoReflect() protoreflect.Message
func (*FetchScriptResultsRequest) Reset ¶
func (x *FetchScriptResultsRequest) Reset()
func (*FetchScriptResultsRequest) String ¶
func (x *FetchScriptResultsRequest) String() string
type FetchScriptResultsResponse ¶
type FetchScriptResultsResponse struct { Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"` Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"` ResultSetIndex int64 `protobuf:"varint,3,opt,name=result_set_index,json=resultSetIndex,proto3" json:"result_set_index,omitempty"` ResultSet *Ydb.ResultSet `protobuf:"bytes,4,opt,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"` NextFetchToken string `protobuf:"bytes,5,opt,name=next_fetch_token,json=nextFetchToken,proto3" json:"next_fetch_token,omitempty"` // contains filtered or unexported fields }
func (*FetchScriptResultsResponse) Descriptor
deprecated
func (*FetchScriptResultsResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchScriptResultsResponse.ProtoReflect.Descriptor instead.
func (*FetchScriptResultsResponse) GetIssues ¶
func (x *FetchScriptResultsResponse) GetIssues() []*Ydb_Issue.IssueMessage
func (*FetchScriptResultsResponse) GetNextFetchToken ¶
func (x *FetchScriptResultsResponse) GetNextFetchToken() string
func (*FetchScriptResultsResponse) GetResultSet ¶
func (x *FetchScriptResultsResponse) GetResultSet() *Ydb.ResultSet
func (*FetchScriptResultsResponse) GetResultSetIndex ¶
func (x *FetchScriptResultsResponse) GetResultSetIndex() int64
func (*FetchScriptResultsResponse) GetStatus ¶
func (x *FetchScriptResultsResponse) GetStatus() Ydb.StatusIds_StatusCode
func (*FetchScriptResultsResponse) ProtoMessage ¶
func (*FetchScriptResultsResponse) ProtoMessage()
func (*FetchScriptResultsResponse) ProtoReflect ¶
func (x *FetchScriptResultsResponse) ProtoReflect() protoreflect.Message
func (*FetchScriptResultsResponse) Reset ¶
func (x *FetchScriptResultsResponse) Reset()
func (*FetchScriptResultsResponse) String ¶
func (x *FetchScriptResultsResponse) String() string
type OnlineModeSettings ¶
type OnlineModeSettings struct { AllowInconsistentReads bool `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
func (*OnlineModeSettings) Descriptor
deprecated
func (*OnlineModeSettings) Descriptor() ([]byte, []int)
Deprecated: Use OnlineModeSettings.ProtoReflect.Descriptor instead.
func (*OnlineModeSettings) GetAllowInconsistentReads ¶
func (x *OnlineModeSettings) GetAllowInconsistentReads() bool
func (*OnlineModeSettings) ProtoMessage ¶
func (*OnlineModeSettings) ProtoMessage()
func (*OnlineModeSettings) ProtoReflect ¶
func (x *OnlineModeSettings) ProtoReflect() protoreflect.Message
func (*OnlineModeSettings) Reset ¶
func (x *OnlineModeSettings) Reset()
func (*OnlineModeSettings) String ¶
func (x *OnlineModeSettings) String() string
type QueryContent ¶
type QueryContent struct { Syntax Syntax `protobuf:"varint,1,opt,name=syntax,proto3,enum=Ydb.Query.Syntax" json:"syntax,omitempty"` Text string `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"` // contains filtered or unexported fields }
func (*QueryContent) Descriptor
deprecated
func (*QueryContent) Descriptor() ([]byte, []int)
Deprecated: Use QueryContent.ProtoReflect.Descriptor instead.
func (*QueryContent) GetSyntax ¶
func (x *QueryContent) GetSyntax() Syntax
func (*QueryContent) GetText ¶
func (x *QueryContent) GetText() string
func (*QueryContent) ProtoMessage ¶
func (*QueryContent) ProtoMessage()
func (*QueryContent) ProtoReflect ¶
func (x *QueryContent) ProtoReflect() protoreflect.Message
func (*QueryContent) Reset ¶
func (x *QueryContent) Reset()
func (*QueryContent) String ¶
func (x *QueryContent) String() string
type ResultSetMeta ¶
type ResultSetMeta struct { Columns []*Ydb.Column `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"` // contains filtered or unexported fields }
func (*ResultSetMeta) Descriptor
deprecated
func (*ResultSetMeta) Descriptor() ([]byte, []int)
Deprecated: Use ResultSetMeta.ProtoReflect.Descriptor instead.
func (*ResultSetMeta) GetColumns ¶
func (x *ResultSetMeta) GetColumns() []*Ydb.Column
func (*ResultSetMeta) ProtoMessage ¶
func (*ResultSetMeta) ProtoMessage()
func (*ResultSetMeta) ProtoReflect ¶
func (x *ResultSetMeta) ProtoReflect() protoreflect.Message
func (*ResultSetMeta) Reset ¶
func (x *ResultSetMeta) Reset()
func (*ResultSetMeta) String ¶
func (x *ResultSetMeta) String() string
type RollbackTransactionRequest ¶
type RollbackTransactionRequest struct { // Session identifier (required) SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Transaction identifier (required) TxId string `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // contains filtered or unexported fields }
func (*RollbackTransactionRequest) Descriptor
deprecated
func (*RollbackTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use RollbackTransactionRequest.ProtoReflect.Descriptor instead.
func (*RollbackTransactionRequest) GetSessionId ¶
func (x *RollbackTransactionRequest) GetSessionId() string
func (*RollbackTransactionRequest) GetTxId ¶
func (x *RollbackTransactionRequest) GetTxId() 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 Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"` Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"` // contains filtered or unexported fields }
func (*RollbackTransactionResponse) Descriptor
deprecated
func (*RollbackTransactionResponse) Descriptor() ([]byte, []int)
Deprecated: Use RollbackTransactionResponse.ProtoReflect.Descriptor instead.
func (*RollbackTransactionResponse) GetIssues ¶
func (x *RollbackTransactionResponse) GetIssues() []*Ydb_Issue.IssueMessage
func (*RollbackTransactionResponse) GetStatus ¶
func (x *RollbackTransactionResponse) GetStatus() Ydb.StatusIds_StatusCode
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 Script ¶
type Script struct { ScriptContent *QueryContent `protobuf:"bytes,1,opt,name=script_content,json=scriptContent,proto3" json:"script_content,omitempty"` // contains filtered or unexported fields }
func (*Script) Descriptor
deprecated
func (*Script) GetScriptContent ¶
func (x *Script) GetScriptContent() *QueryContent
func (*Script) ProtoMessage ¶
func (*Script) ProtoMessage()
func (*Script) ProtoReflect ¶
func (x *Script) ProtoReflect() protoreflect.Message
type SerializableModeSettings ¶
type SerializableModeSettings struct {
// contains filtered or unexported fields
}
func (*SerializableModeSettings) Descriptor
deprecated
func (*SerializableModeSettings) Descriptor() ([]byte, []int)
Deprecated: Use SerializableModeSettings.ProtoReflect.Descriptor instead.
func (*SerializableModeSettings) ProtoMessage ¶
func (*SerializableModeSettings) ProtoMessage()
func (*SerializableModeSettings) ProtoReflect ¶
func (x *SerializableModeSettings) ProtoReflect() protoreflect.Message
func (*SerializableModeSettings) Reset ¶
func (x *SerializableModeSettings) Reset()
func (*SerializableModeSettings) String ¶
func (x *SerializableModeSettings) String() string
type SessionState ¶
type SessionState struct { Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"` Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"` // contains filtered or unexported fields }
func (*SessionState) Descriptor
deprecated
func (*SessionState) Descriptor() ([]byte, []int)
Deprecated: Use SessionState.ProtoReflect.Descriptor instead.
func (*SessionState) GetIssues ¶
func (x *SessionState) GetIssues() []*Ydb_Issue.IssueMessage
func (*SessionState) GetStatus ¶
func (x *SessionState) GetStatus() Ydb.StatusIds_StatusCode
func (*SessionState) ProtoMessage ¶
func (*SessionState) ProtoMessage()
func (*SessionState) ProtoReflect ¶
func (x *SessionState) ProtoReflect() protoreflect.Message
func (*SessionState) Reset ¶
func (x *SessionState) Reset()
func (*SessionState) String ¶
func (x *SessionState) String() string
type SnapshotModeSettings ¶
type SnapshotModeSettings struct {
// contains filtered or unexported fields
}
func (*SnapshotModeSettings) Descriptor
deprecated
func (*SnapshotModeSettings) Descriptor() ([]byte, []int)
Deprecated: Use SnapshotModeSettings.ProtoReflect.Descriptor instead.
func (*SnapshotModeSettings) ProtoMessage ¶
func (*SnapshotModeSettings) ProtoMessage()
func (*SnapshotModeSettings) ProtoReflect ¶
func (x *SnapshotModeSettings) ProtoReflect() protoreflect.Message
func (*SnapshotModeSettings) Reset ¶
func (x *SnapshotModeSettings) Reset()
func (*SnapshotModeSettings) String ¶
func (x *SnapshotModeSettings) String() string
type StaleModeSettings ¶
type StaleModeSettings struct {
// contains filtered or unexported fields
}
func (*StaleModeSettings) Descriptor
deprecated
func (*StaleModeSettings) Descriptor() ([]byte, []int)
Deprecated: Use StaleModeSettings.ProtoReflect.Descriptor instead.
func (*StaleModeSettings) ProtoMessage ¶
func (*StaleModeSettings) ProtoMessage()
func (*StaleModeSettings) ProtoReflect ¶
func (x *StaleModeSettings) ProtoReflect() protoreflect.Message
func (*StaleModeSettings) Reset ¶
func (x *StaleModeSettings) Reset()
func (*StaleModeSettings) String ¶
func (x *StaleModeSettings) String() string
type StatsMode ¶
type StatsMode int32
const ( StatsMode_STATS_MODE_UNSPECIFIED StatsMode = 0 StatsMode_STATS_MODE_NONE StatsMode = 10 // Stats collection is disabled StatsMode_STATS_MODE_BASIC StatsMode = 20 // Aggregated stats of reads, updates and deletes per table StatsMode_STATS_MODE_FULL StatsMode = 30 // Add execution stats and plan on top of STATS_MODE_BASIC StatsMode_STATS_MODE_PROFILE StatsMode = 40 // Detailed execution stats including stats for individual tasks and channels )
func (StatsMode) Descriptor ¶
func (StatsMode) Descriptor() protoreflect.EnumDescriptor
func (StatsMode) EnumDescriptor
deprecated
func (StatsMode) Number ¶
func (x StatsMode) Number() protoreflect.EnumNumber
func (StatsMode) Type ¶
func (StatsMode) Type() protoreflect.EnumType
type Syntax ¶
type Syntax int32
func (Syntax) Descriptor ¶
func (Syntax) Descriptor() protoreflect.EnumDescriptor
func (Syntax) EnumDescriptor
deprecated
func (Syntax) Number ¶
func (x Syntax) Number() protoreflect.EnumNumber
func (Syntax) Type ¶
func (Syntax) Type() protoreflect.EnumType
type TransactionControl ¶
type TransactionControl struct { // Types that are assignable to TxSelector: // // *TransactionControl_TxId // *TransactionControl_BeginTx TxSelector isTransactionControl_TxSelector `protobuf_oneof:"tx_selector"` CommitTx bool `protobuf:"varint,10,opt,name=commit_tx,json=commitTx,proto3" json:"commit_tx,omitempty"` // contains filtered or unexported fields }
func (*TransactionControl) Descriptor
deprecated
func (*TransactionControl) Descriptor() ([]byte, []int)
Deprecated: Use TransactionControl.ProtoReflect.Descriptor instead.
func (*TransactionControl) GetBeginTx ¶
func (x *TransactionControl) GetBeginTx() *TransactionSettings
func (*TransactionControl) GetCommitTx ¶
func (x *TransactionControl) GetCommitTx() bool
func (*TransactionControl) GetTxId ¶
func (x *TransactionControl) GetTxId() string
func (*TransactionControl) GetTxSelector ¶
func (m *TransactionControl) GetTxSelector() isTransactionControl_TxSelector
func (*TransactionControl) ProtoMessage ¶
func (*TransactionControl) ProtoMessage()
func (*TransactionControl) ProtoReflect ¶
func (x *TransactionControl) ProtoReflect() protoreflect.Message
func (*TransactionControl) Reset ¶
func (x *TransactionControl) Reset()
func (*TransactionControl) String ¶
func (x *TransactionControl) String() string
type TransactionControl_BeginTx ¶
type TransactionControl_BeginTx struct {
BeginTx *TransactionSettings `protobuf:"bytes,2,opt,name=begin_tx,json=beginTx,proto3,oneof"`
}
type TransactionControl_TxId ¶
type TransactionControl_TxId struct {
TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3,oneof"`
}
type TransactionMeta ¶
type TransactionMeta struct { // Transaction identifier Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*TransactionMeta) Descriptor
deprecated
func (*TransactionMeta) Descriptor() ([]byte, []int)
Deprecated: Use TransactionMeta.ProtoReflect.Descriptor instead.
func (*TransactionMeta) GetId ¶
func (x *TransactionMeta) GetId() string
func (*TransactionMeta) ProtoMessage ¶
func (*TransactionMeta) ProtoMessage()
func (*TransactionMeta) ProtoReflect ¶
func (x *TransactionMeta) ProtoReflect() protoreflect.Message
func (*TransactionMeta) Reset ¶
func (x *TransactionMeta) Reset()
func (*TransactionMeta) String ¶
func (x *TransactionMeta) String() string
type TransactionSettings ¶
type TransactionSettings struct { // Types that are assignable to TxMode: // // *TransactionSettings_SerializableReadWrite // *TransactionSettings_OnlineReadOnly // *TransactionSettings_StaleReadOnly // *TransactionSettings_SnapshotReadOnly TxMode isTransactionSettings_TxMode `protobuf_oneof:"tx_mode"` // contains filtered or unexported fields }
func (*TransactionSettings) Descriptor
deprecated
func (*TransactionSettings) Descriptor() ([]byte, []int)
Deprecated: Use TransactionSettings.ProtoReflect.Descriptor instead.
func (*TransactionSettings) GetOnlineReadOnly ¶
func (x *TransactionSettings) GetOnlineReadOnly() *OnlineModeSettings
func (*TransactionSettings) GetSerializableReadWrite ¶
func (x *TransactionSettings) GetSerializableReadWrite() *SerializableModeSettings
func (*TransactionSettings) GetSnapshotReadOnly ¶
func (x *TransactionSettings) GetSnapshotReadOnly() *SnapshotModeSettings
func (*TransactionSettings) GetStaleReadOnly ¶
func (x *TransactionSettings) GetStaleReadOnly() *StaleModeSettings
func (*TransactionSettings) GetTxMode ¶
func (m *TransactionSettings) GetTxMode() isTransactionSettings_TxMode
func (*TransactionSettings) ProtoMessage ¶
func (*TransactionSettings) ProtoMessage()
func (*TransactionSettings) ProtoReflect ¶
func (x *TransactionSettings) ProtoReflect() protoreflect.Message
func (*TransactionSettings) Reset ¶
func (x *TransactionSettings) Reset()
func (*TransactionSettings) String ¶
func (x *TransactionSettings) String() string
type TransactionSettings_OnlineReadOnly ¶
type TransactionSettings_OnlineReadOnly struct {
OnlineReadOnly *OnlineModeSettings `protobuf:"bytes,2,opt,name=online_read_only,json=onlineReadOnly,proto3,oneof"`
}
type TransactionSettings_SerializableReadWrite ¶
type TransactionSettings_SerializableReadWrite struct {
SerializableReadWrite *SerializableModeSettings `protobuf:"bytes,1,opt,name=serializable_read_write,json=serializableReadWrite,proto3,oneof"`
}
type TransactionSettings_SnapshotReadOnly ¶
type TransactionSettings_SnapshotReadOnly struct {
SnapshotReadOnly *SnapshotModeSettings `protobuf:"bytes,4,opt,name=snapshot_read_only,json=snapshotReadOnly,proto3,oneof"`
}
type TransactionSettings_StaleReadOnly ¶
type TransactionSettings_StaleReadOnly struct {
StaleReadOnly *StaleModeSettings `protobuf:"bytes,3,opt,name=stale_read_only,json=staleReadOnly,proto3,oneof"`
}