package Ydb_Import
import "github.com/ydb-platform/ydb-go-genproto/protos/Ydb_Import"
Index ¶
- Variables
- type ImportDataRequest
- func (*ImportDataRequest) Descriptor() ([]byte, []int)
- func (x *ImportDataRequest) GetData() []byte
- func (m *ImportDataRequest) GetFormat() isImportDataRequest_Format
- func (x *ImportDataRequest) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *ImportDataRequest) GetPath() string
- func (x *ImportDataRequest) GetYdbDump() *YdbDumpFormat
- func (*ImportDataRequest) ProtoMessage()
- func (x *ImportDataRequest) ProtoReflect() protoreflect.Message
- func (x *ImportDataRequest) Reset()
- func (x *ImportDataRequest) String() string
- type ImportDataRequest_YdbDump
- type ImportDataResponse
- func (*ImportDataResponse) Descriptor() ([]byte, []int)
- func (x *ImportDataResponse) GetOperation() *Ydb_Operations.Operation
- func (*ImportDataResponse) ProtoMessage()
- func (x *ImportDataResponse) ProtoReflect() protoreflect.Message
- func (x *ImportDataResponse) Reset()
- func (x *ImportDataResponse) String() string
- type ImportDataResult
- func (*ImportDataResult) Descriptor() ([]byte, []int)
- func (*ImportDataResult) ProtoMessage()
- func (x *ImportDataResult) ProtoReflect() protoreflect.Message
- func (x *ImportDataResult) Reset()
- func (x *ImportDataResult) String() string
- type ImportFromS3Metadata
- func (*ImportFromS3Metadata) Descriptor() ([]byte, []int)
- func (x *ImportFromS3Metadata) GetItemsProgress() []*ImportItemProgress
- func (x *ImportFromS3Metadata) GetProgress() ImportProgress_Progress
- func (x *ImportFromS3Metadata) GetSettings() *ImportFromS3Settings
- func (*ImportFromS3Metadata) ProtoMessage()
- func (x *ImportFromS3Metadata) ProtoReflect() protoreflect.Message
- func (x *ImportFromS3Metadata) Reset()
- func (x *ImportFromS3Metadata) String() string
- type ImportFromS3Request
- func (*ImportFromS3Request) Descriptor() ([]byte, []int)
- func (x *ImportFromS3Request) GetOperationParams() *Ydb_Operations.OperationParams
- func (x *ImportFromS3Request) GetSettings() *ImportFromS3Settings
- func (*ImportFromS3Request) ProtoMessage()
- func (x *ImportFromS3Request) ProtoReflect() protoreflect.Message
- func (x *ImportFromS3Request) Reset()
- func (x *ImportFromS3Request) String() string
- type ImportFromS3Response
- func (*ImportFromS3Response) Descriptor() ([]byte, []int)
- func (x *ImportFromS3Response) GetOperation() *Ydb_Operations.Operation
- func (*ImportFromS3Response) ProtoMessage()
- func (x *ImportFromS3Response) ProtoReflect() protoreflect.Message
- func (x *ImportFromS3Response) Reset()
- func (x *ImportFromS3Response) String() string
- type ImportFromS3Result
- func (*ImportFromS3Result) Descriptor() ([]byte, []int)
- func (*ImportFromS3Result) ProtoMessage()
- func (x *ImportFromS3Result) ProtoReflect() protoreflect.Message
- func (x *ImportFromS3Result) Reset()
- func (x *ImportFromS3Result) String() string
- type ImportFromS3Settings
- func (*ImportFromS3Settings) Descriptor() ([]byte, []int)
- func (x *ImportFromS3Settings) GetAccessKey() string
- func (x *ImportFromS3Settings) GetBucket() string
- func (x *ImportFromS3Settings) GetDescription() string
- func (x *ImportFromS3Settings) GetDisableVirtualAddressing() bool
- func (x *ImportFromS3Settings) GetEndpoint() string
- func (x *ImportFromS3Settings) GetItems() []*ImportFromS3Settings_Item
- func (x *ImportFromS3Settings) GetNumberOfRetries() uint32
- func (x *ImportFromS3Settings) GetRegion() string
- func (x *ImportFromS3Settings) GetScheme() ImportFromS3Settings_Scheme
- func (x *ImportFromS3Settings) GetSecretKey() string
- func (*ImportFromS3Settings) ProtoMessage()
- func (x *ImportFromS3Settings) ProtoReflect() protoreflect.Message
- func (x *ImportFromS3Settings) Reset()
- func (x *ImportFromS3Settings) String() string
- type ImportFromS3Settings_Item
- func (*ImportFromS3Settings_Item) Descriptor() ([]byte, []int)
- func (x *ImportFromS3Settings_Item) GetDestinationPath() string
- func (x *ImportFromS3Settings_Item) GetSourcePrefix() string
- func (*ImportFromS3Settings_Item) ProtoMessage()
- func (x *ImportFromS3Settings_Item) ProtoReflect() protoreflect.Message
- func (x *ImportFromS3Settings_Item) Reset()
- func (x *ImportFromS3Settings_Item) String() string
- type ImportFromS3Settings_Scheme
- func (ImportFromS3Settings_Scheme) Descriptor() protoreflect.EnumDescriptor
- func (x ImportFromS3Settings_Scheme) Enum() *ImportFromS3Settings_Scheme
- func (ImportFromS3Settings_Scheme) EnumDescriptor() ([]byte, []int)
- func (x ImportFromS3Settings_Scheme) Number() protoreflect.EnumNumber
- func (x ImportFromS3Settings_Scheme) String() string
- func (ImportFromS3Settings_Scheme) Type() protoreflect.EnumType
- type ImportItemProgress
- func (*ImportItemProgress) Descriptor() ([]byte, []int)
- func (x *ImportItemProgress) GetEndTime() *timestamppb.Timestamp
- func (x *ImportItemProgress) GetPartsCompleted() uint32
- func (x *ImportItemProgress) GetPartsTotal() uint32
- func (x *ImportItemProgress) GetStartTime() *timestamppb.Timestamp
- func (*ImportItemProgress) ProtoMessage()
- func (x *ImportItemProgress) ProtoReflect() protoreflect.Message
- func (x *ImportItemProgress) Reset()
- func (x *ImportItemProgress) String() string
- type ImportProgress
- func (*ImportProgress) Descriptor() ([]byte, []int)
- func (*ImportProgress) ProtoMessage()
- func (x *ImportProgress) ProtoReflect() protoreflect.Message
- func (x *ImportProgress) Reset()
- func (x *ImportProgress) String() string
- type ImportProgress_Progress
- func (ImportProgress_Progress) Descriptor() protoreflect.EnumDescriptor
- func (x ImportProgress_Progress) Enum() *ImportProgress_Progress
- func (ImportProgress_Progress) EnumDescriptor() ([]byte, []int)
- func (x ImportProgress_Progress) Number() protoreflect.EnumNumber
- func (x ImportProgress_Progress) String() string
- func (ImportProgress_Progress) Type() protoreflect.EnumType
- type YdbDumpFormat
Variables ¶
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.
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.
var File_protos_ydb_import_proto protoreflect.FileDescriptor
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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"`
// disables virtual hosting style buckets aws s3 feature
// it changes the way bucket appended to url. e.g. https//bucket_name.example.com/ vs https://example.com/bucket_name
// details: https://docs.aws.amazon.com/AmazonS3/latest/userguide/VirtualHosting.html
// it is especially useful for custom s3 implementations
DisableVirtualAddressing bool `protobuf:"varint,10,opt,name=disable_virtual_addressing,json=disableVirtualAddressing,proto3" json:"disable_virtual_addressing,omitempty"`
// contains filtered or unexported fields
}
/ S3
func (*ImportFromS3Settings) Descriptor ¶
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) GetDisableVirtualAddressing ¶
func (x *ImportFromS3Settings) GetDisableVirtualAddressing() bool
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
- Version
- v0.0.0-20241112172322-ea1f63298f77 (latest)
- Published
- Nov 12, 2024
- Platform
- linux/amd64
- Imports
- 7 packages
- Last checked
- 1 year ago –
Tools for package owners.