import_sstpb

package
v0.0.0-...-84f9208 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 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)
}

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

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

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.