Ydb_Import

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: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ImportFromS3Settings_Scheme_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "HTTP",
	2: "HTTPS",
}
View Source 
var ImportFromS3Settings_Scheme_value = map[string]int32{
	"UNSPECIFIED": 0,
	"HTTP":        1,
	"HTTPS":       2,
}
View Source 
var ImportProgress_Progress_name = map[int32]string{
	0: "PROGRESS_UNSPECIFIED",
	1: "PROGRESS_PREPARING",
	2: "PROGRESS_TRANSFER_DATA",
	3: "PROGRESS_BUILD_INDEXES",
	4: "PROGRESS_DONE",
	5: "PROGRESS_CANCELLATION",
	6: "PROGRESS_CANCELLED",
}
View Source 
var ImportProgress_Progress_value = map[string]int32{
	"PROGRESS_UNSPECIFIED":   0,
	"PROGRESS_PREPARING":     1,
	"PROGRESS_TRANSFER_DATA": 2,
	"PROGRESS_BUILD_INDEXES": 3,
	"PROGRESS_DONE":          4,
	"PROGRESS_CANCELLATION":  5,
	"PROGRESS_CANCELLED":     6,
}

Functions

This section is empty.

Types

type ImportDataRequest 

type ImportDataRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Full path to table
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Data serialized in the selected format. Restrictions:
	// - sorted by primary key;
	// - all keys must be from the same partition;
	// - table has no global secondary indexes;
	// - size of serialized data is limited to 8 MB.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// Types that are valid to be assigned to Format:
	//	*ImportDataRequest_YdbDump
	Format               isImportDataRequest_Format `protobuf_oneof:"format"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ImportDataRequest) Descriptor 

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

func (*ImportDataRequest) GetData 

func (m *ImportDataRequest) GetData() []byte

func (*ImportDataRequest) GetFormat 

func (m *ImportDataRequest) GetFormat() isImportDataRequest_Format

func (*ImportDataRequest) GetOperationParams 

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

func (*ImportDataRequest) GetPath 

func (m *ImportDataRequest) GetPath() string

func (*ImportDataRequest) GetYdbDump 

func (m *ImportDataRequest) GetYdbDump() *YdbDumpFormat

func (*ImportDataRequest) ProtoMessage 

func (*ImportDataRequest) ProtoMessage()

func (*ImportDataRequest) Reset 

func (m *ImportDataRequest) Reset()

func (*ImportDataRequest) SetOperationParams 

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

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

func (*ImportDataRequest) String 

func (m *ImportDataRequest) String() string

func (*ImportDataRequest) XXX_DiscardUnknown 

func (m *ImportDataRequest) XXX_DiscardUnknown()

func (*ImportDataRequest) XXX_Marshal 

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

func (*ImportDataRequest) XXX_Merge 

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

func (*ImportDataRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ImportDataRequest) XXX_Size 

func (m *ImportDataRequest) XXX_Size() int

func (*ImportDataRequest) XXX_Unmarshal 

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

type ImportDataRequest_YdbDump 

type ImportDataRequest_YdbDump struct {
	YdbDump *YdbDumpFormat `protobuf:"bytes,4,opt,name=ydb_dump,json=ydbDump,proto3,oneof"`
}

type ImportDataResponse 

type ImportDataResponse struct {
	// operation.result = ImportDataResult
	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 (*ImportDataResponse) Descriptor 

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

func (*ImportDataResponse) GetOperation 

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

func (*ImportDataResponse) ProtoMessage 

func (*ImportDataResponse) ProtoMessage()

func (*ImportDataResponse) Reset 

func (m *ImportDataResponse) Reset()

func (*ImportDataResponse) String 

func (m *ImportDataResponse) String() string

func (*ImportDataResponse) XXX_DiscardUnknown 

func (m *ImportDataResponse) XXX_DiscardUnknown()

func (*ImportDataResponse) XXX_Marshal 

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

func (*ImportDataResponse) XXX_Merge 

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

func (*ImportDataResponse) XXX_Size 

func (m *ImportDataResponse) XXX_Size() int

func (*ImportDataResponse) XXX_Unmarshal 

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

type ImportDataResult 

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

func (*ImportDataResult) Descriptor 

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

func (*ImportDataResult) ProtoMessage 

func (*ImportDataResult) ProtoMessage()

func (*ImportDataResult) Reset 

func (m *ImportDataResult) Reset()

func (*ImportDataResult) String 

func (m *ImportDataResult) String() string

func (*ImportDataResult) XXX_DiscardUnknown 

func (m *ImportDataResult) XXX_DiscardUnknown()

func (*ImportDataResult) XXX_Marshal 

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

func (*ImportDataResult) XXX_Merge 

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

func (*ImportDataResult) XXX_Size 

func (m *ImportDataResult) XXX_Size() int

func (*ImportDataResult) XXX_Unmarshal 

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

type ImportFromS3Metadata 

type ImportFromS3Metadata struct {
	Settings             *ImportFromS3Settings   `protobuf:"bytes,1,opt,name=settings,proto3" json:"settings,omitempty"`
	Progress             ImportProgress_Progress `protobuf:"varint,2,opt,name=progress,proto3,enum=Ydb.Import.ImportProgress_Progress" json:"progress,omitempty"`
	ItemsProgress        []*ImportItemProgress   `protobuf:"bytes,3,rep,name=items_progress,json=itemsProgress,proto3" json:"items_progress,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ImportFromS3Metadata) Descriptor 

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

