Ydb_Scripting

package
v2.10.9 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

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)

func (*ExecuteYqlPartialResponse) GetIssues 

func (m *ExecuteYqlPartialResponse) GetIssues() []*Ydb_Issue.IssueMessage

func (*ExecuteYqlPartialResponse) GetResult 

func (m *ExecuteYqlPartialResponse) GetResult() *ExecuteYqlPartialResult

func (*ExecuteYqlPartialResponse) GetStatus 

func (m *ExecuteYqlPartialResponse) GetStatus() Ydb.StatusIds_StatusCode

func (*ExecuteYqlPartialResponse) ProtoMessage 

func (*ExecuteYqlPartialResponse) ProtoMessage()

func (*ExecuteYqlPartialResponse) Reset 

func (m *ExecuteYqlPartialResponse) Reset()

func (*ExecuteYqlPartialResponse) String 

func (m *ExecuteYqlPartialResponse) String() string

func (*ExecuteYqlPartialResponse) XXX_DiscardUnknown 

func (m *ExecuteYqlPartialResponse) XXX_DiscardUnknown()

func (*ExecuteYqlPartialResponse) XXX_Marshal 

func (m *ExecuteYqlPartialResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteYqlPartialResponse) XXX_Merge 

func (m *ExecuteYqlPartialResponse) XXX_Merge(src proto.Message)

func (*ExecuteYqlPartialResponse) XXX_Size 

func (m *ExecuteYqlPartialResponse) XXX_Size() int

func (*ExecuteYqlPartialResponse) XXX_Unmarshal 

func (m *ExecuteYqlPartialResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

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)

func (*ExecuteYqlPartialResult) GetQueryStats 

func (m *ExecuteYqlPartialResult) GetQueryStats() *Ydb_TableStats.QueryStats

func (*ExecuteYqlPartialResult) GetResultSet 

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

func (*ExecuteYqlPartialResult) GetResultSetIndex 

func (m *ExecuteYqlPartialResult) GetResultSetIndex() uint32

func (*ExecuteYqlPartialResult) ProtoMessage 

func (*ExecuteYqlPartialResult) ProtoMessage()

func (*ExecuteYqlPartialResult) Reset 

func (m *ExecuteYqlPartialResult) Reset()

func (*ExecuteYqlPartialResult) String 

func (m *ExecuteYqlPartialResult) String() string

func (*ExecuteYqlPartialResult) XXX_DiscardUnknown 

func (m *ExecuteYqlPartialResult) XXX_DiscardUnknown()

func (*ExecuteYqlPartialResult) XXX_Marshal 

func (m *ExecuteYqlPartialResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteYqlPartialResult) XXX_Merge 

func (m *ExecuteYqlPartialResult) XXX_Merge(src proto.Message)

func (*ExecuteYqlPartialResult) XXX_Size 

func (m *ExecuteYqlPartialResult) XXX_Size() int

func (*ExecuteYqlPartialResult) XXX_Unmarshal 

