Ydb_Query

package
v0.0.0-...-ea1f632 Latest Latest
Warning

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

Go to latest
Published: Nov 12, 2024 License: Apache-2.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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 (*BeginTransactionResponse) GetStatus

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 (*CommitTransactionResponse) GetStatus

func (*CommitTransactionResponse) ProtoMessage

func (*CommitTransactionResponse) ProtoMessage()

func (*CommitTransactionResponse) ProtoReflect

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 (*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 (*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
const (
	ExecMode_EXEC_MODE_UNSPECIFIED ExecMode = 0
	ExecMode_EXEC_MODE_PARSE       ExecMode = 10
	ExecMode_EXEC_MODE_VALIDATE    ExecMode = 20
	ExecMode_EXEC_MODE_EXPLAIN     ExecMode = 30
	ExecMode_EXEC_MODE_EXECUTE     ExecMode = 50
)

func (ExecMode) Descriptor

func (ExecMode) Descriptor() protoreflect.EnumDescriptor

func (ExecMode) Enum

func (x ExecMode) Enum() *ExecMode

func (ExecMode) EnumDescriptor deprecated

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

Deprecated: Use ExecMode.Descriptor instead.

func (ExecMode) Number

func (x ExecMode) Number() protoreflect.EnumNumber

func (ExecMode) String

func (x ExecMode) String() string

func (ExecMode) Type

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

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 (*ExecuteQueryResponsePart) GetIssues

func (*ExecuteQueryResponsePart) GetResultSet

func (x *ExecuteQueryResponsePart) GetResultSet() *Ydb.ResultSet

func (*ExecuteQueryResponsePart) GetResultSetIndex

func (x *ExecuteQueryResponsePart) GetResultSetIndex() int64

func (*ExecuteQueryResponsePart) GetStatus

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 (*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 (*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 (*FetchScriptResultsResponse) ProtoMessage

func (*FetchScriptResultsResponse) ProtoMessage()

func (*FetchScriptResultsResponse) ProtoReflect

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 (*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 (*RollbackTransactionResponse) GetStatus

func (*RollbackTransactionResponse) ProtoMessage

func (*RollbackTransactionResponse) ProtoMessage()

func (*RollbackTransactionResponse) ProtoReflect

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) Descriptor() ([]byte, []int)

Deprecated: Use Script.ProtoReflect.Descriptor instead.

func (*Script) GetScriptContent

func (x *Script) GetScriptContent() *QueryContent

func (*Script) ProtoMessage

func (*Script) ProtoMessage()

func (*Script) ProtoReflect

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

func (*Script) Reset

func (x *Script) Reset()

func (*Script) String

func (x *Script) String() string

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) Enum

func (x StatsMode) Enum() *StatsMode

func (StatsMode) EnumDescriptor deprecated

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

Deprecated: Use StatsMode.Descriptor instead.

func (StatsMode) Number

func (x StatsMode) Number() protoreflect.EnumNumber

func (StatsMode) String

func (x StatsMode) String() string

func (StatsMode) Type

type Syntax

type Syntax int32
const (
	Syntax_SYNTAX_UNSPECIFIED Syntax = 0
	Syntax_SYNTAX_YQL_V1      Syntax = 1 // YQL
	Syntax_SYNTAX_PG          Syntax = 2 // PostgresQL
)

func (Syntax) Descriptor

func (Syntax) Descriptor() protoreflect.EnumDescriptor

func (Syntax) Enum

func (x Syntax) Enum() *Syntax

func (Syntax) EnumDescriptor deprecated

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

Deprecated: Use Syntax.Descriptor instead.

func (Syntax) Number

func (x Syntax) Number() protoreflect.EnumNumber

func (Syntax) String

func (x Syntax) String() string

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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL