import_sstpb

package
v0.0.0-...-98b0a12 Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthImportSstpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowImportSstpb   = fmt.Errorf("proto: integer overflow")
)
View Source
var SwitchMode_name = map[int32]string{
	0: "Normal",
	1: "Import",
}
View Source
var SwitchMode_value = map[string]int32{
	"Normal": 0,
	"Import": 1,
}

Functions

func RegisterImportSSTServer

func RegisterImportSSTServer(s *grpc.Server, srv ImportSSTServer)

Types

type CompactRequest

type CompactRequest struct {
	// Compact files in the range and above the output level.
	// Compact all files if the range is not specified.
	// Compact all files to the bottommost level if the output level is -1.
	Range                *Range   `protobuf:"bytes,1,opt,name=range" json:"range,omitempty"`
	OutputLevel          int32    `protobuf:"varint,2,opt,name=output_level,json=outputLevel,proto3" json:"output_level,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CompactRequest) Descriptor

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

func (*CompactRequest) GetOutputLevel

func (m *CompactRequest) GetOutputLevel() int32

func (*CompactRequest) GetRange

func (m *CompactRequest) GetRange() *Range

func (*CompactRequest) Marshal

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

func (*CompactRequest) MarshalTo

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

func (*CompactRequest) ProtoMessage

func (*CompactRequest) ProtoMessage()

func (*CompactRequest) Reset

func (m *CompactRequest) Reset()

func (*CompactRequest) Size

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

func (*CompactRequest) String

func (m *CompactRequest) String() string

func (*CompactRequest) Unmarshal

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

func (*CompactRequest) XXX_DiscardUnknown

func (m *CompactRequest) XXX_DiscardUnknown()

func (*CompactRequest) XXX_Marshal

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

func (*CompactRequest) XXX_Merge

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

func (*CompactRequest) XXX_Size

func (m *CompactRequest) XXX_Size() int

func (*CompactRequest) XXX_Unmarshal

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

type CompactResponse

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

func (*CompactResponse) Descriptor

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

func (*CompactResponse) Marshal

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

func (*CompactResponse) MarshalTo

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

func (*CompactResponse) ProtoMessage

func (*CompactResponse) ProtoMessage()

func (*CompactResponse) Reset

func (m *CompactResponse) Reset()

func (*CompactResponse) Size

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

func (*CompactResponse) String

func (m *CompactResponse) String() string

func (*CompactResponse) Unmarshal

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

func (*CompactResponse) XXX_DiscardUnknown

func (m *CompactResponse) XXX_DiscardUnknown()

func (*CompactResponse) XXX_Marshal

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

func (*CompactResponse) XXX_Merge

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

func (*CompactResponse) XXX_Size

func (m *CompactResponse) XXX_Size() int

func (*CompactResponse) XXX_Unmarshal

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

type DownloadRequest

type DownloadRequest struct {
	// The SST meta used to identify the downloaded file.
	// Must be the same among all nodes in the same Raft group.
	// Note: the "crc32" and "cf_name" fields are ignored in this request,
	// and the "range" field represents keys after rewrite (as origin keys in
	// encoded representation).
	Sst SSTMeta `protobuf:"bytes,2,opt,name=sst" json:"sst"`
	// The URL of the external storage to fetch the folder containing SST file.
	Url string `protobuf:"bytes,8,opt,name=url,proto3" json:"url,omitempty"`
	// The file name of the SST file.
	Name string `protobuf:"bytes,9,opt,name=name,proto3" json:"name,omitempty"`
	// Performs a key prefix rewrite after downloading the SST file.
	// All keys in the SST will be rewritten as:
	//
	//  new_key = new_key_prefix + old_key[len(old_key_prefix)..]
	//
	// When used for TiDB, rewriting the prefix changes the table ID. Please
	// note that key-rewrite is applied on the origin keys in encoded
	// representation (the SST itself should still use data keys in encoded
	// representation).
	//
	// You need to ensure that the keys before and after rewriting are in the
	// same order, otherwise the RPC request will fail.
	RewriteRule RewriteRule `protobuf:"bytes,13,opt,name=rewrite_rule,json=rewriteRule" json:"rewrite_rule"`
	// The download speed limit (bytes/second). Set to 0 for unlimited speed.
	SpeedLimit           uint64   `protobuf:"varint,12,opt,name=speed_limit,json=speedLimit,proto3" json:"speed_limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DownloadRequest) Descriptor

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

func (*DownloadRequest) GetName

func (m *DownloadRequest) GetName() string

func (*DownloadRequest) GetRewriteRule

func (m *DownloadRequest) GetRewriteRule() RewriteRule

func (*DownloadRequest) GetSpeedLimit

func (m *DownloadRequest) GetSpeedLimit() uint64

func (*DownloadRequest) GetSst

func (m *DownloadRequest) GetSst() SSTMeta

func (*DownloadRequest) GetUrl

func (m *DownloadRequest) GetUrl() string

func (*DownloadRequest) Marshal

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

func (*DownloadRequest) MarshalTo

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

func (*DownloadRequest) ProtoMessage

func (*DownloadRequest) ProtoMessage()

func (*DownloadRequest) Reset

func (m *DownloadRequest) Reset()

func (*DownloadRequest) Size

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

func (*DownloadRequest) String

func (m *DownloadRequest) String() string

func (*DownloadRequest) Unmarshal

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

func (*DownloadRequest) XXX_DiscardUnknown

func (m *DownloadRequest) XXX_DiscardUnknown()

func (*DownloadRequest) XXX_Marshal

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

func (*DownloadRequest) XXX_Merge

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

func (*DownloadRequest) XXX_Size

func (m *DownloadRequest) XXX_Size() int

func (*DownloadRequest) XXX_Unmarshal

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

type DownloadResponse

type DownloadResponse struct {
	// The actual key range (after rewrite) of the downloaded SST. The start key
	// is inclusive and the end key is exclusive.
	Range Range `protobuf:"bytes,1,opt,name=range" json:"range"`
	// Whether the SST is empty. An empty SST is prohibited in TiKV, do not
	// ingest if this field is true.
	IsEmpty              bool     `protobuf:"varint,2,opt,name=is_empty,json=isEmpty,proto3" json:"is_empty,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DownloadResponse) Descriptor

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

func (*DownloadResponse) GetIsEmpty

func (m *DownloadResponse) GetIsEmpty() bool

func (*DownloadResponse) GetRange

func (m *DownloadResponse) GetRange() Range

func (*DownloadResponse) Marshal

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

func (*DownloadResponse) MarshalTo

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

func (*DownloadResponse) ProtoMessage

func (*DownloadResponse) ProtoMessage()

func (*DownloadResponse) Reset

func (m *DownloadResponse) Reset()

func (*DownloadResponse) Size

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

func (*DownloadResponse) String

func (m *DownloadResponse) String() string

func (*DownloadResponse) Unmarshal

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

func (*DownloadResponse) XXX_DiscardUnknown

func (m *DownloadResponse) XXX_DiscardUnknown()

func (*DownloadResponse) XXX_Marshal

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

func (*DownloadResponse) XXX_Merge

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

func (*DownloadResponse) XXX_Size

func (m *DownloadResponse) XXX_Size() int

func (*DownloadResponse) XXX_Unmarshal

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

type ImportSSTClient

type ImportSSTClient interface {
	// Switch to normal/import mode.
	SwitchMode(ctx context.Context, in *SwitchModeRequest, opts ...grpc.CallOption) (*SwitchModeResponse, error)
	// Upload an SST file to a server.
	Upload(ctx context.Context, opts ...grpc.CallOption) (ImportSST_UploadClient, error)
	// Ingest an uploaded SST file to a region.
	Ingest(ctx context.Context, in *IngestRequest, opts ...grpc.CallOption) (*IngestResponse, error)
	// Compact the specific range for better performance.
	Compact(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error)
	// Download an SST file from an external storage, and performs key-rewrite
	// after downloading.
	Download(ctx context.Context, in *DownloadRequest, opts ...grpc.CallOption) (*DownloadResponse, error)
}

func NewImportSSTClient

func NewImportSSTClient(cc *grpc.ClientConn) ImportSSTClient

type ImportSSTServer

type ImportSSTServer interface {
	// Switch to normal/import mode.
	SwitchMode(context.Context, *SwitchModeRequest) (*SwitchModeResponse, error)
	// Upload an SST file to a server.
	Upload(ImportSST_UploadServer) error
	// Ingest an uploaded SST file to a region.
	Ingest(context.Context, *IngestRequest) (*IngestResponse, error)
	// Compact the specific range for better performance.
	Compact(context.Context, *CompactRequest) (*CompactResponse, error)
	// Download an SST file from an external storage, and performs key-rewrite
	// after downloading.
	Download(context.Context, *DownloadRequest) (*DownloadResponse, error)
}

type ImportSST_UploadClient

type ImportSST_UploadClient interface {
	Send(*UploadRequest) error
	CloseAndRecv() (*UploadResponse, error)
	grpc.ClientStream
}

type ImportSST_UploadServer

type ImportSST_UploadServer interface {
	SendAndClose(*UploadResponse) error
	Recv() (*UploadRequest, error)
	grpc.ServerStream
}

type IngestRequest

type IngestRequest struct {
	Context              *kvrpcpb.Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Sst                  *SSTMeta         `protobuf:"bytes,2,opt,name=sst" json:"sst,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*IngestRequest) Descriptor

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

func (*IngestRequest) GetContext

func (m *IngestRequest) GetContext() *kvrpcpb.Context

func (*IngestRequest) GetSst

func (m *IngestRequest) GetSst() *SSTMeta

func (*IngestRequest) Marshal

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

func (*IngestRequest) MarshalTo

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

func (*IngestRequest) ProtoMessage

func (*IngestRequest) ProtoMessage()

func (*IngestRequest) Reset

func (m *IngestRequest) Reset()

func (*IngestRequest) Size

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

func (*IngestRequest) String

func (m *IngestRequest) String() string

func (*IngestRequest) Unmarshal

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

func (*IngestRequest) XXX_DiscardUnknown

func (m *IngestRequest) XXX_DiscardUnknown()

func (*IngestRequest) XXX_Marshal

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

func (*IngestRequest) XXX_Merge

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

func (*IngestRequest) XXX_Size

func (m *IngestRequest) XXX_Size() int

func (*IngestRequest) XXX_Unmarshal

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

type IngestResponse

type IngestResponse struct {
	Error                *errorpb.Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*IngestResponse) Descriptor

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

func (*IngestResponse) GetError

func (m *IngestResponse) GetError() *errorpb.Error

func (*IngestResponse) Marshal

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

func (*IngestResponse) MarshalTo

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

func (*IngestResponse) ProtoMessage

func (*IngestResponse) ProtoMessage()

func (*IngestResponse) Reset

func (m *IngestResponse) Reset()

func (*IngestResponse) Size

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

func (*IngestResponse) String

func (m *IngestResponse) String() string

func (*IngestResponse) Unmarshal

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

func (*IngestResponse) XXX_DiscardUnknown

func (m *IngestResponse) XXX_DiscardUnknown()

func (*IngestResponse) XXX_Marshal

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

func (*IngestResponse) XXX_Merge

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

func (*IngestResponse) XXX_Size

func (m *IngestResponse) XXX_Size() int

func (*IngestResponse) XXX_Unmarshal

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

type Range

type Range struct {
	Start                []byte   `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End                  []byte   `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Range) Descriptor

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

func (*Range) GetEnd

func (m *Range) GetEnd() []byte

func (*Range) GetStart

func (m *Range) GetStart() []byte

func (*Range) Marshal

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

func (*Range) MarshalTo

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

func (*Range) ProtoMessage

func (*Range) ProtoMessage()

func (*Range) Reset

func (m *Range) Reset()

func (*Range) Size

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

func (*Range) String

func (m *Range) String() string

func (*Range) Unmarshal

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

func (*Range) XXX_DiscardUnknown

func (m *Range) XXX_DiscardUnknown()

func (*Range) XXX_Marshal

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

func (*Range) XXX_Merge

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

func (*Range) XXX_Size

func (m *Range) XXX_Size() int

func (*Range) XXX_Unmarshal

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

type RewriteRule

type RewriteRule struct {
	OldKeyPrefix         []byte   `protobuf:"bytes,1,opt,name=old_key_prefix,json=oldKeyPrefix,proto3" json:"old_key_prefix,omitempty"`
	NewKeyPrefix         []byte   `protobuf:"bytes,2,opt,name=new_key_prefix,json=newKeyPrefix,proto3" json:"new_key_prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A rewrite rule is applied on the *encoded* keys (the internal storage representation).

func (*RewriteRule) Descriptor

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

func (*RewriteRule) GetNewKeyPrefix

func (m *RewriteRule) GetNewKeyPrefix() []byte

func (*RewriteRule) GetOldKeyPrefix

func (m *RewriteRule) GetOldKeyPrefix() []byte

func (*RewriteRule) Marshal

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

func (*RewriteRule) MarshalTo

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

func (*RewriteRule) ProtoMessage

func (*RewriteRule) ProtoMessage()

func (*RewriteRule) Reset

func (m *RewriteRule) Reset()

func (*RewriteRule) Size

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

func (*RewriteRule) String

func (m *RewriteRule) String() string

func (*RewriteRule) Unmarshal

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

func (*RewriteRule) XXX_DiscardUnknown

func (m *RewriteRule) XXX_DiscardUnknown()

func (*RewriteRule) XXX_Marshal

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

func (*RewriteRule) XXX_Merge

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

func (*RewriteRule) XXX_Size

func (m *RewriteRule) XXX_Size() int

func (*RewriteRule) XXX_Unmarshal

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

type SSTMeta

type SSTMeta struct {
	Uuid                 []byte              `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Range                *Range              `protobuf:"bytes,2,opt,name=range" json:"range,omitempty"`
	Crc32                uint32              `protobuf:"varint,3,opt,name=crc32,proto3" json:"crc32,omitempty"`
	Length               uint64              `protobuf:"varint,4,opt,name=length,proto3" json:"length,omitempty"`
	CfName               string              `protobuf:"bytes,5,opt,name=cf_name,json=cfName,proto3" json:"cf_name,omitempty"`
	RegionId             uint64              `protobuf:"varint,6,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	RegionEpoch          *metapb.RegionEpoch `protobuf:"bytes,7,opt,name=region_epoch,json=regionEpoch" json:"region_epoch,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SSTMeta) Descriptor

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

func (*SSTMeta) GetCfName

func (m *SSTMeta) GetCfName() string

func (*SSTMeta) GetCrc32

func (m *SSTMeta) GetCrc32() uint32

func (*SSTMeta) GetLength

func (m *SSTMeta) GetLength() uint64

func (*SSTMeta) GetRange

func (m *SSTMeta) GetRange() *Range

func (*SSTMeta) GetRegionEpoch

func (m *SSTMeta) GetRegionEpoch() *metapb.RegionEpoch

func (*SSTMeta) GetRegionId

func (m *SSTMeta) GetRegionId() uint64

func (*SSTMeta) GetUuid

func (m *SSTMeta) GetUuid() []byte

func (*SSTMeta) Marshal

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

func (*SSTMeta) MarshalTo

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

func (*SSTMeta) ProtoMessage

func (*SSTMeta) ProtoMessage()

func (*SSTMeta) Reset

func (m *SSTMeta) Reset()

func (*SSTMeta) Size

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

func (*SSTMeta) String

func (m *SSTMeta) String() string

func (*SSTMeta) Unmarshal

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

func (*SSTMeta) XXX_DiscardUnknown

func (m *SSTMeta) XXX_DiscardUnknown()

func (*SSTMeta) XXX_Marshal

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

func (*SSTMeta) XXX_Merge

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

func (*SSTMeta) XXX_Size

func (m *SSTMeta) XXX_Size() int

func (*SSTMeta) XXX_Unmarshal

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

type SwitchMode

type SwitchMode int32
const (
	SwitchMode_Normal SwitchMode = 0
	SwitchMode_Import SwitchMode = 1
)

func (SwitchMode) EnumDescriptor

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

func (SwitchMode) String

func (x SwitchMode) String() string

type SwitchModeRequest

type SwitchModeRequest struct {
	Mode                 SwitchMode `protobuf:"varint,1,opt,name=mode,proto3,enum=import_sstpb.SwitchMode" json:"mode,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SwitchModeRequest) Descriptor

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

func (*SwitchModeRequest) GetMode

func (m *SwitchModeRequest) GetMode() SwitchMode

func (*SwitchModeRequest) Marshal

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

func (*SwitchModeRequest) MarshalTo

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

func (*SwitchModeRequest) ProtoMessage

func (*SwitchModeRequest) ProtoMessage()

func (*SwitchModeRequest) Reset

func (m *SwitchModeRequest) Reset()

func (*SwitchModeRequest) Size

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

func (*SwitchModeRequest) String

func (m *SwitchModeRequest) String() string

func (*SwitchModeRequest) Unmarshal

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

func (*SwitchModeRequest) XXX_DiscardUnknown

func (m *SwitchModeRequest) XXX_DiscardUnknown()

func (*SwitchModeRequest) XXX_Marshal

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

func (*SwitchModeRequest) XXX_Merge

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

func (*SwitchModeRequest) XXX_Size

func (m *SwitchModeRequest) XXX_Size() int

func (*SwitchModeRequest) XXX_Unmarshal

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

type SwitchModeResponse

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

func (*SwitchModeResponse) Descriptor

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

func (*SwitchModeResponse) Marshal

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

func (*SwitchModeResponse) MarshalTo

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

func (*SwitchModeResponse) ProtoMessage

func (*SwitchModeResponse) ProtoMessage()

func (*SwitchModeResponse) Reset

func (m *SwitchModeResponse) Reset()

func (*SwitchModeResponse) Size

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

func (*SwitchModeResponse) String

func (m *SwitchModeResponse) String() string

func (*SwitchModeResponse) Unmarshal

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

func (*SwitchModeResponse) XXX_DiscardUnknown

func (m *SwitchModeResponse) XXX_DiscardUnknown()

func (*SwitchModeResponse) XXX_Marshal

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

func (*SwitchModeResponse) XXX_Merge

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

func (*SwitchModeResponse) XXX_Size

func (m *SwitchModeResponse) XXX_Size() int

func (*SwitchModeResponse) XXX_Unmarshal

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

type UploadRequest

type UploadRequest struct {
	// Types that are valid to be assigned to Chunk:
	//	*UploadRequest_Meta
	//	*UploadRequest_Data
	Chunk                isUploadRequest_Chunk `protobuf_oneof:"chunk"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*UploadRequest) Descriptor

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

func (*UploadRequest) GetChunk

func (m *UploadRequest) GetChunk() isUploadRequest_Chunk

func (*UploadRequest) GetData

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

func (*UploadRequest) GetMeta

func (m *UploadRequest) GetMeta() *SSTMeta

func (*UploadRequest) Marshal

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

func (*UploadRequest) MarshalTo

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

func (*UploadRequest) ProtoMessage

func (*UploadRequest) ProtoMessage()

func (*UploadRequest) Reset

func (m *UploadRequest) Reset()

func (*UploadRequest) Size

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

func (*UploadRequest) String

func (m *UploadRequest) String() string

func (*UploadRequest) Unmarshal

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

func (*UploadRequest) XXX_DiscardUnknown

func (m *UploadRequest) XXX_DiscardUnknown()

func (*UploadRequest) XXX_Marshal

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

func (*UploadRequest) XXX_Merge

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

func (*UploadRequest) XXX_OneofFuncs

func (*UploadRequest) 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 (*UploadRequest) XXX_Size

func (m *UploadRequest) XXX_Size() int

func (*UploadRequest) XXX_Unmarshal

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

type UploadRequest_Data

type UploadRequest_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

func (*UploadRequest_Data) MarshalTo

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

func (*UploadRequest_Data) Size

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

type UploadRequest_Meta

type UploadRequest_Meta struct {
	Meta *SSTMeta `protobuf:"bytes,1,opt,name=meta,oneof"`
}

func (*UploadRequest_Meta) MarshalTo

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

func (*UploadRequest_Meta) Size

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

type UploadResponse

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

func (*UploadResponse) Descriptor

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

func (*UploadResponse) Marshal

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

func (*UploadResponse) MarshalTo

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

func (*UploadResponse) ProtoMessage

func (*UploadResponse) ProtoMessage()

func (*UploadResponse) Reset

func (m *UploadResponse) Reset()

func (*UploadResponse) Size

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

func (*UploadResponse) String

func (m *UploadResponse) String() string

func (*UploadResponse) Unmarshal

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

func (*UploadResponse) XXX_DiscardUnknown

func (m *UploadResponse) XXX_DiscardUnknown()

func (*UploadResponse) XXX_Marshal

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

func (*UploadResponse) XXX_Merge

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

func (*UploadResponse) XXX_Size

func (m *UploadResponse) XXX_Size() int

func (*UploadResponse) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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