Documentation ¶
Index ¶
- Variables
- type ExecuteStreamQueryRequest
- func (*ExecuteStreamQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteStreamQueryRequest) GetExplain() bool
- func (x *ExecuteStreamQueryRequest) GetParameters() map[string]*Ydb.TypedValue
- func (x *ExecuteStreamQueryRequest) GetProfileMode() ExecuteStreamQueryRequest_ProfileMode
- func (x *ExecuteStreamQueryRequest) GetYqlText() string
- func (*ExecuteStreamQueryRequest) ProtoMessage()
- func (x *ExecuteStreamQueryRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteStreamQueryRequest) Reset()
- func (x *ExecuteStreamQueryRequest) String() string
- type ExecuteStreamQueryRequest_ProfileMode
- func (ExecuteStreamQueryRequest_ProfileMode) Descriptor() protoreflect.EnumDescriptor
- func (x ExecuteStreamQueryRequest_ProfileMode) Enum() *ExecuteStreamQueryRequest_ProfileMode
- func (ExecuteStreamQueryRequest_ProfileMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x ExecuteStreamQueryRequest_ProfileMode) Number() protoreflect.EnumNumber
- func (x ExecuteStreamQueryRequest_ProfileMode) String() string
- func (ExecuteStreamQueryRequest_ProfileMode) Type() protoreflect.EnumType
- type ExecuteStreamQueryResponse
- func (*ExecuteStreamQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteStreamQueryResponse) GetIssues() []*Ydb_Issue.IssueMessage
- func (x *ExecuteStreamQueryResponse) GetResult() *ExecuteStreamQueryResult
- func (x *ExecuteStreamQueryResponse) GetStatus() Ydb.StatusIds_StatusCode
- func (*ExecuteStreamQueryResponse) ProtoMessage()
- func (x *ExecuteStreamQueryResponse) ProtoReflect() protoreflect.Message
- func (x *ExecuteStreamQueryResponse) Reset()
- func (x *ExecuteStreamQueryResponse) String() string
- type ExecuteStreamQueryResult
- func (*ExecuteStreamQueryResult) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteStreamQueryResult) GetProfile() string
- func (x *ExecuteStreamQueryResult) GetProgress() *StreamQueryProgress
- func (x *ExecuteStreamQueryResult) GetQueryPlan() string
- func (m *ExecuteStreamQueryResult) GetResult() isExecuteStreamQueryResult_Result
- func (x *ExecuteStreamQueryResult) GetResultSet() *Ydb.ResultSet
- func (*ExecuteStreamQueryResult) ProtoMessage()
- func (x *ExecuteStreamQueryResult) ProtoReflect() protoreflect.Message
- func (x *ExecuteStreamQueryResult) Reset()
- func (x *ExecuteStreamQueryResult) String() string
- type ExecuteStreamQueryResult_Profile
- type ExecuteStreamQueryResult_Progress
- type ExecuteStreamQueryResult_QueryPlan
- type ExecuteStreamQueryResult_ResultSet
- type StreamQueryProgress
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ExecuteStreamQueryRequest_ProfileMode_name = map[int32]string{ 0: "PROFILE_MODE_UNSPECIFIED", 1: "NONE", 2: "BASIC", 3: "FULL", } ExecuteStreamQueryRequest_ProfileMode_value = map[string]int32{ "PROFILE_MODE_UNSPECIFIED": 0, "NONE": 1, "BASIC": 2, "FULL": 3, } )
Enum value maps for ExecuteStreamQueryRequest_ProfileMode.
View Source
var File_protos_ydb_experimental_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ExecuteStreamQueryRequest ¶
type ExecuteStreamQueryRequest struct { YqlText string `protobuf:"bytes,1,opt,name=yql_text,json=yqlText,proto3" json:"yql_text,omitempty"` Parameters map[string]*Ydb.TypedValue `` /* 161-byte string literal not displayed */ ProfileMode ExecuteStreamQueryRequest_ProfileMode `` /* 155-byte string literal not displayed */ Explain bool `protobuf:"varint,4,opt,name=explain,proto3" json:"explain,omitempty"` // contains filtered or unexported fields }
func (*ExecuteStreamQueryRequest) Descriptor
deprecated
func (*ExecuteStreamQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteStreamQueryRequest.ProtoReflect.Descriptor instead.
func (*ExecuteStreamQueryRequest) GetExplain ¶
func (x *ExecuteStreamQueryRequest) GetExplain() bool
func (*ExecuteStreamQueryRequest) GetParameters ¶
func (x *ExecuteStreamQueryRequest) GetParameters() map[string]*Ydb.TypedValue
func (*ExecuteStreamQueryRequest) GetProfileMode ¶
func (x *ExecuteStreamQueryRequest) GetProfileMode() ExecuteStreamQueryRequest_ProfileMode
func (*ExecuteStreamQueryRequest) GetYqlText ¶
func (x *ExecuteStreamQueryRequest) GetYqlText() string
func (*ExecuteStreamQueryRequest) ProtoMessage ¶
func (*ExecuteStreamQueryRequest) ProtoMessage()
func (*ExecuteStreamQueryRequest) ProtoReflect ¶
func (x *ExecuteStreamQueryRequest) ProtoReflect() protoreflect.Message
func (*ExecuteStreamQueryRequest) Reset ¶
func (x *ExecuteStreamQueryRequest) Reset()
func (*ExecuteStreamQueryRequest) String ¶
func (x *ExecuteStreamQueryRequest) String() string
type ExecuteStreamQueryRequest_ProfileMode ¶
type ExecuteStreamQueryRequest_ProfileMode int32
const ( ExecuteStreamQueryRequest_PROFILE_MODE_UNSPECIFIED ExecuteStreamQueryRequest_ProfileMode = 0 ExecuteStreamQueryRequest_NONE ExecuteStreamQueryRequest_ProfileMode = 1 ExecuteStreamQueryRequest_BASIC ExecuteStreamQueryRequest_ProfileMode = 2 ExecuteStreamQueryRequest_FULL ExecuteStreamQueryRequest_ProfileMode = 3 )
func (ExecuteStreamQueryRequest_ProfileMode) Descriptor ¶
func (ExecuteStreamQueryRequest_ProfileMode) Descriptor() protoreflect.EnumDescriptor
func (ExecuteStreamQueryRequest_ProfileMode) EnumDescriptor
deprecated
func (ExecuteStreamQueryRequest_ProfileMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use ExecuteStreamQueryRequest_ProfileMode.Descriptor instead.
func (ExecuteStreamQueryRequest_ProfileMode) Number ¶
func (x ExecuteStreamQueryRequest_ProfileMode) Number() protoreflect.EnumNumber
func (ExecuteStreamQueryRequest_ProfileMode) String ¶
func (x ExecuteStreamQueryRequest_ProfileMode) String() string
func (ExecuteStreamQueryRequest_ProfileMode) Type ¶
func (ExecuteStreamQueryRequest_ProfileMode) Type() protoreflect.EnumType
type ExecuteStreamQueryResponse ¶
type ExecuteStreamQueryResponse 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 *ExecuteStreamQueryResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*ExecuteStreamQueryResponse) Descriptor
deprecated
func (*ExecuteStreamQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteStreamQueryResponse.ProtoReflect.Descriptor instead.
func (*ExecuteStreamQueryResponse) GetIssues ¶
func (x *ExecuteStreamQueryResponse) GetIssues() []*Ydb_Issue.IssueMessage
func (*ExecuteStreamQueryResponse) GetResult ¶
func (x *ExecuteStreamQueryResponse) GetResult() *ExecuteStreamQueryResult
func (*ExecuteStreamQueryResponse) GetStatus ¶
func (x *ExecuteStreamQueryResponse) GetStatus() Ydb.StatusIds_StatusCode
func (*ExecuteStreamQueryResponse) ProtoMessage ¶
func (*ExecuteStreamQueryResponse) ProtoMessage()
func (*ExecuteStreamQueryResponse) ProtoReflect ¶
func (x *ExecuteStreamQueryResponse) ProtoReflect() protoreflect.Message
func (*ExecuteStreamQueryResponse) Reset ¶
func (x *ExecuteStreamQueryResponse) Reset()
func (*ExecuteStreamQueryResponse) String ¶
func (x *ExecuteStreamQueryResponse) String() string
type ExecuteStreamQueryResult ¶
type ExecuteStreamQueryResult struct { // Types that are assignable to Result: // *ExecuteStreamQueryResult_ResultSet // *ExecuteStreamQueryResult_Profile // *ExecuteStreamQueryResult_Progress // *ExecuteStreamQueryResult_QueryPlan Result isExecuteStreamQueryResult_Result `protobuf_oneof:"result"` // contains filtered or unexported fields }
func (*ExecuteStreamQueryResult) Descriptor
deprecated
func (*ExecuteStreamQueryResult) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteStreamQueryResult.ProtoReflect.Descriptor instead.
func (*ExecuteStreamQueryResult) GetProfile ¶
func (x *ExecuteStreamQueryResult) GetProfile() string
func (*ExecuteStreamQueryResult) GetProgress ¶
func (x *ExecuteStreamQueryResult) GetProgress() *StreamQueryProgress
func (*ExecuteStreamQueryResult) GetQueryPlan ¶
func (x *ExecuteStreamQueryResult) GetQueryPlan() string
func (*ExecuteStreamQueryResult) GetResult ¶
func (m *ExecuteStreamQueryResult) GetResult() isExecuteStreamQueryResult_Result
func (*ExecuteStreamQueryResult) GetResultSet ¶
func (x *ExecuteStreamQueryResult) GetResultSet() *Ydb.ResultSet
func (*ExecuteStreamQueryResult) ProtoMessage ¶
func (*ExecuteStreamQueryResult) ProtoMessage()
func (*ExecuteStreamQueryResult) ProtoReflect ¶
func (x *ExecuteStreamQueryResult) ProtoReflect() protoreflect.Message
func (*ExecuteStreamQueryResult) Reset ¶
func (x *ExecuteStreamQueryResult) Reset()
func (*ExecuteStreamQueryResult) String ¶
func (x *ExecuteStreamQueryResult) String() string
type ExecuteStreamQueryResult_Profile ¶
type ExecuteStreamQueryResult_Profile struct {
Profile string `protobuf:"bytes,2,opt,name=profile,proto3,oneof"`
}
type ExecuteStreamQueryResult_Progress ¶
type ExecuteStreamQueryResult_Progress struct {
Progress *StreamQueryProgress `protobuf:"bytes,3,opt,name=progress,proto3,oneof"`
}
type ExecuteStreamQueryResult_QueryPlan ¶
type ExecuteStreamQueryResult_QueryPlan struct {
QueryPlan string `protobuf:"bytes,4,opt,name=query_plan,json=queryPlan,proto3,oneof"`
}
type StreamQueryProgress ¶
type StreamQueryProgress struct {
// contains filtered or unexported fields
}
func (*StreamQueryProgress) Descriptor
deprecated
func (*StreamQueryProgress) Descriptor() ([]byte, []int)
Deprecated: Use StreamQueryProgress.ProtoReflect.Descriptor instead.
func (*StreamQueryProgress) ProtoMessage ¶
func (*StreamQueryProgress) ProtoMessage()
func (*StreamQueryProgress) ProtoReflect ¶
func (x *StreamQueryProgress) ProtoReflect() protoreflect.Message
func (*StreamQueryProgress) Reset ¶
func (x *StreamQueryProgress) Reset()
func (*StreamQueryProgress) String ¶
func (x *StreamQueryProgress) String() string
Click to show internal directories.
Click to hide internal directories.