Ydb_Experimental

package
v2.11.2 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

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",
}
View Source 
var ExecuteStreamQueryRequest_ProfileMode_value = map[string]int32{
	"PROFILE_MODE_UNSPECIFIED": 0,
	"NONE":                     1,
	"BASIC":                    2,
	"FULL":                     3,
}

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

func (*ExecuteStreamQueryRequest) Descriptor 

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

func (*ExecuteStreamQueryRequest) GetExplain 

func (m *ExecuteStreamQueryRequest) GetExplain() bool

func (*ExecuteStreamQueryRequest) GetParameters 

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

func (*ExecuteStreamQueryRequest) GetProfileMode 

func (m *ExecuteStreamQueryRequest) GetProfileMode() ExecuteStreamQueryRequest_ProfileMode

func (*ExecuteStreamQueryRequest) GetYqlText 

func (m *ExecuteStreamQueryRequest) GetYqlText() string

func (*ExecuteStreamQueryRequest) ProtoMessage 

func (*ExecuteStreamQueryRequest) ProtoMessage()

func (*ExecuteStreamQueryRequest) Reset 

func (m *ExecuteStreamQueryRequest) Reset()

func (*ExecuteStreamQueryRequest) String 

func (m *ExecuteStreamQueryRequest) String() string

func (*ExecuteStreamQueryRequest) XXX_DiscardUnknown 

func (m *ExecuteStreamQueryRequest) XXX_DiscardUnknown()

func (*ExecuteStreamQueryRequest) XXX_Marshal 

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

func (*ExecuteStreamQueryRequest) XXX_Merge 

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

func (*ExecuteStreamQueryRequest) XXX_Size 

func (m *ExecuteStreamQueryRequest) XXX_Size() int

func (*ExecuteStreamQueryRequest) XXX_Unmarshal 

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

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

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

func (ExecuteStreamQueryRequest_ProfileMode) String 

func (x ExecuteStreamQueryRequest_ProfileMode) String() string

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

func (*ExecuteStreamQueryResponse) Descriptor 

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

func (*ExecuteStreamQueryResponse) GetIssues 

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

func (*ExecuteStreamQueryResponse) GetResult 

func (m *ExecuteStreamQueryResponse) GetResult() *ExecuteStreamQueryResult

func (*ExecuteStreamQueryResponse) GetStatus 

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

func (*ExecuteStreamQueryResponse) ProtoMessage 

func (*ExecuteStreamQueryResponse) ProtoMessage()

func (*ExecuteStreamQueryResponse) Reset 

func (m *ExecuteStreamQueryResponse) Reset()

func (*ExecuteStreamQueryResponse) String 

func (m *ExecuteStreamQueryResponse) String() string

func (*ExecuteStreamQueryResponse) XXX_DiscardUnknown 

func (m *ExecuteStreamQueryResponse) XXX_DiscardUnknown()

func (*ExecuteStreamQueryResponse) XXX_Marshal 

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

func (*ExecuteStreamQueryResponse) XXX_Merge 

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

func (*ExecuteStreamQueryResponse) XXX_Size 

func (m *ExecuteStreamQueryResponse) XXX_Size() int

func (*ExecuteStreamQueryResponse) XXX_Unmarshal 

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

type ExecuteStreamQueryResult 

type ExecuteStreamQueryResult struct {
	// Types that are valid to be assigned to Result:
	//	*ExecuteStreamQueryResult_ResultSet
	//	*ExecuteStreamQueryResult_Profile
	//	*ExecuteStreamQueryResult_Progress
	//	*ExecuteStreamQueryResult_QueryPlan
	Result               isExecuteStreamQueryResult_Result `protobuf_oneof:"result"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*ExecuteStreamQueryResult) Descriptor 

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

func (*ExecuteStreamQueryResult) GetProfile 

func (m *ExecuteStreamQueryResult) GetProfile() string

func (*ExecuteStreamQueryResult) GetProgress 

func (m *ExecuteStreamQueryResult) GetProgress() *StreamQueryProgress

func (*ExecuteStreamQueryResult) GetQueryPlan 

func (m *ExecuteStreamQueryResult) GetQueryPlan() string

func (*ExecuteStreamQueryResult) GetResult 

func (m *ExecuteStreamQueryResult) GetResult() isExecuteStreamQueryResult_Result

func (*ExecuteStreamQueryResult) GetResultSet 

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

func (*ExecuteStreamQueryResult) ProtoMessage 

func (*ExecuteStreamQueryResult) ProtoMessage()

func (*ExecuteStreamQueryResult) Reset 

func (m *ExecuteStreamQueryResult) Reset()

func (*ExecuteStreamQueryResult) String 

func (m *ExecuteStreamQueryResult) String() string

func (*ExecuteStreamQueryResult) XXX_DiscardUnknown 

func (m *ExecuteStreamQueryResult) XXX_DiscardUnknown()

func (*ExecuteStreamQueryResult) XXX_Marshal 

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

func (*ExecuteStreamQueryResult) XXX_Merge 

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

func (*ExecuteStreamQueryResult) XXX_OneofWrappers 

func (*ExecuteStreamQueryResult) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExecuteStreamQueryResult) XXX_Size 

func (m *ExecuteStreamQueryResult) XXX_Size() int

func (*ExecuteStreamQueryResult) XXX_Unmarshal 

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

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 ExecuteStreamQueryResult_ResultSet 

type ExecuteStreamQueryResult_ResultSet struct {
	ResultSet *Ydb.ResultSet `protobuf:"bytes,1,opt,name=result_set,json=resultSet,proto3,oneof"`
}

type StreamQueryProgress 

type StreamQueryProgress struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamQueryProgress) Descriptor 

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

func (*StreamQueryProgress) ProtoMessage 

func (*StreamQueryProgress) ProtoMessage()

func (*StreamQueryProgress) Reset 

func (m *StreamQueryProgress) Reset()

func (*StreamQueryProgress) String 

func (m *StreamQueryProgress) String() string

func (*StreamQueryProgress) XXX_DiscardUnknown 

func (m *StreamQueryProgress) XXX_DiscardUnknown()

func (*StreamQueryProgress) XXX_Marshal 

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

func (*StreamQueryProgress) XXX_Merge 

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

func (*StreamQueryProgress) XXX_Size 

func (m *StreamQueryProgress) XXX_Size() int

func (*StreamQueryProgress) XXX_Unmarshal 

func (m *StreamQueryProgress) 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.