Ydb_Import

package
v0.0.0-...-8dd88c8 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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",
	}
	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,
	}
)

Enum value maps for ImportProgress_Progress.

View Source 
var (
	ImportFromS3Settings_Scheme_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "HTTP",
		2: "HTTPS",
	}
	ImportFromS3Settings_Scheme_value = map[string]int32{
		"UNSPECIFIED": 0,
		"HTTP":        1,
		"HTTPS":       2,
	}
)

Enum value maps for ImportFromS3Settings_Scheme.

View Source 
var File_protos_ydb_import_proto protoreflect.FileDescriptor

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 assignable to Format:
	//
	//	*ImportDataRequest_YdbDump
	Format isImportDataRequest_Format `protobuf_oneof:"format"`
	// contains filtered or unexported fields
}

func (*ImportDataRequest) Descriptor deprecated 

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

Deprecated: Use ImportDataRequest.ProtoReflect.Descriptor instead.

func (*ImportDataRequest) GetData 

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

func (*ImportDataRequest) GetFormat 

func (m *ImportDataRequest) GetFormat() isImportDataRequest_Format

func (*ImportDataRequest) GetOperationParams 

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

func (*ImportDataRequest) GetPath 

func (x *ImportDataRequest) GetPath() string

func (*ImportDataRequest) GetYdbDump 

func (x *ImportDataRequest) GetYdbDump() *YdbDumpFormat

func (*ImportDataRequest) ProtoMessage 

func (*ImportDataRequest) ProtoMessage()

func (*ImportDataRequest) ProtoReflect 

func (x *ImportDataRequest) ProtoReflect() protoreflect.Message

func (*ImportDataRequest) Reset 

func (x *ImportDataRequest) Reset()

func (*ImportDataRequest) String 

func (x *ImportDataRequest) String() string

type ImportDataRequest_YdbDump 

type ImportDataRequest_YdbDump struct {
	// Result of `ydb tools dump`
	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"`
	// contains filtered or unexported fields
}

func (*ImportDataResponse) Descriptor deprecated 

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

Deprecated: Use ImportDataResponse.ProtoReflect.Descriptor instead.

func (*ImportDataResponse) GetOperation 

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

func (*ImportDataResponse) ProtoMessage 

func (*ImportDataResponse) ProtoMessage()

func (*ImportDataResponse) ProtoReflect 

func (x *ImportDataResponse) ProtoReflect() protoreflect.Message

func (*ImportDataResponse) Reset 

func (x *ImportDataResponse) Reset()

func (*ImportDataResponse) String 

func (x *ImportDataResponse) String() string

type ImportDataResult 

type ImportDataResult struct {
	// contains filtered or unexported fields
}

func (*ImportDataResult) Descriptor deprecated 

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

Deprecated: Use ImportDataResult.ProtoReflect.Descriptor instead.

func (*ImportDataResult) ProtoMessage 

func (*ImportDataResult) ProtoMessage()

func (*ImportDataResult) ProtoReflect 

func (x *ImportDataResult) ProtoReflect() protoreflect.Message

func (*ImportDataResult) Reset 

func (x *ImportDataResult) Reset()

func (*ImportDataResult) String 

func (x *ImportDataResult) String() string

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"`
	// contains filtered or unexported fields
}

func (*ImportFromS3Metadata) Descriptor deprecated 

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

Deprecated: Use ImportFromS3Metadata.ProtoReflect.Descriptor instead.

func (*ImportFromS3Metadata) GetItemsProgress 

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

func (*ImportFromS3Metadata) GetProgress 

func (x *ImportFromS3Metadata) GetProgress() ImportProgress_Progress

func (*ImportFromS3Metadata) GetSettings 

func (x *ImportFromS3Metadata) GetSettings() *ImportFromS3Settings

func (*ImportFromS3Metadata) ProtoMessage 

func (*ImportFromS3Metadata) ProtoMessage()

func (*ImportFromS3Metadata) ProtoReflect 

func (x *ImportFromS3Metadata) ProtoReflect() protoreflect.Message

func (*ImportFromS3Metadata) Reset 

func (x *ImportFromS3Metadata) Reset()

func (*ImportFromS3Metadata) String 

func (x *ImportFromS3Metadata) String() string

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"`
	// contains filtered or unexported fields
}

func (*ImportFromS3Request) Descriptor deprecated 

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

Deprecated: Use ImportFromS3Request.ProtoReflect.Descriptor instead.

func (*ImportFromS3Request) GetOperationParams 

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

func (*ImportFromS3Request) GetSettings 

func (x *ImportFromS3Request) GetSettings() *ImportFromS3Settings

func (*ImportFromS3Request) ProtoMessage 

func (*ImportFromS3Request) ProtoMessage()

func (*ImportFromS3Request) ProtoReflect 

func (x *ImportFromS3Request) ProtoReflect() protoreflect.Message

func (*ImportFromS3Request) Reset 

func (x *ImportFromS3Request) Reset()

func (*ImportFromS3Request) String 

func (x *ImportFromS3Request) String() string

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"`
	// contains filtered or unexported fields
}

func (*ImportFromS3Response) Descriptor deprecated 

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

Deprecated: Use ImportFromS3Response.ProtoReflect.Descriptor instead.

func (*ImportFromS3Response) GetOperation 

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

func (*ImportFromS3Response) ProtoMessage 

func (*ImportFromS3Response) ProtoMessage()

func (*ImportFromS3Response) ProtoReflect 

func (x *ImportFromS3Response) ProtoReflect() protoreflect.Message

func (*ImportFromS3Response) Reset 

func (x *ImportFromS3Response) Reset()

func (*ImportFromS3Response) String 

func (x *ImportFromS3Response) String() string

type ImportFromS3Result 

type ImportFromS3Result struct {
	// contains filtered or unexported fields
}

func (*ImportFromS3Result) Descriptor deprecated 

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

Deprecated: Use ImportFromS3Result.ProtoReflect.Descriptor instead.

func (*ImportFromS3Result) ProtoMessage 

func (*ImportFromS3Result) ProtoMessage()

func (*ImportFromS3Result) ProtoReflect 

func (x *ImportFromS3Result) ProtoReflect() protoreflect.Message

func (*ImportFromS3Result) Reset 

func (x *ImportFromS3Result) Reset()

func (*ImportFromS3Result) String 

func (x *ImportFromS3Result) String() string

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"` // HTTPS if not specified
	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"`
	// Region to use in requests
	Region string `protobuf:"bytes,9,opt,name=region,proto3" json:"region,omitempty"`
	// contains filtered or unexported fields
}

/ S3

func (*ImportFromS3Settings) Descriptor deprecated 

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

Deprecated: Use ImportFromS3Settings.ProtoReflect.Descriptor instead.

func (*ImportFromS3Settings) GetAccessKey 

func (x *ImportFromS3Settings) GetAccessKey() string

func (*ImportFromS3Settings) GetBucket 

func (x *ImportFromS3Settings) GetBucket() string

func (*ImportFromS3Settings) GetDescription 

func (x *ImportFromS3Settings) GetDescription() string

func (*ImportFromS3Settings) GetEndpoint 

func (x *ImportFromS3Settings) GetEndpoint() string

func (*ImportFromS3Settings) GetItems 

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

func (*ImportFromS3Settings) GetNumberOfRetries 

func (x *ImportFromS3Settings) GetNumberOfRetries() uint32

func (*ImportFromS3Settings) GetRegion 

func (x *ImportFromS3Settings) GetRegion() string

func (*ImportFromS3Settings) GetScheme 

func (x *ImportFromS3Settings) GetScheme() ImportFromS3Settings_Scheme

func (*ImportFromS3Settings) GetSecretKey 

func (x *ImportFromS3Settings) GetSecretKey() string

func (*ImportFromS3Settings) ProtoMessage 

func (*ImportFromS3Settings) ProtoMessage()

func (*ImportFromS3Settings) ProtoReflect 

func (x *ImportFromS3Settings) ProtoReflect() protoreflect.Message

func (*ImportFromS3Settings) Reset 

func (x *ImportFromS3Settings) Reset()

func (*ImportFromS3Settings) String 

func (x *ImportFromS3Settings) String() string

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"`
	// contains filtered or unexported fields
}

func (*ImportFromS3Settings_Item) Descriptor deprecated 

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

Deprecated: Use ImportFromS3Settings_Item.ProtoReflect.Descriptor instead.

func (*ImportFromS3Settings_Item) GetDestinationPath 

func (x *ImportFromS3Settings_Item) GetDestinationPath() string

func (*ImportFromS3Settings_Item) GetSourcePrefix 

func (x *ImportFromS3Settings_Item) GetSourcePrefix() string

func (*ImportFromS3Settings_Item) ProtoMessage 

func (*ImportFromS3Settings_Item) ProtoMessage()

func (*ImportFromS3Settings_Item) ProtoReflect 

func (x *ImportFromS3Settings_Item) ProtoReflect() protoreflect.Message

func (*ImportFromS3Settings_Item) Reset 

func (x *ImportFromS3Settings_Item) Reset()

func (*ImportFromS3Settings_Item) String 

func (x *ImportFromS3Settings_Item) String() string

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

func (ImportFromS3Settings_Scheme) Descriptor() protoreflect.EnumDescriptor

func (ImportFromS3Settings_Scheme) Enum 

func (x ImportFromS3Settings_Scheme) Enum() *ImportFromS3Settings_Scheme

func (ImportFromS3Settings_Scheme) EnumDescriptor deprecated 

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

Deprecated: Use ImportFromS3Settings_Scheme.Descriptor instead.

func (ImportFromS3Settings_Scheme) Number 

func (x ImportFromS3Settings_Scheme) Number() protoreflect.EnumNumber

func (ImportFromS3Settings_Scheme) String 

func (x ImportFromS3Settings_Scheme) String() string

func (ImportFromS3Settings_Scheme) Type 

func (ImportFromS3Settings_Scheme) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*ImportItemProgress) Descriptor deprecated 

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

Deprecated: Use ImportItemProgress.ProtoReflect.Descriptor instead.

func (*ImportItemProgress) GetEndTime 

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

func (*ImportItemProgress) GetPartsCompleted 

func (x *ImportItemProgress) GetPartsCompleted() uint32

func (*ImportItemProgress) GetPartsTotal 

func (x *ImportItemProgress) GetPartsTotal() uint32

func (*ImportItemProgress) GetStartTime 

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

func (*ImportItemProgress) ProtoMessage 

func (*ImportItemProgress) ProtoMessage()

func (*ImportItemProgress) ProtoReflect 

func (x *ImportItemProgress) ProtoReflect() protoreflect.Message

func (*ImportItemProgress) Reset 

func (x *ImportItemProgress) Reset()

func (*ImportItemProgress) String 

func (x *ImportItemProgress) String() string

type ImportProgress 

type ImportProgress struct {
	// contains filtered or unexported fields
}

/ Common

func (*ImportProgress) Descriptor deprecated 

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

Deprecated: Use ImportProgress.ProtoReflect.Descriptor instead.

func (*ImportProgress) ProtoMessage 

func (*ImportProgress) ProtoMessage()

func (*ImportProgress) ProtoReflect 

func (x *ImportProgress) ProtoReflect() protoreflect.Message

func (*ImportProgress) Reset 

func (x *ImportProgress) Reset()

func (*ImportProgress) String 

func (x *ImportProgress) String() string

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

func (ImportProgress_Progress) Descriptor() protoreflect.EnumDescriptor

func (ImportProgress_Progress) Enum 

func (x ImportProgress_Progress) Enum() *ImportProgress_Progress

func (ImportProgress_Progress) EnumDescriptor deprecated 

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

Deprecated: Use ImportProgress_Progress.Descriptor instead.

func (ImportProgress_Progress) Number 

func (x ImportProgress_Progress) Number() protoreflect.EnumNumber

func (ImportProgress_Progress) String 

func (x ImportProgress_Progress) String() string

func (ImportProgress_Progress) Type 

func (ImportProgress_Progress) Type() protoreflect.EnumType

type YdbDumpFormat 

type YdbDumpFormat struct {
	Columns []string `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

/ Data

func (*YdbDumpFormat) Descriptor deprecated 

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

Deprecated: Use YdbDumpFormat.ProtoReflect.Descriptor instead.

func (*YdbDumpFormat) GetColumns 

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

func (*YdbDumpFormat) ProtoMessage 

func (*YdbDumpFormat) ProtoMessage()

func (*YdbDumpFormat) ProtoReflect 

func (x *YdbDumpFormat) ProtoReflect() protoreflect.Message

func (*YdbDumpFormat) Reset 

func (x *YdbDumpFormat) Reset()

func (*YdbDumpFormat) String 

func (x *YdbDumpFormat) String() string

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.