package Ydb_Scripting

import "github.com/ydb-platform/ydb-go-genproto/protos/Ydb_Scripting"

Index

Variables

var (
	ExplainYqlRequest_Mode_name = map[int32]string{
		0: "MODE_UNSPECIFIED",
		2: "VALIDATE",
		3: "PLAN",
	}
	ExplainYqlRequest_Mode_value = map[string]int32{
		"MODE_UNSPECIFIED": 0,
		"VALIDATE":         2,
		"PLAN":             3,
	}
)

Enum value maps for ExplainYqlRequest_Mode.

var File_protos_ydb_scripting_proto protoreflect.FileDescriptor

Types

type ExecuteYqlPartialResponse

type ExecuteYqlPartialResponse 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"`
	Result *ExecuteYqlPartialResult  `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

Response for StreamExecuteYql is a stream of ExecuteYqlPartialResponse messages. These responses can contain ExecuteYqlPartialResult messages with results (or result parts) for data or scan queries in the script. YqlScript can have multiple results (result sets). Each result set has an index (starting at 0).

func (*ExecuteYqlPartialResponse) Descriptor

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

Deprecated: Use ExecuteYqlPartialResponse.ProtoReflect.Descriptor instead.

func (*ExecuteYqlPartialResponse) GetIssues

func (*ExecuteYqlPartialResponse) GetResult

func (*ExecuteYqlPartialResponse) GetStatus

func (*ExecuteYqlPartialResponse) ProtoMessage

func (*ExecuteYqlPartialResponse) ProtoMessage()

func (*ExecuteYqlPartialResponse) ProtoReflect

func (*ExecuteYqlPartialResponse) Reset

func (x *ExecuteYqlPartialResponse) Reset()

func (*ExecuteYqlPartialResponse) String

func (x *ExecuteYqlPartialResponse) String() string

type ExecuteYqlPartialResult

type ExecuteYqlPartialResult struct {

	// Index of current result
	ResultSetIndex uint32 `protobuf:"varint,1,opt,name=result_set_index,json=resultSetIndex,proto3" json:"result_set_index,omitempty"`
	// Result set (or a result set part) for one data or scan query
	ResultSet  *Ydb.ResultSet             `protobuf:"bytes,2,opt,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"`
	QueryStats *Ydb_TableStats.QueryStats `protobuf:"bytes,3,opt,name=query_stats,json=queryStats,proto3" json:"query_stats,omitempty"`
	// contains filtered or unexported fields
}

Contains result set (or a result set part) for one data or scan query in the script. One result set can be split into several responses with same result_index. Only the final response can contain query stats.

func (*ExecuteYqlPartialResult) Descriptor

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

Deprecated: Use ExecuteYqlPartialResult.ProtoReflect.Descriptor instead.

func (*ExecuteYqlPartialResult) GetQueryStats

func (*ExecuteYqlPartialResult) GetResultSet

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

func (*ExecuteYqlPartialResult) GetResultSetIndex

func (x *ExecuteYqlPartialResult) GetResultSetIndex() uint32

func (*ExecuteYqlPartialResult) ProtoMessage

func (*ExecuteYqlPartialResult) ProtoMessage()

func (*ExecuteYqlPartialResult) ProtoReflect

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

func (*ExecuteYqlPartialResult) Reset

func (x *ExecuteYqlPartialResult) Reset()

func (*ExecuteYqlPartialResult) String

func (x *ExecuteYqlPartialResult) String() string

type ExecuteYqlRequest

type ExecuteYqlRequest struct {
	OperationParams *Ydb_Operations.OperationParams     `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	Script          string                              `protobuf:"bytes,2,opt,name=script,proto3" json:"script,omitempty"`
	Parameters      map[string]*Ydb.TypedValue          `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	CollectStats    Ydb_Table.QueryStatsCollection_Mode `protobuf:"varint,4,opt,name=collect_stats,json=collectStats,proto3,enum=Ydb.Table.QueryStatsCollection_Mode" json:"collect_stats,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteYqlRequest) Descriptor

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

Deprecated: Use ExecuteYqlRequest.ProtoReflect.Descriptor instead.

func (*ExecuteYqlRequest) GetCollectStats

func (*ExecuteYqlRequest) GetOperationParams

func (x *ExecuteYqlRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ExecuteYqlRequest) GetParameters

func (x *ExecuteYqlRequest) GetParameters() map[string]*Ydb.TypedValue

func (*ExecuteYqlRequest) GetScript

func (x *ExecuteYqlRequest) GetScript() string

func (*ExecuteYqlRequest) ProtoMessage

func (*ExecuteYqlRequest) ProtoMessage()

func (*ExecuteYqlRequest) ProtoReflect

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

func (*ExecuteYqlRequest) Reset

func (x *ExecuteYqlRequest) Reset()

func (*ExecuteYqlRequest) String

func (x *ExecuteYqlRequest) String() string

type ExecuteYqlResponse

type ExecuteYqlResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteYqlResponse) Descriptor

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

Deprecated: Use ExecuteYqlResponse.ProtoReflect.Descriptor instead.

func (*ExecuteYqlResponse) GetOperation

func (x *ExecuteYqlResponse) GetOperation() *Ydb_Operations.Operation

func (*ExecuteYqlResponse) ProtoMessage

func (*ExecuteYqlResponse) ProtoMessage()

func (*ExecuteYqlResponse) ProtoReflect

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

func (*ExecuteYqlResponse) Reset

func (x *ExecuteYqlResponse) Reset()

func (*ExecuteYqlResponse) String

func (x *ExecuteYqlResponse) String() string

type ExecuteYqlResult

type ExecuteYqlResult struct {
	ResultSets []*Ydb.ResultSet           `protobuf:"bytes,1,rep,name=result_sets,json=resultSets,proto3" json:"result_sets,omitempty"`
	QueryStats *Ydb_TableStats.QueryStats `protobuf:"bytes,2,opt,name=query_stats,json=queryStats,proto3" json:"query_stats,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteYqlResult) Descriptor

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

Deprecated: Use ExecuteYqlResult.ProtoReflect.Descriptor instead.

func (*ExecuteYqlResult) GetQueryStats

func (x *ExecuteYqlResult) GetQueryStats() *Ydb_TableStats.QueryStats

func (*ExecuteYqlResult) GetResultSets

func (x *ExecuteYqlResult) GetResultSets() []*Ydb.ResultSet

func (*ExecuteYqlResult) ProtoMessage

func (*ExecuteYqlResult) ProtoMessage()

func (*ExecuteYqlResult) ProtoReflect

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

func (*ExecuteYqlResult) Reset

func (x *ExecuteYqlResult) Reset()

func (*ExecuteYqlResult) String

func (x *ExecuteYqlResult) String() string

type ExplainYqlRequest

type ExplainYqlRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	Script          string                          `protobuf:"bytes,2,opt,name=script,proto3" json:"script,omitempty"`
	Mode            ExplainYqlRequest_Mode          `protobuf:"varint,3,opt,name=mode,proto3,enum=Ydb.Scripting.ExplainYqlRequest_Mode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainYqlRequest) Descriptor

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

Deprecated: Use ExplainYqlRequest.ProtoReflect.Descriptor instead.

func (*ExplainYqlRequest) GetMode

func (*ExplainYqlRequest) GetOperationParams

func (x *ExplainYqlRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ExplainYqlRequest) GetScript

func (x *ExplainYqlRequest) GetScript() string

func (*ExplainYqlRequest) ProtoMessage

func (*ExplainYqlRequest) ProtoMessage()

func (*ExplainYqlRequest) ProtoReflect

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

func (*ExplainYqlRequest) Reset

func (x *ExplainYqlRequest) Reset()

func (*ExplainYqlRequest) String

func (x *ExplainYqlRequest) String() string

type ExplainYqlRequest_Mode

type ExplainYqlRequest_Mode int32
const (
	ExplainYqlRequest_MODE_UNSPECIFIED ExplainYqlRequest_Mode = 0
	// PARSE = 1;
	ExplainYqlRequest_VALIDATE ExplainYqlRequest_Mode = 2
	ExplainYqlRequest_PLAN     ExplainYqlRequest_Mode = 3
)

func (ExplainYqlRequest_Mode) Descriptor

func (ExplainYqlRequest_Mode) Enum

func (ExplainYqlRequest_Mode) EnumDescriptor

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

Deprecated: Use ExplainYqlRequest_Mode.Descriptor instead.

func (ExplainYqlRequest_Mode) Number

func (ExplainYqlRequest_Mode) String

func (x ExplainYqlRequest_Mode) String() string

func (ExplainYqlRequest_Mode) Type

type ExplainYqlResponse

type ExplainYqlResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainYqlResponse) Descriptor

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

Deprecated: Use ExplainYqlResponse.ProtoReflect.Descriptor instead.

func (*ExplainYqlResponse) GetOperation

func (x *ExplainYqlResponse) GetOperation() *Ydb_Operations.Operation

func (*ExplainYqlResponse) ProtoMessage

func (*ExplainYqlResponse) ProtoMessage()

func (*ExplainYqlResponse) ProtoReflect

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

func (*ExplainYqlResponse) Reset

func (x *ExplainYqlResponse) Reset()

func (*ExplainYqlResponse) String

func (x *ExplainYqlResponse) String() string

type ExplainYqlResult

type ExplainYqlResult struct {
	ParametersTypes map[string]*Ydb.Type `protobuf:"bytes,1,rep,name=parameters_types,json=parametersTypes,proto3" json:"parameters_types,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	Plan            string               `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainYqlResult) Descriptor

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

Deprecated: Use ExplainYqlResult.ProtoReflect.Descriptor instead.

func (*ExplainYqlResult) GetParametersTypes

func (x *ExplainYqlResult) GetParametersTypes() map[string]*Ydb.Type

func (*ExplainYqlResult) GetPlan

func (x *ExplainYqlResult) GetPlan() string

func (*ExplainYqlResult) ProtoMessage

func (*ExplainYqlResult) ProtoMessage()

func (*ExplainYqlResult) ProtoReflect

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

func (*ExplainYqlResult) Reset

func (x *ExplainYqlResult) Reset()

func (*ExplainYqlResult) String

func (x *ExplainYqlResult) String() string

Source Files

ydb_scripting.pb.go

Version
v0.0.0-20241112172322-ea1f63298f77 (latest)
Published
Nov 12, 2024
Platform
js/wasm
Imports
9 packages
Last checked
10 hours ago

Tools for package owners.