Ydb_Query

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
}

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
}

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
}

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
}

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
}

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

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
}

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
}

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
}

type ExecMode int32

type ExecStatus int32

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 */
	// Workload manager pool id
	PoolId string `protobuf:"bytes,10,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// Time interval for sending periodical query statistics.
	// When query statistics are enabled (stats_mode != STATS_MODE_NONE), by default statistics will be sent only once after query execution is finished.
	// In case when stats_period_ms is specified and is non-zero, query statistics will be additionally sent every stats_period_ms milliseconds beginning from the start of query execution.
	StatsPeriodMs int64 `protobuf:"varint,11,opt,name=stats_period_ms,json=statsPeriodMs,proto3" json:"stats_period_ms,omitempty"`
	// Schema inclusion mode for the result sets.
	// If is not specified, SchemaInclusionMode.SCHEMA_INCLUSION_MODE_ALWAYS is used.
	SchemaInclusionMode SchemaInclusionMode `` /* 157-byte string literal not displayed */
	// Format of the result sets.
	// If is not specified, Ydb.ResultSet.Format.FORMAT_VALUE is used.
	ResultSetFormat Ydb.ResultSet_Format `` /* 136-byte string literal not displayed */
	// Format settings, only used for Ydb.ResultSet.Format.FORMAT_ARROW
	ArrowFormatSettings *Ydb_Formats.ArrowFormatSettings `protobuf:"bytes,14,opt,name=arrow_format_settings,json=arrowFormatSettings,proto3" json:"arrow_format_settings,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteQueryRequest_QueryContent struct {
	QueryContent *QueryContent `protobuf:"bytes,4,opt,name=query_content,json=queryContent,proto3,oneof"`
}

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
}

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
}

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
}

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
}

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
}

type OnlineModeSettings struct {
	AllowInconsistentReads bool `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

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
}

type ResultSetMeta struct {
	Columns []*Ydb.Column `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

type SchemaInclusionMode int32

type Script struct {
	ScriptContent *QueryContent `protobuf:"bytes,1,opt,name=script_content,json=scriptContent,proto3" json:"script_content,omitempty"`
	// contains filtered or unexported fields
}

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

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
}

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

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

type StatsMode int32

type Syntax int32

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
}

type TransactionControl_BeginTx struct {
	BeginTx *TransactionSettings `protobuf:"bytes,2,opt,name=begin_tx,json=beginTx,proto3,oneof"`
}

type TransactionControl_TxId struct {
	TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3,oneof"`
}

type TransactionMeta struct {

	// Transaction identifier
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

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
}

type TransactionSettings_OnlineReadOnly struct {
	OnlineReadOnly *OnlineModeSettings `protobuf:"bytes,2,opt,name=online_read_only,json=onlineReadOnly,proto3,oneof"`
}

type TransactionSettings_SerializableReadWrite struct {
	SerializableReadWrite *SerializableModeSettings `protobuf:"bytes,1,opt,name=serializable_read_write,json=serializableReadWrite,proto3,oneof"`
}

type TransactionSettings_SnapshotReadOnly struct {
	SnapshotReadOnly *SnapshotModeSettings `protobuf:"bytes,4,opt,name=snapshot_read_only,json=snapshotReadOnly,proto3,oneof"`
}

type TransactionSettings_StaleReadOnly struct {
	StaleReadOnly *StaleModeSettings `protobuf:"bytes,3,opt,name=stale_read_only,json=staleReadOnly,proto3,oneof"`
}