Ydb_Experimental

package
v1.5.2 Latest Latest
Warning

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

 Go to latest Published: Aug 3, 2021 License: Apache-2.0 Imports: 6 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 GetDiskSpaceUsageRequest 

type GetDiskSpaceUsageRequest struct {
	OperationParams      *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	Database             string                          `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*GetDiskSpaceUsageRequest) Descriptor 

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

func (*GetDiskSpaceUsageRequest) GetDatabase 

func (m *GetDiskSpaceUsageRequest) GetDatabase() string

func (*GetDiskSpaceUsageRequest) GetOperationParams 

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

func (*GetDiskSpaceUsageRequest) ProtoMessage 

func (*GetDiskSpaceUsageRequest) ProtoMessage()

func (*GetDiskSpaceUsageRequest) Reset 

func (m *GetDiskSpaceUsageRequest) Reset()

func (*GetDiskSpaceUsageRequest) SetOperationParams 

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

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

func (*GetDiskSpaceUsageRequest) String 

func (m *GetDiskSpaceUsageRequest) String() string

func (*GetDiskSpaceUsageRequest) XXX_DiscardUnknown 

func (m *GetDiskSpaceUsageRequest) XXX_DiscardUnknown()

func (*GetDiskSpaceUsageRequest) XXX_Marshal 

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

func (*GetDiskSpaceUsageRequest) XXX_Merge 

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

func (*GetDiskSpaceUsageRequest) XXX_Size 

func (m *GetDiskSpaceUsageRequest) XXX_Size() int

func (*GetDiskSpaceUsageRequest) XXX_Unmarshal 

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

type GetDiskSpaceUsageResponse 

type GetDiskSpaceUsageResponse 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 (*GetDiskSpaceUsageResponse) Descriptor 

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

func (*GetDiskSpaceUsageResponse) GetOperation 

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

func (*GetDiskSpaceUsageResponse) ProtoMessage 

func (*GetDiskSpaceUsageResponse) ProtoMessage()

func (*GetDiskSpaceUsageResponse) Reset 

func (m *GetDiskSpaceUsageResponse) Reset()

func (*GetDiskSpaceUsageResponse) String 

func (m *GetDiskSpaceUsageResponse) String() string

func (*GetDiskSpaceUsageResponse) XXX_DiscardUnknown 

func (m *GetDiskSpaceUsageResponse) XXX_DiscardUnknown()

func (*GetDiskSpaceUsageResponse) XXX_Marshal 

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

func (*GetDiskSpaceUsageResponse) XXX_Merge 

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

func (*GetDiskSpaceUsageResponse) XXX_Size 

func (m *GetDiskSpaceUsageResponse) XXX_Size() int

func (*GetDiskSpaceUsageResponse) XXX_Unmarshal 

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

type GetDiskSpaceUsageResult 

type GetDiskSpaceUsageResult struct {
	CloudId    string `protobuf:"bytes,1,opt,name=cloud_id,json=cloudId,proto3" json:"cloud_id,omitempty"`
	FolderId   string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	DatabaseId string `protobuf:"bytes,3,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
	// in bytes
	TotalSize            uint64   `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	DataSize             uint64   `protobuf:"varint,5,opt,name=data_size,json=dataSize,proto3" json:"data_size,omitempty"`
	IndexSize            uint64   `protobuf:"varint,6,opt,name=index_size,json=indexSize,proto3" json:"index_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDiskSpaceUsageResult) Descriptor 

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

func (*GetDiskSpaceUsageResult) GetCloudId 

func (m *GetDiskSpaceUsageResult) GetCloudId() string

func (*GetDiskSpaceUsageResult) GetDataSize 

func (m *GetDiskSpaceUsageResult) GetDataSize() uint64

func (*GetDiskSpaceUsageResult) GetDatabaseId 

func (m *GetDiskSpaceUsageResult) GetDatabaseId() string

func (*GetDiskSpaceUsageResult) GetFolderId 

func (m *GetDiskSpaceUsageResult) GetFolderId() string

func (*GetDiskSpaceUsageResult) GetIndexSize 

func (m *GetDiskSpaceUsageResult) GetIndexSize() uint64

func (*GetDiskSpaceUsageResult) GetTotalSize 

func (m *GetDiskSpaceUsageResult) GetTotalSize() uint64

func (*GetDiskSpaceUsageResult) ProtoMessage 

func (*GetDiskSpaceUsageResult) ProtoMessage()

func (*GetDiskSpaceUsageResult) Reset 

func (m *GetDiskSpaceUsageResult) Reset()

func (*GetDiskSpaceUsageResult) String 

func (m *GetDiskSpaceUsageResult) String() string

func (*GetDiskSpaceUsageResult) XXX_DiscardUnknown 

func (m *GetDiskSpaceUsageResult) XXX_DiscardUnknown()

func (*GetDiskSpaceUsageResult) XXX_Marshal 

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

func (*GetDiskSpaceUsageResult) XXX_Merge 

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

func (*GetDiskSpaceUsageResult) XXX_Size 

func (m *GetDiskSpaceUsageResult) XXX_Size() int

func (*GetDiskSpaceUsageResult) XXX_Unmarshal 

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

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

type UploadRowsRequest 

type UploadRowsRequest struct {
	Table                string                          `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Rows                 *Ydb.TypedValue                 `protobuf:"bytes,2,opt,name=rows,proto3" json:"rows,omitempty"`
	OperationParams      *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*UploadRowsRequest) Descriptor 

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

func (*UploadRowsRequest) GetOperationParams 

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

func (*UploadRowsRequest) GetRows 

func (m *UploadRowsRequest) GetRows() *Ydb.TypedValue

func (*UploadRowsRequest) GetTable 

func (m *UploadRowsRequest) GetTable() string

func (*UploadRowsRequest) ProtoMessage 

func (*UploadRowsRequest) ProtoMessage()

func (*UploadRowsRequest) Reset 

func (m *UploadRowsRequest) Reset()

func (*UploadRowsRequest) SetOperationParams 

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

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

func (*UploadRowsRequest) String 

func (m *UploadRowsRequest) String() string

func (*UploadRowsRequest) XXX_DiscardUnknown 

func (m *UploadRowsRequest) XXX_DiscardUnknown()

func (*UploadRowsRequest) XXX_Marshal 

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

func (*UploadRowsRequest) XXX_Merge 

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

func (*UploadRowsRequest) XXX_Size 

func (m *UploadRowsRequest) XXX_Size() int

func (*UploadRowsRequest) XXX_Unmarshal 

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

type UploadRowsResponse 

type UploadRowsResponse 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 (*UploadRowsResponse) Descriptor 

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

func (*UploadRowsResponse) GetOperation 

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

func (*UploadRowsResponse) ProtoMessage 

func (*UploadRowsResponse) ProtoMessage()

func (*UploadRowsResponse) Reset 

func (m *UploadRowsResponse) Reset()

func (*UploadRowsResponse) String 

func (m *UploadRowsResponse) String() string

func (*UploadRowsResponse) XXX_DiscardUnknown 

func (m *UploadRowsResponse) XXX_DiscardUnknown()

func (*UploadRowsResponse) XXX_Marshal 

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

func (*UploadRowsResponse) XXX_Merge 

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

func (*UploadRowsResponse) XXX_Size 

func (m *UploadRowsResponse) XXX_Size() int

func (*UploadRowsResponse) XXX_Unmarshal 

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

type UploadRowsResult 

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

func (*UploadRowsResult) Descriptor 

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

func (*UploadRowsResult) ProtoMessage 

func (*UploadRowsResult) ProtoMessage()

func (*UploadRowsResult) Reset 

func (m *UploadRowsResult) Reset()

func (*UploadRowsResult) String 

func (m *UploadRowsResult) String() string

func (*UploadRowsResult) XXX_DiscardUnknown 

func (m *UploadRowsResult) XXX_DiscardUnknown()

func (*UploadRowsResult) XXX_Marshal 

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

func (*UploadRowsResult) XXX_Merge 

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

func (*UploadRowsResult) XXX_Size 

func (m *UploadRowsResult) XXX_Size() int

func (*UploadRowsResult) XXX_Unmarshal 

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