func (m *ExecuteYqlPartialResult) XXX_Unmarshal(b []byte) error

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          `` /* 161-byte string literal not displayed */
	CollectStats         Ydb_Table.QueryStatsCollection_Mode `` /* 139-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*ExecuteYqlRequest) Descriptor 

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

func (*ExecuteYqlRequest) GetCollectStats 

func (m *ExecuteYqlRequest) GetCollectStats() Ydb_Table.QueryStatsCollection_Mode

func (*ExecuteYqlRequest) GetOperationParams 

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

func (*ExecuteYqlRequest) GetParameters 

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

func (*ExecuteYqlRequest) GetScript 

func (m *ExecuteYqlRequest) GetScript() string

func (*ExecuteYqlRequest) ProtoMessage 

func (*ExecuteYqlRequest) ProtoMessage()

func (*ExecuteYqlRequest) Reset 

func (m *ExecuteYqlRequest) Reset()

func (*ExecuteYqlRequest) SetOperationParams 

func (m *ExecuteYqlRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*ExecuteYqlRequest) String 

func (m *ExecuteYqlRequest) String() string

func (*ExecuteYqlRequest) XXX_DiscardUnknown 

func (m *ExecuteYqlRequest) XXX_DiscardUnknown()

func (*ExecuteYqlRequest) XXX_Marshal 

func (m *ExecuteYqlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteYqlRequest) XXX_Merge 

func (m *ExecuteYqlRequest) XXX_Merge(src proto.Message)

func (*ExecuteYqlRequest) XXX_Size 

func (m *ExecuteYqlRequest) XXX_Size() int

func (*ExecuteYqlRequest) XXX_Unmarshal 

func (m *ExecuteYqlRequest) XXX_Unmarshal(b []byte) error

type ExecuteYqlResponse 

type ExecuteYqlResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ExecuteYqlResponse) Descriptor 

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

func (*ExecuteYqlResponse) GetOperation 

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

func (*ExecuteYqlResponse) ProtoMessage 

func (*ExecuteYqlResponse) ProtoMessage()

func (*ExecuteYqlResponse) Reset 

func (m *ExecuteYqlResponse) Reset()

func (*ExecuteYqlResponse) String 

func (m *ExecuteYqlResponse) String() string

func (*ExecuteYqlResponse) XXX_DiscardUnknown 

func (m *ExecuteYqlResponse) XXX_DiscardUnknown()

func (*ExecuteYqlResponse) XXX_Marshal 

func (m *ExecuteYqlResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteYqlResponse) XXX_Merge 

func (m *ExecuteYqlResponse) XXX_Merge(src proto.Message)

func (*ExecuteYqlResponse) XXX_Size 

func (m *ExecuteYqlResponse) XXX_Size() int

func (*ExecuteYqlResponse) XXX_Unmarshal 

func (m *ExecuteYqlResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ExecuteYqlResult) Descriptor 

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

func (*ExecuteYqlResult) GetQueryStats 

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

func (*ExecuteYqlResult) GetResultSets 

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

func (*ExecuteYqlResult) ProtoMessage 

func (*ExecuteYqlResult) ProtoMessage()

func (*ExecuteYqlResult) Reset 

func (m *ExecuteYqlResult) Reset()

func (*ExecuteYqlResult) String 

func (m *ExecuteYqlResult) String() string

func (*ExecuteYqlResult) XXX_DiscardUnknown 

func (m *ExecuteYqlResult) XXX_DiscardUnknown()

func (*ExecuteYqlResult) XXX_Marshal 

func (m *ExecuteYqlResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteYqlResult) XXX_Merge 

func (m *ExecuteYqlResult) XXX_Merge(src proto.Message)

func (*ExecuteYqlResult) XXX_Size 

func (m *ExecuteYqlResult) XXX_Size() int

func (*ExecuteYqlResult) XXX_Unmarshal 

func (m *ExecuteYqlResult) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*ExplainYqlRequest) Descriptor 

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

func (*ExplainYqlRequest) GetMode 

func (m *ExplainYqlRequest) GetMode() ExplainYqlRequest_Mode

func (*ExplainYqlRequest) GetOperationParams 

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

func (*ExplainYqlRequest) GetScript 

func (m *ExplainYqlRequest) GetScript() string

func (*ExplainYqlRequest) ProtoMessage 

func (*ExplainYqlRequest) ProtoMessage()

func (*ExplainYqlRequest) Reset 

func (m *ExplainYqlRequest) Reset()

func (*ExplainYqlRequest) SetOperationParams 

func (m *ExplainYqlRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*ExplainYqlRequest) String 

func (m *ExplainYqlRequest) String() string

func (*ExplainYqlRequest) XXX_DiscardUnknown 

func (m *ExplainYqlRequest) XXX_DiscardUnknown()

func (*ExplainYqlRequest) XXX_Marshal 

func (m *ExplainYqlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExplainYqlRequest) XXX_Merge 

func (m *ExplainYqlRequest) XXX_Merge(src proto.Message)

func (*ExplainYqlRequest) XXX_Size 

func (m *ExplainYqlRequest) XXX_Size() int

func (*ExplainYqlRequest) XXX_Unmarshal 

func (m *ExplainYqlRequest) XXX_Unmarshal(b []byte) error

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

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

func (ExplainYqlRequest_Mode) String 

func (x ExplainYqlRequest_Mode) String() string

type ExplainYqlResponse 

type ExplainYqlResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ExplainYqlResponse) Descriptor 

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

func (*ExplainYqlResponse) GetOperation 

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

func (*ExplainYqlResponse) ProtoMessage 

func (*ExplainYqlResponse) ProtoMessage()

func (*ExplainYqlResponse) Reset 

func (m *ExplainYqlResponse) Reset()

func (*ExplainYqlResponse) String 

func (m *ExplainYqlResponse) String() string

func (*ExplainYqlResponse) XXX_DiscardUnknown 

func (m *ExplainYqlResponse) XXX_DiscardUnknown()

func (*ExplainYqlResponse) XXX_Marshal 

func (m *ExplainYqlResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExplainYqlResponse) XXX_Merge 

func (m *ExplainYqlResponse) XXX_Merge(src proto.Message)

func (*ExplainYqlResponse) XXX_Size 

func (m *ExplainYqlResponse) XXX_Size() int

func (*ExplainYqlResponse) XXX_Unmarshal 

func (m *ExplainYqlResponse) XXX_Unmarshal(b []byte) error

type ExplainYqlResult 

type ExplainYqlResult struct {
	ParametersTypes      map[string]*Ydb.Type `` /* 194-byte string literal not displayed */
	Plan                 string               `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ExplainYqlResult) Descriptor 

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

func (*ExplainYqlResult) GetParametersTypes 

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

func (*ExplainYqlResult) GetPlan 

func (m *ExplainYqlResult) GetPlan() string

func (*ExplainYqlResult) ProtoMessage 

func (*ExplainYqlResult) ProtoMessage()

func (*ExplainYqlResult) Reset 

func (m *ExplainYqlResult) Reset()

func (*ExplainYqlResult) String 

func (m *ExplainYqlResult) String() string

func (*ExplainYqlResult) XXX_DiscardUnknown 

func (m *ExplainYqlResult) XXX_DiscardUnknown()

func (*ExplainYqlResult) XXX_Marshal 

func (m *ExplainYqlResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExplainYqlResult) XXX_Merge 

func (m *ExplainYqlResult) XXX_Merge(src proto.Message)

func (*ExplainYqlResult) XXX_Size 

func (m *ExplainYqlResult) XXX_Size() int

func (*ExplainYqlResult) XXX_Unmarshal 

func (m *ExplainYqlResult) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.