func (*ImportFromS3Metadata) GetItemsProgress 

func (m *ImportFromS3Metadata) GetItemsProgress() []*ImportItemProgress

func (*ImportFromS3Metadata) GetProgress 

func (m *ImportFromS3Metadata) GetProgress() ImportProgress_Progress

func (*ImportFromS3Metadata) GetSettings 

func (m *ImportFromS3Metadata) GetSettings() *ImportFromS3Settings

func (*ImportFromS3Metadata) ProtoMessage 

func (*ImportFromS3Metadata) ProtoMessage()

func (*ImportFromS3Metadata) Reset 

func (m *ImportFromS3Metadata) Reset()

func (*ImportFromS3Metadata) String 

func (m *ImportFromS3Metadata) String() string

func (*ImportFromS3Metadata) XXX_DiscardUnknown 

func (m *ImportFromS3Metadata) XXX_DiscardUnknown()

func (*ImportFromS3Metadata) XXX_Marshal 

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

func (*ImportFromS3Metadata) XXX_Merge 

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

func (*ImportFromS3Metadata) XXX_Size 

func (m *ImportFromS3Metadata) XXX_Size() int

func (*ImportFromS3Metadata) XXX_Unmarshal 

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

type ImportFromS3Request 

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

func (*ImportFromS3Request) Descriptor 

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

func (*ImportFromS3Request) GetOperationParams 

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

func (*ImportFromS3Request) GetSettings 

func (m *ImportFromS3Request) GetSettings() *ImportFromS3Settings

func (*ImportFromS3Request) ProtoMessage 

func (*ImportFromS3Request) ProtoMessage()

func (*ImportFromS3Request) Reset 

func (m *ImportFromS3Request) Reset()

func (*ImportFromS3Request) SetOperationParams 

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

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

func (*ImportFromS3Request) String 

func (m *ImportFromS3Request) String() string

func (*ImportFromS3Request) XXX_DiscardUnknown 

func (m *ImportFromS3Request) XXX_DiscardUnknown()

func (*ImportFromS3Request) XXX_Marshal 

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

func (*ImportFromS3Request) XXX_Merge 

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

func (*ImportFromS3Request) XXX_Size 

func (m *ImportFromS3Request) XXX_Size() int

func (*ImportFromS3Request) XXX_Unmarshal 

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

type ImportFromS3Response 

type ImportFromS3Response struct {
	// operation.result = ImportFromS3Result
	// operation.metadata = ImportFromS3Metadata
	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 (*ImportFromS3Response) Descriptor 

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

func (*ImportFromS3Response) GetOperation 

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

func (*ImportFromS3Response) ProtoMessage 

func (*ImportFromS3Response) ProtoMessage()

func (*ImportFromS3Response) Reset 

func (m *ImportFromS3Response) Reset()

func (*ImportFromS3Response) String 

func (m *ImportFromS3Response) String() string

func (*ImportFromS3Response) XXX_DiscardUnknown 

func (m *ImportFromS3Response) XXX_DiscardUnknown()

func (*ImportFromS3Response) XXX_Marshal 

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

func (*ImportFromS3Response) XXX_Merge 

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

func (*ImportFromS3Response) XXX_Size 

func (m *ImportFromS3Response) XXX_Size() int

func (*ImportFromS3Response) XXX_Unmarshal 

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

type ImportFromS3Result 

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

func (*ImportFromS3Result) Descriptor 

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

func (*ImportFromS3Result) ProtoMessage 

func (*ImportFromS3Result) ProtoMessage()

func (*ImportFromS3Result) Reset 

func (m *ImportFromS3Result) Reset()

func (*ImportFromS3Result) String 

func (m *ImportFromS3Result) String() string

func (*ImportFromS3Result) XXX_DiscardUnknown 

func (m *ImportFromS3Result) XXX_DiscardUnknown()

func (*ImportFromS3Result) XXX_Marshal 

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

func (*ImportFromS3Result) XXX_Merge 

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

func (*ImportFromS3Result) XXX_Size 

func (m *ImportFromS3Result) XXX_Size() int

func (*ImportFromS3Result) XXX_Unmarshal 

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

type ImportFromS3Settings 

type ImportFromS3Settings struct {
	Endpoint             string                       `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Scheme               ImportFromS3Settings_Scheme  `protobuf:"varint,2,opt,name=scheme,proto3,enum=Ydb.Import.ImportFromS3Settings_Scheme" json:"scheme,omitempty"`
	Bucket               string                       `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	AccessKey            string                       `protobuf:"bytes,4,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey            string                       `protobuf:"bytes,5,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	Items                []*ImportFromS3Settings_Item `protobuf:"bytes,6,rep,name=items,proto3" json:"items,omitempty"`
	Description          string                       `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	NumberOfRetries      uint32                       `protobuf:"varint,8,opt,name=number_of_retries,json=numberOfRetries,proto3" json:"number_of_retries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

/ S3

func (*ImportFromS3Settings) Descriptor 

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

func (*ImportFromS3Settings) GetAccessKey 

func (m *ImportFromS3Settings) GetAccessKey() string

func (*ImportFromS3Settings) GetBucket 

func (m *ImportFromS3Settings) GetBucket() string

func (*ImportFromS3Settings) GetDescription 

func (m *ImportFromS3Settings) GetDescription() string

func (*ImportFromS3Settings) GetEndpoint 

func (m *ImportFromS3Settings) GetEndpoint() string

func (*ImportFromS3Settings) GetItems 

func (m *ImportFromS3Settings) GetItems() []*ImportFromS3Settings_Item

func (*ImportFromS3Settings) GetNumberOfRetries 

func (m *ImportFromS3Settings) GetNumberOfRetries() uint32

func (*ImportFromS3Settings) GetScheme 

func (m *ImportFromS3Settings) GetScheme() ImportFromS3Settings_Scheme

func (*ImportFromS3Settings) GetSecretKey 

func (m *ImportFromS3Settings) GetSecretKey() string

func (*ImportFromS3Settings) ProtoMessage 

func (*ImportFromS3Settings) ProtoMessage()

func (*ImportFromS3Settings) Reset 

func (m *ImportFromS3Settings) Reset()

func (*ImportFromS3Settings) String 

func (m *ImportFromS3Settings) String() string

func (*ImportFromS3Settings) XXX_DiscardUnknown 

func (m *ImportFromS3Settings) XXX_DiscardUnknown()

func (*ImportFromS3Settings) XXX_Marshal 

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

func (*ImportFromS3Settings) XXX_Merge 

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

func (*ImportFromS3Settings) XXX_Size 

func (m *ImportFromS3Settings) XXX_Size() int

func (*ImportFromS3Settings) XXX_Unmarshal 

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

type ImportFromS3Settings_Item 

type ImportFromS3Settings_Item struct {
	// YDB tables in S3 are stored in one or more objects (see ydb_export.proto).
	//The object name begins with 'source_prefix'.
	//This prefix is followed by:
	// '/data_PartNumber', where 'PartNumber' represents the index of the part, starting at zero;
	// '/scheme.pb' - object with information about scheme, indexes, etc.
	SourcePrefix string `protobuf:"bytes,1,opt,name=source_prefix,json=sourcePrefix,proto3" json:"source_prefix,omitempty"`
	// Database path to a table to import to.
	DestinationPath      string   `protobuf:"bytes,2,opt,name=destination_path,json=destinationPath,proto3" json:"destination_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportFromS3Settings_Item) Descriptor 

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

func (*ImportFromS3Settings_Item) GetDestinationPath 

func (m *ImportFromS3Settings_Item) GetDestinationPath() string

func (*ImportFromS3Settings_Item) GetSourcePrefix 

func (m *ImportFromS3Settings_Item) GetSourcePrefix() string

func (*ImportFromS3Settings_Item) ProtoMessage 

func (*ImportFromS3Settings_Item) ProtoMessage()

func (*ImportFromS3Settings_Item) Reset 

func (m *ImportFromS3Settings_Item) Reset()

func (*ImportFromS3Settings_Item) String 

func (m *ImportFromS3Settings_Item) String() string

func (*ImportFromS3Settings_Item) XXX_DiscardUnknown 

func (m *ImportFromS3Settings_Item) XXX_DiscardUnknown()

func (*ImportFromS3Settings_Item) XXX_Marshal 

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

func (*ImportFromS3Settings_Item) XXX_Merge 

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

func (*ImportFromS3Settings_Item) XXX_Size 

func (m *ImportFromS3Settings_Item) XXX_Size() int

func (*ImportFromS3Settings_Item) XXX_Unmarshal 

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

type ImportFromS3Settings_Scheme 

type ImportFromS3Settings_Scheme int32
const (
	ImportFromS3Settings_UNSPECIFIED ImportFromS3Settings_Scheme = 0
	ImportFromS3Settings_HTTP        ImportFromS3Settings_Scheme = 1
	ImportFromS3Settings_HTTPS       ImportFromS3Settings_Scheme = 2
)

func (ImportFromS3Settings_Scheme) EnumDescriptor 

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

func (ImportFromS3Settings_Scheme) String 

func (x ImportFromS3Settings_Scheme) String() string

type ImportItemProgress 

type ImportItemProgress struct {
	PartsTotal           uint32                 `protobuf:"varint,1,opt,name=parts_total,json=partsTotal,proto3" json:"parts_total,omitempty"`
	PartsCompleted       uint32                 `protobuf:"varint,2,opt,name=parts_completed,json=partsCompleted,proto3" json:"parts_completed,omitempty"`
	StartTime            *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime              *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ImportItemProgress) Descriptor 

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

func (*ImportItemProgress) GetEndTime 

func (m *ImportItemProgress) GetEndTime() *timestamppb.Timestamp

func (*ImportItemProgress) GetPartsCompleted 

func (m *ImportItemProgress) GetPartsCompleted() uint32

func (*ImportItemProgress) GetPartsTotal 

func (m *ImportItemProgress) GetPartsTotal() uint32

func (*ImportItemProgress) GetStartTime 

func (m *ImportItemProgress) GetStartTime() *timestamppb.Timestamp

func (*ImportItemProgress) ProtoMessage 

func (*ImportItemProgress) ProtoMessage()

func (*ImportItemProgress) Reset 

func (m *ImportItemProgress) Reset()

func (*ImportItemProgress) String 

func (m *ImportItemProgress) String() string

func (*ImportItemProgress) XXX_DiscardUnknown 

func (m *ImportItemProgress) XXX_DiscardUnknown()

func (*ImportItemProgress) XXX_Marshal 

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

func (*ImportItemProgress) XXX_Merge 

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

func (*ImportItemProgress) XXX_Size 

func (m *ImportItemProgress) XXX_Size() int

func (*ImportItemProgress) XXX_Unmarshal 

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

type ImportProgress 

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

/ Common

func (*ImportProgress) Descriptor 

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

func (*ImportProgress) ProtoMessage 

func (*ImportProgress) ProtoMessage()

func (*ImportProgress) Reset 

func (m *ImportProgress) Reset()

func (*ImportProgress) String 

func (m *ImportProgress) String() string

func (*ImportProgress) XXX_DiscardUnknown 

func (m *ImportProgress) XXX_DiscardUnknown()

func (*ImportProgress) XXX_Marshal 

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

func (*ImportProgress) XXX_Merge 

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

func (*ImportProgress) XXX_Size 

func (m *ImportProgress) XXX_Size() int

func (*ImportProgress) XXX_Unmarshal 

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

type ImportProgress_Progress 

type ImportProgress_Progress int32
const (
	ImportProgress_PROGRESS_UNSPECIFIED   ImportProgress_Progress = 0
	ImportProgress_PROGRESS_PREPARING     ImportProgress_Progress = 1
	ImportProgress_PROGRESS_TRANSFER_DATA ImportProgress_Progress = 2
	ImportProgress_PROGRESS_BUILD_INDEXES ImportProgress_Progress = 3
	ImportProgress_PROGRESS_DONE          ImportProgress_Progress = 4
	ImportProgress_PROGRESS_CANCELLATION  ImportProgress_Progress = 5
	ImportProgress_PROGRESS_CANCELLED     ImportProgress_Progress = 6
)

func (ImportProgress_Progress) EnumDescriptor 

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

func (ImportProgress_Progress) String 

func (x ImportProgress_Progress) String() string

type YdbDumpFormat 

type YdbDumpFormat struct {
	Columns              []string `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

/ Data

func (*YdbDumpFormat) Descriptor 

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

func (*YdbDumpFormat) GetColumns 

func (m *YdbDumpFormat) GetColumns() []string

func (*YdbDumpFormat) ProtoMessage 

func (*YdbDumpFormat) ProtoMessage()

func (*YdbDumpFormat) Reset 

func (m *YdbDumpFormat) Reset()

func (*YdbDumpFormat) String 

func (m *YdbDumpFormat) String() string

func (*YdbDumpFormat) XXX_DiscardUnknown 

func (m *YdbDumpFormat) XXX_DiscardUnknown()

func (*YdbDumpFormat) XXX_Marshal 

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

func (*YdbDumpFormat) XXX_Merge 

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

func (*YdbDumpFormat) XXX_Size 

func (m *YdbDumpFormat) XXX_Size() int

func (*YdbDumpFormat) XXX_Unmarshal 

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