backup

package
v0.0.0-...-0e3ce33 Latest Latest
Warning

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

Go to latest
Published: Nov 26, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthBackup = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBackup   = fmt.Errorf("proto: integer overflow")
)
View Source
var CompressionType_name = map[int32]string{
	0: "UNKNOWN",
	1: "LZ4",
	2: "SNAPPY",
	3: "ZSTD",
}
View Source
var CompressionType_value = map[string]int32{
	"UNKNOWN": 0,
	"LZ4":     1,
	"SNAPPY":  2,
	"ZSTD":    3,
}

Functions

func RegisterBackupServer

func RegisterBackupServer(s *grpc.Server, srv BackupServer)

Types

type BackupClient

type BackupClient interface {
	Backup(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (Backup_BackupClient, error)
}

func NewBackupClient

func NewBackupClient(cc *grpc.ClientConn) BackupClient

type BackupMeta

type BackupMeta struct {
	// ID and version of backuped cluster.
	ClusterId      uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ClusterVersion string `protobuf:"bytes,2,opt,name=cluster_version,json=clusterVersion,proto3" json:"cluster_version,omitempty"`
	// A set of files that compose a backup.
	Files []*File `protobuf:"bytes,4,rep,name=files" json:"files,omitempty"`
	// A pair of timestamp specifies a time range of a backup.
	// For full backup, the start_version equals to the end_version,
	// it means point in time.
	// For incremental backup, the time range is specified as
	// (start_version, end_version].
	StartVersion uint64 `protobuf:"varint,5,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	EndVersion   uint64 `protobuf:"varint,6,opt,name=end_version,json=endVersion,proto3" json:"end_version,omitempty"`
	// Additional metadata describes database and table info.
	Schemas []*Schema `protobuf:"bytes,7,rep,name=schemas" json:"schemas,omitempty"`
	// If in raw kv mode, `start_versions`, `end_versions` and `schemas` will be ignored, and the
	// backup data's range is represented by raw_ranges.
	IsRawKv   bool        `protobuf:"varint,8,opt,name=is_raw_kv,json=isRawKv,proto3" json:"is_raw_kv,omitempty"`
	RawRanges []*RawRange `protobuf:"bytes,9,rep,name=raw_ranges,json=rawRanges" json:"raw_ranges,omitempty"`
	// In incremental backup, DDLs which are completed in (lastBackupTS, backupTS] will be stored here.
	Ddls                 []byte   `protobuf:"bytes,10,opt,name=ddls,proto3" json:"ddls,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The message save the metadata of a backup.

func (*BackupMeta) Descriptor

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

func (*BackupMeta) GetClusterId

func (m *BackupMeta) GetClusterId() uint64

func (*BackupMeta) GetClusterVersion

func (m *BackupMeta) GetClusterVersion() string

func (*BackupMeta) GetDdls

func (m *BackupMeta) GetDdls() []byte

func (*BackupMeta) GetEndVersion

func (m *BackupMeta) GetEndVersion() uint64

func (*BackupMeta) GetFiles

func (m *BackupMeta) GetFiles() []*File

func (*BackupMeta) GetIsRawKv

func (m *BackupMeta) GetIsRawKv() bool

func (*BackupMeta) GetRawRanges

func (m *BackupMeta) GetRawRanges() []*RawRange

func (*BackupMeta) GetSchemas

func (m *BackupMeta) GetSchemas() []*Schema

func (*BackupMeta) GetStartVersion

func (m *BackupMeta) GetStartVersion() uint64

func (*BackupMeta) Marshal

func (m *BackupMeta) Marshal() (dAtA []byte, err error)

func (*BackupMeta) MarshalTo

func (m *BackupMeta) MarshalTo(dAtA []byte) (int, error)

func (*BackupMeta) ProtoMessage

func (*BackupMeta) ProtoMessage()

func (*BackupMeta) Reset

func (m *BackupMeta) Reset()

func (*BackupMeta) Size

func (m *BackupMeta) Size() (n int)

func (*BackupMeta) String

func (m *BackupMeta) String() string

func (*BackupMeta) Unmarshal

func (m *BackupMeta) Unmarshal(dAtA []byte) error

func (*BackupMeta) XXX_DiscardUnknown

func (m *BackupMeta) XXX_DiscardUnknown()

func (*BackupMeta) XXX_Marshal

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

func (*BackupMeta) XXX_Merge

func (dst *BackupMeta) XXX_Merge(src proto.Message)

func (*BackupMeta) XXX_Size

func (m *BackupMeta) XXX_Size() int

func (*BackupMeta) XXX_Unmarshal

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

type BackupRequest

type BackupRequest struct {
	ClusterId    uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	StartKey     []byte `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey       []byte `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	StartVersion uint64 `protobuf:"varint,4,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	EndVersion   uint64 `protobuf:"varint,5,opt,name=end_version,json=endVersion,proto3" json:"end_version,omitempty"`
	// The I/O rate limit for backup request.
	RateLimit uint64 `protobuf:"varint,7,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit,omitempty"`
	// The concurrency for executing the backup request in every tikv node.
	Concurrency    uint32          `protobuf:"varint,8,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	StorageBackend *StorageBackend `protobuf:"bytes,9,opt,name=storage_backend,json=storageBackend" json:"storage_backend,omitempty"`
	// If raw kv mode is enabled, `start_version` and `end_version` will be ignored, and `cf`
	// specifies which cf to backup.
	IsRawKv bool   `protobuf:"varint,10,opt,name=is_raw_kv,json=isRawKv,proto3" json:"is_raw_kv,omitempty"`
	Cf      string `protobuf:"bytes,11,opt,name=cf,proto3" json:"cf,omitempty"`
	// algorithm used for compress sst files
	CompressionType CompressionType `` /* 136-byte string literal not displayed */
	// sst compression level, some algorithms support negative compression levels
	CompressionLevel     int32    `protobuf:"varint,13,opt,name=compression_level,json=compressionLevel,proto3" json:"compression_level,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupRequest) Descriptor

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

func (*BackupRequest) GetCf

func (m *BackupRequest) GetCf() string

func (*BackupRequest) GetClusterId

func (m *BackupRequest) GetClusterId() uint64

func (*BackupRequest) GetCompressionLevel

func (m *BackupRequest) GetCompressionLevel() int32

func (*BackupRequest) GetCompressionType

func (m *BackupRequest) GetCompressionType() CompressionType

func (*BackupRequest) GetConcurrency

func (m *BackupRequest) GetConcurrency() uint32

func (*BackupRequest) GetEndKey

func (m *BackupRequest) GetEndKey() []byte

func (*BackupRequest) GetEndVersion

func (m *BackupRequest) GetEndVersion() uint64

func (*BackupRequest) GetIsRawKv

func (m *BackupRequest) GetIsRawKv() bool

func (*BackupRequest) GetRateLimit

func (m *BackupRequest) GetRateLimit() uint64

func (*BackupRequest) GetStartKey

func (m *BackupRequest) GetStartKey() []byte

func (*BackupRequest) GetStartVersion

func (m *BackupRequest) GetStartVersion() uint64

func (*BackupRequest) GetStorageBackend

func (m *BackupRequest) GetStorageBackend() *StorageBackend

func (*BackupRequest) Marshal

func (m *BackupRequest) Marshal() (dAtA []byte, err error)

func (*BackupRequest) MarshalTo

func (m *BackupRequest) MarshalTo(dAtA []byte) (int, error)

func (*BackupRequest) ProtoMessage

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) Reset

func (m *BackupRequest) Reset()

func (*BackupRequest) Size

func (m *BackupRequest) Size() (n int)

func (*BackupRequest) String

func (m *BackupRequest) String() string

func (*BackupRequest) Unmarshal

func (m *BackupRequest) Unmarshal(dAtA []byte) error

func (*BackupRequest) XXX_DiscardUnknown

func (m *BackupRequest) XXX_DiscardUnknown()

func (*BackupRequest) XXX_Marshal

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

func (*BackupRequest) XXX_Merge

func (dst *BackupRequest) XXX_Merge(src proto.Message)

func (*BackupRequest) XXX_Size

func (m *BackupRequest) XXX_Size() int

func (*BackupRequest) XXX_Unmarshal

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

type BackupResponse

type BackupResponse struct {
	Error                *Error   `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	StartKey             []byte   `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey               []byte   `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	Files                []*File  `protobuf:"bytes,4,rep,name=files" json:"files,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupResponse) Descriptor

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

func (*BackupResponse) GetEndKey

func (m *BackupResponse) GetEndKey() []byte

func (*BackupResponse) GetError

func (m *BackupResponse) GetError() *Error

func (*BackupResponse) GetFiles

func (m *BackupResponse) GetFiles() []*File

func (*BackupResponse) GetStartKey

func (m *BackupResponse) GetStartKey() []byte

func (*BackupResponse) Marshal

func (m *BackupResponse) Marshal() (dAtA []byte, err error)

func (*BackupResponse) MarshalTo

func (m *BackupResponse) MarshalTo(dAtA []byte) (int, error)

func (*BackupResponse) ProtoMessage

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) Reset

func (m *BackupResponse) Reset()

func (*BackupResponse) Size

func (m *BackupResponse) Size() (n int)

func (*BackupResponse) String

func (m *BackupResponse) String() string

func (*BackupResponse) Unmarshal

func (m *BackupResponse) Unmarshal(dAtA []byte) error

func (*BackupResponse) XXX_DiscardUnknown

func (m *BackupResponse) XXX_DiscardUnknown()

func (*BackupResponse) XXX_Marshal

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

func (*BackupResponse) XXX_Merge

func (dst *BackupResponse) XXX_Merge(src proto.Message)

func (*BackupResponse) XXX_Size

func (m *BackupResponse) XXX_Size() int

func (*BackupResponse) XXX_Unmarshal

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

type BackupServer

type BackupServer interface {
	Backup(*BackupRequest, Backup_BackupServer) error
}

type Backup_BackupClient

type Backup_BackupClient interface {
	Recv() (*BackupResponse, error)
	grpc.ClientStream
}

type Backup_BackupServer

type Backup_BackupServer interface {
	Send(*BackupResponse) error
	grpc.ServerStream
}

type ClusterIDError

type ClusterIDError struct {
	Current              uint64   `protobuf:"varint,1,opt,name=current,proto3" json:"current,omitempty"`
	Request              uint64   `protobuf:"varint,2,opt,name=request,proto3" json:"request,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterIDError) Descriptor

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

func (*ClusterIDError) GetCurrent

func (m *ClusterIDError) GetCurrent() uint64

func (*ClusterIDError) GetRequest

func (m *ClusterIDError) GetRequest() uint64

func (*ClusterIDError) Marshal

func (m *ClusterIDError) Marshal() (dAtA []byte, err error)

func (*ClusterIDError) MarshalTo

func (m *ClusterIDError) MarshalTo(dAtA []byte) (int, error)

func (*ClusterIDError) ProtoMessage

func (*ClusterIDError) ProtoMessage()

func (*ClusterIDError) Reset

func (m *ClusterIDError) Reset()

func (*ClusterIDError) Size

func (m *ClusterIDError) Size() (n int)

func (*ClusterIDError) String

func (m *ClusterIDError) String() string

func (*ClusterIDError) Unmarshal

func (m *ClusterIDError) Unmarshal(dAtA []byte) error

func (*ClusterIDError) XXX_DiscardUnknown

func (m *ClusterIDError) XXX_DiscardUnknown()

func (*ClusterIDError) XXX_Marshal

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

func (*ClusterIDError) XXX_Merge

func (dst *ClusterIDError) XXX_Merge(src proto.Message)

func (*ClusterIDError) XXX_Size

func (m *ClusterIDError) XXX_Size() int

func (*ClusterIDError) XXX_Unmarshal

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

type CompressionType

type CompressionType int32

sst files compression algorithm

const (
	CompressionType_UNKNOWN CompressionType = 0
	CompressionType_LZ4     CompressionType = 1
	CompressionType_SNAPPY  CompressionType = 2
	CompressionType_ZSTD    CompressionType = 3
)

func (CompressionType) EnumDescriptor

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

func (CompressionType) String

func (x CompressionType) String() string

type Error

type Error struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// Types that are valid to be assigned to Detail:
	//	*Error_ClusterIdError
	//	*Error_KvError
	//	*Error_RegionError
	Detail               isError_Detail `protobuf_oneof:"detail"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Error) Descriptor

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

func (*Error) GetClusterIdError

func (m *Error) GetClusterIdError() *ClusterIDError

func (*Error) GetDetail

func (m *Error) GetDetail() isError_Detail

func (*Error) GetKvError

func (m *Error) GetKvError() *kvrpcpb.KeyError

func (*Error) GetMsg

func (m *Error) GetMsg() string

func (*Error) GetRegionError

func (m *Error) GetRegionError() *errorpb.Error

func (*Error) Marshal

func (m *Error) Marshal() (dAtA []byte, err error)

func (*Error) MarshalTo

func (m *Error) MarshalTo(dAtA []byte) (int, error)

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) Size

func (m *Error) Size() (n int)

func (*Error) String

func (m *Error) String() string

func (*Error) Unmarshal

func (m *Error) Unmarshal(dAtA []byte) error

func (*Error) XXX_DiscardUnknown

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal

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

func (*Error) XXX_Merge

func (dst *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_OneofFuncs

func (*Error) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Error) XXX_Size

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal

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

type Error_ClusterIdError

type Error_ClusterIdError struct {
	ClusterIdError *ClusterIDError `protobuf:"bytes,3,opt,name=cluster_id_error,json=clusterIdError,oneof"`
}

func (*Error_ClusterIdError) MarshalTo

func (m *Error_ClusterIdError) MarshalTo(dAtA []byte) (int, error)

func (*Error_ClusterIdError) Size

func (m *Error_ClusterIdError) Size() (n int)

type Error_KvError

type Error_KvError struct {
	KvError *kvrpcpb.KeyError `protobuf:"bytes,4,opt,name=kv_error,json=kvError,oneof"`
}

func (*Error_KvError) MarshalTo

func (m *Error_KvError) MarshalTo(dAtA []byte) (int, error)

func (*Error_KvError) Size

func (m *Error_KvError) Size() (n int)

type Error_RegionError

type Error_RegionError struct {
	RegionError *errorpb.Error `protobuf:"bytes,5,opt,name=region_error,json=regionError,oneof"`
}

func (*Error_RegionError) MarshalTo

func (m *Error_RegionError) MarshalTo(dAtA []byte) (int, error)

func (*Error_RegionError) Size

func (m *Error_RegionError) Size() (n int)

type File

type File struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Sha256               []byte   `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	StartKey             []byte   `protobuf:"bytes,3,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey               []byte   `protobuf:"bytes,4,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	StartVersion         uint64   `protobuf:"varint,5,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	EndVersion           uint64   `protobuf:"varint,6,opt,name=end_version,json=endVersion,proto3" json:"end_version,omitempty"`
	Crc64Xor             uint64   `protobuf:"varint,7,opt,name=crc64xor,proto3" json:"crc64xor,omitempty"`
	TotalKvs             uint64   `protobuf:"varint,8,opt,name=total_kvs,json=totalKvs,proto3" json:"total_kvs,omitempty"`
	TotalBytes           uint64   `protobuf:"varint,9,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
	Cf                   string   `protobuf:"bytes,10,opt,name=cf,proto3" json:"cf,omitempty"`
	Size_                uint64   `protobuf:"varint,11,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*File) Descriptor

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

func (*File) GetCf

func (m *File) GetCf() string

func (*File) GetCrc64Xor

func (m *File) GetCrc64Xor() uint64

func (*File) GetEndKey

func (m *File) GetEndKey() []byte

func (*File) GetEndVersion

func (m *File) GetEndVersion() uint64

func (*File) GetName

func (m *File) GetName() string

func (*File) GetSha256

func (m *File) GetSha256() []byte

func (*File) GetSize_

func (m *File) GetSize_() uint64

func (*File) GetStartKey

func (m *File) GetStartKey() []byte

func (*File) GetStartVersion

func (m *File) GetStartVersion() uint64

func (*File) GetTotalBytes

func (m *File) GetTotalBytes() uint64

func (*File) GetTotalKvs

func (m *File) GetTotalKvs() uint64

func (*File) Marshal

func (m *File) Marshal() (dAtA []byte, err error)

func (*File) MarshalTo

func (m *File) MarshalTo(dAtA []byte) (int, error)

func (*File) ProtoMessage

func (*File) ProtoMessage()

func (*File) Reset

func (m *File) Reset()

func (*File) Size

func (m *File) Size() (n int)

func (*File) String

func (m *File) String() string

func (*File) Unmarshal

func (m *File) Unmarshal(dAtA []byte) error

func (*File) XXX_DiscardUnknown

func (m *File) XXX_DiscardUnknown()

func (*File) XXX_Marshal

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

func (*File) XXX_Merge

func (dst *File) XXX_Merge(src proto.Message)

func (*File) XXX_Size

func (m *File) XXX_Size() int

func (*File) XXX_Unmarshal

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

type GCS

type GCS struct {
	Endpoint     string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Bucket       string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Prefix       string `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	StorageClass string `protobuf:"bytes,4,opt,name=storage_class,json=storageClass,proto3" json:"storage_class,omitempty"`
	// If not empty, applies a predefined set of access controls.
	// See https://cloud.google.com/storage/docs/access-control/lists#predefined-acl
	// for valid values.
	PredefinedAcl string `protobuf:"bytes,5,opt,name=predefined_acl,json=predefinedAcl,proto3" json:"predefined_acl,omitempty"`
	// Service Account Credentials JSON blob
	// You can get one from https://console.cloud.google.com/apis/credentials, and
	// copy the content, set it as string here.
	CredentialsBlob      string   `protobuf:"bytes,6,opt,name=credentials_blob,json=credentialsBlob,proto3" json:"credentials_blob,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GCS storage backend saves files into google cloud storage.

func (*GCS) Descriptor

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

func (*GCS) GetBucket

func (m *GCS) GetBucket() string

func (*GCS) GetCredentialsBlob

func (m *GCS) GetCredentialsBlob() string

func (*GCS) GetEndpoint

func (m *GCS) GetEndpoint() string

func (*GCS) GetPredefinedAcl

func (m *GCS) GetPredefinedAcl() string

func (*GCS) GetPrefix

func (m *GCS) GetPrefix() string

func (*GCS) GetStorageClass

func (m *GCS) GetStorageClass() string

func (*GCS) Marshal

func (m *GCS) Marshal() (dAtA []byte, err error)

func (*GCS) MarshalTo

func (m *GCS) MarshalTo(dAtA []byte) (int, error)

func (*GCS) ProtoMessage

func (*GCS) ProtoMessage()

func (*GCS) Reset

func (m *GCS) Reset()

func (*GCS) Size

func (m *GCS) Size() (n int)

func (*GCS) String

func (m *GCS) String() string

func (*GCS) Unmarshal

func (m *GCS) Unmarshal(dAtA []byte) error

func (*GCS) XXX_DiscardUnknown

func (m *GCS) XXX_DiscardUnknown()

func (*GCS) XXX_Marshal

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

func (*GCS) XXX_Merge

func (dst *GCS) XXX_Merge(src proto.Message)

func (*GCS) XXX_Size

func (m *GCS) XXX_Size() int

func (*GCS) XXX_Unmarshal

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

type Local

type Local struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Local storage backend saves files into local disk

func (*Local) Descriptor

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

func (*Local) GetPath

func (m *Local) GetPath() string

func (*Local) Marshal

func (m *Local) Marshal() (dAtA []byte, err error)

func (*Local) MarshalTo

func (m *Local) MarshalTo(dAtA []byte) (int, error)

func (*Local) ProtoMessage

func (*Local) ProtoMessage()

func (*Local) Reset

func (m *Local) Reset()

func (*Local) Size

func (m *Local) Size() (n int)

func (*Local) String

func (m *Local) String() string

func (*Local) Unmarshal

func (m *Local) Unmarshal(dAtA []byte) error

func (*Local) XXX_DiscardUnknown

func (m *Local) XXX_DiscardUnknown()

func (*Local) XXX_Marshal

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

func (*Local) XXX_Merge

func (dst *Local) XXX_Merge(src proto.Message)

func (*Local) XXX_Size

func (m *Local) XXX_Size() int

func (*Local) XXX_Unmarshal

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

type Noop

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

Noop storage backend saves files into void.

func (*Noop) Descriptor

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

func (*Noop) Marshal

func (m *Noop) Marshal() (dAtA []byte, err error)

func (*Noop) MarshalTo

func (m *Noop) MarshalTo(dAtA []byte) (int, error)

func (*Noop) ProtoMessage

func (*Noop) ProtoMessage()

func (*Noop) Reset

func (m *Noop) Reset()

func (*Noop) Size

func (m *Noop) Size() (n int)

func (*Noop) String

func (m *Noop) String() string

func (*Noop) Unmarshal

func (m *Noop) Unmarshal(dAtA []byte) error

func (*Noop) XXX_DiscardUnknown

func (m *Noop) XXX_DiscardUnknown()

func (*Noop) XXX_Marshal

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

func (*Noop) XXX_Merge

func (dst *Noop) XXX_Merge(src proto.Message)

func (*Noop) XXX_Size

func (m *Noop) XXX_Size() int

func (*Noop) XXX_Unmarshal

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

type RawRange

type RawRange struct {
	StartKey             []byte   `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey               []byte   `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	Cf                   string   `protobuf:"bytes,3,opt,name=cf,proto3" json:"cf,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawRange) Descriptor

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

func (*RawRange) GetCf

func (m *RawRange) GetCf() string

func (*RawRange) GetEndKey

func (m *RawRange) GetEndKey() []byte

func (*RawRange) GetStartKey

func (m *RawRange) GetStartKey() []byte

func (*RawRange) Marshal

func (m *RawRange) Marshal() (dAtA []byte, err error)

func (*RawRange) MarshalTo

func (m *RawRange) MarshalTo(dAtA []byte) (int, error)

func (*RawRange) ProtoMessage

func (*RawRange) ProtoMessage()

func (*RawRange) Reset

func (m *RawRange) Reset()

func (*RawRange) Size

func (m *RawRange) Size() (n int)

func (*RawRange) String

func (m *RawRange) String() string

func (*RawRange) Unmarshal

func (m *RawRange) Unmarshal(dAtA []byte) error

func (*RawRange) XXX_DiscardUnknown

func (m *RawRange) XXX_DiscardUnknown()

func (*RawRange) XXX_Marshal

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

func (*RawRange) XXX_Merge

func (dst *RawRange) XXX_Merge(src proto.Message)

func (*RawRange) XXX_Size

func (m *RawRange) XXX_Size() int

func (*RawRange) XXX_Unmarshal

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

type S3

type S3 struct {
	Endpoint     string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Region       string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	Bucket       string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Prefix       string `protobuf:"bytes,4,opt,name=prefix,proto3" json:"prefix,omitempty"`
	StorageClass string `protobuf:"bytes,5,opt,name=storage_class,json=storageClass,proto3" json:"storage_class,omitempty"`
	// server side encryption
	Sse                  string   `protobuf:"bytes,6,opt,name=sse,proto3" json:"sse,omitempty"`
	Acl                  string   `protobuf:"bytes,7,opt,name=acl,proto3" json:"acl,omitempty"`
	AccessKey            string   `protobuf:"bytes,8,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretAccessKey      string   `protobuf:"bytes,9,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"`
	ForcePathStyle       bool     `protobuf:"varint,10,opt,name=force_path_style,json=forcePathStyle,proto3" json:"force_path_style,omitempty"`
	SseKmsKeyId          string   `protobuf:"bytes,11,opt,name=sse_kms_key_id,json=sseKmsKeyId,proto3" json:"sse_kms_key_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

S3 storage backend saves files into S3 compatible storages For non-aws providers, endpoint must be provided

func (*S3) Descriptor

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

func (*S3) GetAccessKey

func (m *S3) GetAccessKey() string

func (*S3) GetAcl

func (m *S3) GetAcl() string

func (*S3) GetBucket

func (m *S3) GetBucket() string

func (*S3) GetEndpoint

func (m *S3) GetEndpoint() string

func (*S3) GetForcePathStyle

func (m *S3) GetForcePathStyle() bool

func (*S3) GetPrefix

func (m *S3) GetPrefix() string

func (*S3) GetRegion

func (m *S3) GetRegion() string

func (*S3) GetSecretAccessKey

func (m *S3) GetSecretAccessKey() string

func (*S3) GetSse

func (m *S3) GetSse() string

func (*S3) GetSseKmsKeyId

func (m *S3) GetSseKmsKeyId() string

func (*S3) GetStorageClass

func (m *S3) GetStorageClass() string

func (*S3) Marshal

func (m *S3) Marshal() (dAtA []byte, err error)

func (*S3) MarshalTo

func (m *S3) MarshalTo(dAtA []byte) (int, error)

func (*S3) ProtoMessage

func (*S3) ProtoMessage()

func (*S3) Reset

func (m *S3) Reset()

func (*S3) Size

func (m *S3) Size() (n int)

func (*S3) String

func (m *S3) String() string

func (*S3) Unmarshal

func (m *S3) Unmarshal(dAtA []byte) error

func (*S3) XXX_DiscardUnknown

func (m *S3) XXX_DiscardUnknown()

func (*S3) XXX_Marshal

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

func (*S3) XXX_Merge

func (dst *S3) XXX_Merge(src proto.Message)

func (*S3) XXX_Size

func (m *S3) XXX_Size() int

func (*S3) XXX_Unmarshal

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

type Schema

type Schema struct {
	Db                   []byte   `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"`
	Table                []byte   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Crc64Xor             uint64   `protobuf:"varint,3,opt,name=crc64xor,proto3" json:"crc64xor,omitempty"`
	TotalKvs             uint64   `protobuf:"varint,4,opt,name=total_kvs,json=totalKvs,proto3" json:"total_kvs,omitempty"`
	TotalBytes           uint64   `protobuf:"varint,5,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
	TiflashReplicas      uint32   `protobuf:"varint,6,opt,name=tiflash_replicas,json=tiflashReplicas,proto3" json:"tiflash_replicas,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Schema) Descriptor

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

func (*Schema) GetCrc64Xor

func (m *Schema) GetCrc64Xor() uint64

func (*Schema) GetDb

func (m *Schema) GetDb() []byte

func (*Schema) GetTable

func (m *Schema) GetTable() []byte

func (*Schema) GetTiflashReplicas

func (m *Schema) GetTiflashReplicas() uint32

func (*Schema) GetTotalBytes

func (m *Schema) GetTotalBytes() uint64

func (*Schema) GetTotalKvs

func (m *Schema) GetTotalKvs() uint64

func (*Schema) Marshal

func (m *Schema) Marshal() (dAtA []byte, err error)

func (*Schema) MarshalTo

func (m *Schema) MarshalTo(dAtA []byte) (int, error)

func (*Schema) ProtoMessage

func (*Schema) ProtoMessage()

func (*Schema) Reset

func (m *Schema) Reset()

func (*Schema) Size

func (m *Schema) Size() (n int)

func (*Schema) String

func (m *Schema) String() string

func (*Schema) Unmarshal

func (m *Schema) Unmarshal(dAtA []byte) error

func (*Schema) XXX_DiscardUnknown

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal

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

func (*Schema) XXX_Merge

func (dst *Schema) XXX_Merge(src proto.Message)

func (*Schema) XXX_Size

func (m *Schema) XXX_Size() int

func (*Schema) XXX_Unmarshal

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

type StorageBackend

type StorageBackend struct {
	// Types that are valid to be assigned to Backend:
	//	*StorageBackend_Noop
	//	*StorageBackend_Local
	//	*StorageBackend_S3
	//	*StorageBackend_Gcs
	Backend              isStorageBackend_Backend `protobuf_oneof:"backend"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*StorageBackend) Descriptor

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

func (*StorageBackend) GetBackend

func (m *StorageBackend) GetBackend() isStorageBackend_Backend

func (*StorageBackend) GetGcs

func (m *StorageBackend) GetGcs() *GCS

func (*StorageBackend) GetLocal

func (m *StorageBackend) GetLocal() *Local

func (*StorageBackend) GetNoop

func (m *StorageBackend) GetNoop() *Noop

func (*StorageBackend) GetS3

func (m *StorageBackend) GetS3() *S3

func (*StorageBackend) Marshal

func (m *StorageBackend) Marshal() (dAtA []byte, err error)

func (*StorageBackend) MarshalTo

func (m *StorageBackend) MarshalTo(dAtA []byte) (int, error)

func (*StorageBackend) ProtoMessage

func (*StorageBackend) ProtoMessage()

func (*StorageBackend) Reset

func (m *StorageBackend) Reset()

func (*StorageBackend) Size

func (m *StorageBackend) Size() (n int)

func (*StorageBackend) String

func (m *StorageBackend) String() string

func (*StorageBackend) Unmarshal

func (m *StorageBackend) Unmarshal(dAtA []byte) error

func (*StorageBackend) XXX_DiscardUnknown

func (m *StorageBackend) XXX_DiscardUnknown()

func (*StorageBackend) XXX_Marshal

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

func (*StorageBackend) XXX_Merge

func (dst *StorageBackend) XXX_Merge(src proto.Message)

func (*StorageBackend) XXX_OneofFuncs

func (*StorageBackend) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*StorageBackend) XXX_Size

func (m *StorageBackend) XXX_Size() int

func (*StorageBackend) XXX_Unmarshal

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

type StorageBackend_Gcs

type StorageBackend_Gcs struct {
	Gcs *GCS `protobuf:"bytes,4,opt,name=gcs,oneof"`
}

func (*StorageBackend_Gcs) MarshalTo

func (m *StorageBackend_Gcs) MarshalTo(dAtA []byte) (int, error)

func (*StorageBackend_Gcs) Size

func (m *StorageBackend_Gcs) Size() (n int)

type StorageBackend_Local

type StorageBackend_Local struct {
	Local *Local `protobuf:"bytes,2,opt,name=local,oneof"`
}

func (*StorageBackend_Local) MarshalTo

func (m *StorageBackend_Local) MarshalTo(dAtA []byte) (int, error)

func (*StorageBackend_Local) Size

func (m *StorageBackend_Local) Size() (n int)

type StorageBackend_Noop

type StorageBackend_Noop struct {
	Noop *Noop `protobuf:"bytes,1,opt,name=noop,oneof"`
}

func (*StorageBackend_Noop) MarshalTo

func (m *StorageBackend_Noop) MarshalTo(dAtA []byte) (int, error)

func (*StorageBackend_Noop) Size

func (m *StorageBackend_Noop) Size() (n int)

type StorageBackend_S3

type StorageBackend_S3 struct {
	S3 *S3 `protobuf:"bytes,3,opt,name=s3,oneof"`
}

func (*StorageBackend_S3) MarshalTo

func (m *StorageBackend_S3) MarshalTo(dAtA []byte) (int, error)

func (*StorageBackend_S3) Size

func (m *StorageBackend_S3) Size() (n int)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL