Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowDisaggregated = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthDisaggregated = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupDisaggregated = fmt.Errorf("proto: unexpected end of group") + type CancelDisaggTaskRequest struct + Meta *DisaggTaskMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CancelDisaggTaskRequest) Descriptor() ([]byte, []int) + func (*CancelDisaggTaskRequest) ProtoMessage() + func (m *CancelDisaggTaskRequest) GetMeta() *DisaggTaskMeta + func (m *CancelDisaggTaskRequest) Marshal() (dAtA []byte, err error) + func (m *CancelDisaggTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CancelDisaggTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CancelDisaggTaskRequest) Reset() + func (m *CancelDisaggTaskRequest) Size() (n int) + func (m *CancelDisaggTaskRequest) String() string + func (m *CancelDisaggTaskRequest) Unmarshal(dAtA []byte) error + func (m *CancelDisaggTaskRequest) XXX_DiscardUnknown() + func (m *CancelDisaggTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CancelDisaggTaskRequest) XXX_Merge(src proto.Message) + func (m *CancelDisaggTaskRequest) XXX_Size() int + func (m *CancelDisaggTaskRequest) XXX_Unmarshal(b []byte) error + type CancelDisaggTaskResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CancelDisaggTaskResponse) Descriptor() ([]byte, []int) + func (*CancelDisaggTaskResponse) ProtoMessage() + func (m *CancelDisaggTaskResponse) Marshal() (dAtA []byte, err error) + func (m *CancelDisaggTaskResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CancelDisaggTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CancelDisaggTaskResponse) Reset() + func (m *CancelDisaggTaskResponse) Size() (n int) + func (m *CancelDisaggTaskResponse) String() string + func (m *CancelDisaggTaskResponse) Unmarshal(dAtA []byte) error + func (m *CancelDisaggTaskResponse) XXX_DiscardUnknown() + func (m *CancelDisaggTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CancelDisaggTaskResponse) XXX_Merge(src proto.Message) + func (m *CancelDisaggTaskResponse) XXX_Size() int + func (m *CancelDisaggTaskResponse) XXX_Unmarshal(b []byte) error + type Conflict struct + Reason string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Conflict) Descriptor() ([]byte, []int) + func (*Conflict) ProtoMessage() + func (m *Conflict) GetReason() string + func (m *Conflict) Marshal() (dAtA []byte, err error) + func (m *Conflict) MarshalTo(dAtA []byte) (int, error) + func (m *Conflict) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Conflict) Reset() + func (m *Conflict) Size() (n int) + func (m *Conflict) String() string + func (m *Conflict) Unmarshal(dAtA []byte) error + func (m *Conflict) XXX_DiscardUnknown() + func (m *Conflict) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Conflict) XXX_Merge(src proto.Message) + func (m *Conflict) XXX_Size() int + func (m *Conflict) XXX_Unmarshal(b []byte) error + type DisaggReadError struct + Code int32 + Msg string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DisaggReadError) Descriptor() ([]byte, []int) + func (*DisaggReadError) ProtoMessage() + func (m *DisaggReadError) GetCode() int32 + func (m *DisaggReadError) GetMsg() string + func (m *DisaggReadError) Marshal() (dAtA []byte, err error) + func (m *DisaggReadError) MarshalTo(dAtA []byte) (int, error) + func (m *DisaggReadError) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DisaggReadError) Reset() + func (m *DisaggReadError) Size() (n int) + func (m *DisaggReadError) String() string + func (m *DisaggReadError) Unmarshal(dAtA []byte) error + func (m *DisaggReadError) XXX_DiscardUnknown() + func (m *DisaggReadError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DisaggReadError) XXX_Merge(src proto.Message) + func (m *DisaggReadError) XXX_Size() int + func (m *DisaggReadError) XXX_Unmarshal(b []byte) error + type DisaggS3Config struct + Bucket string + Endpoint string + Root string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DisaggS3Config) Descriptor() ([]byte, []int) + func (*DisaggS3Config) ProtoMessage() + func (m *DisaggS3Config) GetBucket() string + func (m *DisaggS3Config) GetEndpoint() string + func (m *DisaggS3Config) GetRoot() string + func (m *DisaggS3Config) Marshal() (dAtA []byte, err error) + func (m *DisaggS3Config) MarshalTo(dAtA []byte) (int, error) + func (m *DisaggS3Config) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DisaggS3Config) Reset() + func (m *DisaggS3Config) Size() (n int) + func (m *DisaggS3Config) String() string + func (m *DisaggS3Config) Unmarshal(dAtA []byte) error + func (m *DisaggS3Config) XXX_DiscardUnknown() + func (m *DisaggS3Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DisaggS3Config) XXX_Merge(src proto.Message) + func (m *DisaggS3Config) XXX_Size() int + func (m *DisaggS3Config) XXX_Unmarshal(b []byte) error + type DisaggTaskMeta struct + ApiVersion kvrpcpb.APIVersion + ExecutorId string + KeyspaceId uint32 + LocalQueryId uint64 + QueryTs uint64 + ServerId uint64 + StartTs uint64 + TaskId int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DisaggTaskMeta) Descriptor() ([]byte, []int) + func (*DisaggTaskMeta) ProtoMessage() + func (m *DisaggTaskMeta) GetApiVersion() kvrpcpb.APIVersion + func (m *DisaggTaskMeta) GetExecutorId() string + func (m *DisaggTaskMeta) GetKeyspaceId() uint32 + func (m *DisaggTaskMeta) GetLocalQueryId() uint64 + func (m *DisaggTaskMeta) GetQueryTs() uint64 + func (m *DisaggTaskMeta) GetServerId() uint64 + func (m *DisaggTaskMeta) GetStartTs() uint64 + func (m *DisaggTaskMeta) GetTaskId() int64 + func (m *DisaggTaskMeta) Marshal() (dAtA []byte, err error) + func (m *DisaggTaskMeta) MarshalTo(dAtA []byte) (int, error) + func (m *DisaggTaskMeta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DisaggTaskMeta) Reset() + func (m *DisaggTaskMeta) Size() (n int) + func (m *DisaggTaskMeta) String() string + func (m *DisaggTaskMeta) Unmarshal(dAtA []byte) error + func (m *DisaggTaskMeta) XXX_DiscardUnknown() + func (m *DisaggTaskMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DisaggTaskMeta) XXX_Merge(src proto.Message) + func (m *DisaggTaskMeta) XXX_Size() int + func (m *DisaggTaskMeta) XXX_Unmarshal(b []byte) error + type ErrorLocked struct + Locked []*kvrpcpb.LockInfo + Msg string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ErrorLocked) Descriptor() ([]byte, []int) + func (*ErrorLocked) ProtoMessage() + func (m *ErrorLocked) GetLocked() []*kvrpcpb.LockInfo + func (m *ErrorLocked) GetMsg() string + func (m *ErrorLocked) Marshal() (dAtA []byte, err error) + func (m *ErrorLocked) MarshalTo(dAtA []byte) (int, error) + func (m *ErrorLocked) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ErrorLocked) Reset() + func (m *ErrorLocked) Size() (n int) + func (m *ErrorLocked) String() string + func (m *ErrorLocked) Unmarshal(dAtA []byte) error + func (m *ErrorLocked) XXX_DiscardUnknown() + func (m *ErrorLocked) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ErrorLocked) XXX_Merge(src proto.Message) + func (m *ErrorLocked) XXX_Size() int + func (m *ErrorLocked) XXX_Unmarshal(b []byte) error + type ErrorOther struct + Code int32 + Msg string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ErrorOther) Descriptor() ([]byte, []int) + func (*ErrorOther) ProtoMessage() + func (m *ErrorOther) GetCode() int32 + func (m *ErrorOther) GetMsg() string + func (m *ErrorOther) Marshal() (dAtA []byte, err error) + func (m *ErrorOther) MarshalTo(dAtA []byte) (int, error) + func (m *ErrorOther) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ErrorOther) Reset() + func (m *ErrorOther) Size() (n int) + func (m *ErrorOther) String() string + func (m *ErrorOther) Unmarshal(dAtA []byte) error + func (m *ErrorOther) XXX_DiscardUnknown() + func (m *ErrorOther) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ErrorOther) XXX_Merge(src proto.Message) + func (m *ErrorOther) XXX_Size() int + func (m *ErrorOther) XXX_Unmarshal(b []byte) error + type ErrorRegion struct + Msg string + RegionIds []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ErrorRegion) Descriptor() ([]byte, []int) + func (*ErrorRegion) ProtoMessage() + func (m *ErrorRegion) GetMsg() string + func (m *ErrorRegion) GetRegionIds() []uint64 + func (m *ErrorRegion) Marshal() (dAtA []byte, err error) + func (m *ErrorRegion) MarshalTo(dAtA []byte) (int, error) + func (m *ErrorRegion) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ErrorRegion) Reset() + func (m *ErrorRegion) Size() (n int) + func (m *ErrorRegion) String() string + func (m *ErrorRegion) Unmarshal(dAtA []byte) error + func (m *ErrorRegion) XXX_DiscardUnknown() + func (m *ErrorRegion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ErrorRegion) XXX_Merge(src proto.Message) + func (m *ErrorRegion) XXX_Size() int + func (m *ErrorRegion) XXX_Unmarshal(b []byte) error + type EstablishDisaggTaskError struct + Errors isEstablishDisaggTaskError_Errors + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EstablishDisaggTaskError) Descriptor() ([]byte, []int) + func (*EstablishDisaggTaskError) ProtoMessage() + func (*EstablishDisaggTaskError) XXX_OneofWrappers() []interface{} + func (m *EstablishDisaggTaskError) GetErrorLocked() *ErrorLocked + func (m *EstablishDisaggTaskError) GetErrorOther() *ErrorOther + func (m *EstablishDisaggTaskError) GetErrorRegion() *ErrorRegion + func (m *EstablishDisaggTaskError) GetErrors() isEstablishDisaggTaskError_Errors + func (m *EstablishDisaggTaskError) Marshal() (dAtA []byte, err error) + func (m *EstablishDisaggTaskError) MarshalTo(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskError) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskError) Reset() + func (m *EstablishDisaggTaskError) Size() (n int) + func (m *EstablishDisaggTaskError) String() string + func (m *EstablishDisaggTaskError) Unmarshal(dAtA []byte) error + func (m *EstablishDisaggTaskError) XXX_DiscardUnknown() + func (m *EstablishDisaggTaskError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EstablishDisaggTaskError) XXX_Merge(src proto.Message) + func (m *EstablishDisaggTaskError) XXX_Size() int + func (m *EstablishDisaggTaskError) XXX_Unmarshal(b []byte) error + type EstablishDisaggTaskError_ErrorLocked struct + ErrorLocked *ErrorLocked + func (m *EstablishDisaggTaskError_ErrorLocked) MarshalTo(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskError_ErrorLocked) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskError_ErrorLocked) Size() (n int) + type EstablishDisaggTaskError_ErrorOther struct + ErrorOther *ErrorOther + func (m *EstablishDisaggTaskError_ErrorOther) MarshalTo(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskError_ErrorOther) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskError_ErrorOther) Size() (n int) + type EstablishDisaggTaskError_ErrorRegion struct + ErrorRegion *ErrorRegion + func (m *EstablishDisaggTaskError_ErrorRegion) MarshalTo(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskError_ErrorRegion) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskError_ErrorRegion) Size() (n int) + type EstablishDisaggTaskRequest struct + Address string + EncodedPlan []byte + Meta *DisaggTaskMeta + Regions []*coprocessor.RegionInfo + SchemaVer int64 + TableRegions []*coprocessor.TableRegions + TimeoutS int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EstablishDisaggTaskRequest) Descriptor() ([]byte, []int) + func (*EstablishDisaggTaskRequest) ProtoMessage() + func (m *EstablishDisaggTaskRequest) GetAddress() string + func (m *EstablishDisaggTaskRequest) GetEncodedPlan() []byte + func (m *EstablishDisaggTaskRequest) GetMeta() *DisaggTaskMeta + func (m *EstablishDisaggTaskRequest) GetRegions() []*coprocessor.RegionInfo + func (m *EstablishDisaggTaskRequest) GetSchemaVer() int64 + func (m *EstablishDisaggTaskRequest) GetTableRegions() []*coprocessor.TableRegions + func (m *EstablishDisaggTaskRequest) GetTimeoutS() int64 + func (m *EstablishDisaggTaskRequest) Marshal() (dAtA []byte, err error) + func (m *EstablishDisaggTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskRequest) Reset() + func (m *EstablishDisaggTaskRequest) Size() (n int) + func (m *EstablishDisaggTaskRequest) String() string + func (m *EstablishDisaggTaskRequest) Unmarshal(dAtA []byte) error + func (m *EstablishDisaggTaskRequest) XXX_DiscardUnknown() + func (m *EstablishDisaggTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EstablishDisaggTaskRequest) XXX_Merge(src proto.Message) + func (m *EstablishDisaggTaskRequest) XXX_Size() int + func (m *EstablishDisaggTaskRequest) XXX_Unmarshal(b []byte) error + type EstablishDisaggTaskResponse struct + Error *EstablishDisaggTaskError + SnapshotId *DisaggTaskMeta + StoreId uint64 + Tables [][]byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EstablishDisaggTaskResponse) Descriptor() ([]byte, []int) + func (*EstablishDisaggTaskResponse) ProtoMessage() + func (m *EstablishDisaggTaskResponse) GetError() *EstablishDisaggTaskError + func (m *EstablishDisaggTaskResponse) GetSnapshotId() *DisaggTaskMeta + func (m *EstablishDisaggTaskResponse) GetStoreId() uint64 + func (m *EstablishDisaggTaskResponse) GetTables() [][]byte + func (m *EstablishDisaggTaskResponse) Marshal() (dAtA []byte, err error) + func (m *EstablishDisaggTaskResponse) MarshalTo(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EstablishDisaggTaskResponse) Reset() + func (m *EstablishDisaggTaskResponse) Size() (n int) + func (m *EstablishDisaggTaskResponse) String() string + func (m *EstablishDisaggTaskResponse) Unmarshal(dAtA []byte) error + func (m *EstablishDisaggTaskResponse) XXX_DiscardUnknown() + func (m *EstablishDisaggTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EstablishDisaggTaskResponse) XXX_Merge(src proto.Message) + func (m *EstablishDisaggTaskResponse) XXX_Size() int + func (m *EstablishDisaggTaskResponse) XXX_Unmarshal(b []byte) error + type FetchDisaggPagesRequest struct + PageIds []uint64 + SegmentId uint64 + SnapshotId *DisaggTaskMeta + TableId int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FetchDisaggPagesRequest) Descriptor() ([]byte, []int) + func (*FetchDisaggPagesRequest) ProtoMessage() + func (m *FetchDisaggPagesRequest) GetPageIds() []uint64 + func (m *FetchDisaggPagesRequest) GetSegmentId() uint64 + func (m *FetchDisaggPagesRequest) GetSnapshotId() *DisaggTaskMeta + func (m *FetchDisaggPagesRequest) GetTableId() int64 + func (m *FetchDisaggPagesRequest) Marshal() (dAtA []byte, err error) + func (m *FetchDisaggPagesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *FetchDisaggPagesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FetchDisaggPagesRequest) Reset() + func (m *FetchDisaggPagesRequest) Size() (n int) + func (m *FetchDisaggPagesRequest) String() string + func (m *FetchDisaggPagesRequest) Unmarshal(dAtA []byte) error + func (m *FetchDisaggPagesRequest) XXX_DiscardUnknown() + func (m *FetchDisaggPagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FetchDisaggPagesRequest) XXX_Merge(src proto.Message) + func (m *FetchDisaggPagesRequest) XXX_Size() int + func (m *FetchDisaggPagesRequest) XXX_Unmarshal(b []byte) error + type GetDisaggConfigRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetDisaggConfigRequest) Descriptor() ([]byte, []int) + func (*GetDisaggConfigRequest) ProtoMessage() + func (m *GetDisaggConfigRequest) Marshal() (dAtA []byte, err error) + func (m *GetDisaggConfigRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetDisaggConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetDisaggConfigRequest) Reset() + func (m *GetDisaggConfigRequest) Size() (n int) + func (m *GetDisaggConfigRequest) String() string + func (m *GetDisaggConfigRequest) Unmarshal(dAtA []byte) error + func (m *GetDisaggConfigRequest) XXX_DiscardUnknown() + func (m *GetDisaggConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetDisaggConfigRequest) XXX_Merge(src proto.Message) + func (m *GetDisaggConfigRequest) XXX_Size() int + func (m *GetDisaggConfigRequest) XXX_Unmarshal(b []byte) error + type GetDisaggConfigResponse struct + S3Config *DisaggS3Config + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetDisaggConfigResponse) Descriptor() ([]byte, []int) + func (*GetDisaggConfigResponse) ProtoMessage() + func (m *GetDisaggConfigResponse) GetS3Config() *DisaggS3Config + func (m *GetDisaggConfigResponse) Marshal() (dAtA []byte, err error) + func (m *GetDisaggConfigResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetDisaggConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetDisaggConfigResponse) Reset() + func (m *GetDisaggConfigResponse) Size() (n int) + func (m *GetDisaggConfigResponse) String() string + func (m *GetDisaggConfigResponse) Unmarshal(dAtA []byte) error + func (m *GetDisaggConfigResponse) XXX_DiscardUnknown() + func (m *GetDisaggConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetDisaggConfigResponse) XXX_Merge(src proto.Message) + func (m *GetDisaggConfigResponse) XXX_Size() int + func (m *GetDisaggConfigResponse) XXX_Unmarshal(b []byte) error + type NotOwner struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NotOwner) Descriptor() ([]byte, []int) + func (*NotOwner) ProtoMessage() + func (m *NotOwner) Marshal() (dAtA []byte, err error) + func (m *NotOwner) MarshalTo(dAtA []byte) (int, error) + func (m *NotOwner) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NotOwner) Reset() + func (m *NotOwner) Size() (n int) + func (m *NotOwner) String() string + func (m *NotOwner) Unmarshal(dAtA []byte) error + func (m *NotOwner) XXX_DiscardUnknown() + func (m *NotOwner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NotOwner) XXX_Merge(src proto.Message) + func (m *NotOwner) XXX_Size() int + func (m *NotOwner) XXX_Unmarshal(b []byte) error + type PagesPacket struct + Chunks [][]byte + Error *DisaggReadError + Pages [][]byte + Summaries [][]byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PagesPacket) Descriptor() ([]byte, []int) + func (*PagesPacket) ProtoMessage() + func (m *PagesPacket) GetChunks() [][]byte + func (m *PagesPacket) GetError() *DisaggReadError + func (m *PagesPacket) GetPages() [][]byte + func (m *PagesPacket) GetSummaries() [][]byte + func (m *PagesPacket) Marshal() (dAtA []byte, err error) + func (m *PagesPacket) MarshalTo(dAtA []byte) (int, error) + func (m *PagesPacket) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PagesPacket) Reset() + func (m *PagesPacket) Size() (n int) + func (m *PagesPacket) String() string + func (m *PagesPacket) Unmarshal(dAtA []byte) error + func (m *PagesPacket) XXX_DiscardUnknown() + func (m *PagesPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PagesPacket) XXX_Merge(src proto.Message) + func (m *PagesPacket) XXX_Size() int + func (m *PagesPacket) XXX_Unmarshal(b []byte) error + type S3LockResult struct + Error isS3LockResult_Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*S3LockResult) Descriptor() ([]byte, []int) + func (*S3LockResult) ProtoMessage() + func (*S3LockResult) XXX_OneofWrappers() []interface{} + func (m *S3LockResult) GetConflict() *Conflict + func (m *S3LockResult) GetError() isS3LockResult_Error + func (m *S3LockResult) GetNotOwner() *NotOwner + func (m *S3LockResult) GetSuccess() *Success + func (m *S3LockResult) Marshal() (dAtA []byte, err error) + func (m *S3LockResult) MarshalTo(dAtA []byte) (int, error) + func (m *S3LockResult) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *S3LockResult) Reset() + func (m *S3LockResult) Size() (n int) + func (m *S3LockResult) String() string + func (m *S3LockResult) Unmarshal(dAtA []byte) error + func (m *S3LockResult) XXX_DiscardUnknown() + func (m *S3LockResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *S3LockResult) XXX_Merge(src proto.Message) + func (m *S3LockResult) XXX_Size() int + func (m *S3LockResult) XXX_Unmarshal(b []byte) error + type S3LockResult_Conflict struct + Conflict *Conflict + func (m *S3LockResult_Conflict) MarshalTo(dAtA []byte) (int, error) + func (m *S3LockResult_Conflict) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *S3LockResult_Conflict) Size() (n int) + type S3LockResult_NotOwner struct + NotOwner *NotOwner + func (m *S3LockResult_NotOwner) MarshalTo(dAtA []byte) (int, error) + func (m *S3LockResult_NotOwner) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *S3LockResult_NotOwner) Size() (n int) + type S3LockResult_Success struct + Success *Success + func (m *S3LockResult_Success) MarshalTo(dAtA []byte) (int, error) + func (m *S3LockResult_Success) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *S3LockResult_Success) Size() (n int) + type Success struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Success) Descriptor() ([]byte, []int) + func (*Success) ProtoMessage() + func (m *Success) Marshal() (dAtA []byte, err error) + func (m *Success) MarshalTo(dAtA []byte) (int, error) + func (m *Success) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Success) Reset() + func (m *Success) Size() (n int) + func (m *Success) String() string + func (m *Success) Unmarshal(dAtA []byte) error + func (m *Success) XXX_DiscardUnknown() + func (m *Success) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Success) XXX_Merge(src proto.Message) + func (m *Success) XXX_Size() int + func (m *Success) XXX_Unmarshal(b []byte) error + type TryAddLockRequest struct + DataFileKey []byte + LockSeq uint64 + LockStoreId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TryAddLockRequest) Descriptor() ([]byte, []int) + func (*TryAddLockRequest) ProtoMessage() + func (m *TryAddLockRequest) GetDataFileKey() []byte + func (m *TryAddLockRequest) GetLockSeq() uint64 + func (m *TryAddLockRequest) GetLockStoreId() uint64 + func (m *TryAddLockRequest) Marshal() (dAtA []byte, err error) + func (m *TryAddLockRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TryAddLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TryAddLockRequest) Reset() + func (m *TryAddLockRequest) Size() (n int) + func (m *TryAddLockRequest) String() string + func (m *TryAddLockRequest) Unmarshal(dAtA []byte) error + func (m *TryAddLockRequest) XXX_DiscardUnknown() + func (m *TryAddLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TryAddLockRequest) XXX_Merge(src proto.Message) + func (m *TryAddLockRequest) XXX_Size() int + func (m *TryAddLockRequest) XXX_Unmarshal(b []byte) error + type TryAddLockResponse struct + Result *S3LockResult + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TryAddLockResponse) Descriptor() ([]byte, []int) + func (*TryAddLockResponse) ProtoMessage() + func (m *TryAddLockResponse) GetResult() *S3LockResult + func (m *TryAddLockResponse) Marshal() (dAtA []byte, err error) + func (m *TryAddLockResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TryAddLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TryAddLockResponse) Reset() + func (m *TryAddLockResponse) Size() (n int) + func (m *TryAddLockResponse) String() string + func (m *TryAddLockResponse) Unmarshal(dAtA []byte) error + func (m *TryAddLockResponse) XXX_DiscardUnknown() + func (m *TryAddLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TryAddLockResponse) XXX_Merge(src proto.Message) + func (m *TryAddLockResponse) XXX_Size() int + func (m *TryAddLockResponse) XXX_Unmarshal(b []byte) error + type TryMarkDeleteRequest struct + DataFileKey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TryMarkDeleteRequest) Descriptor() ([]byte, []int) + func (*TryMarkDeleteRequest) ProtoMessage() + func (m *TryMarkDeleteRequest) GetDataFileKey() []byte + func (m *TryMarkDeleteRequest) Marshal() (dAtA []byte, err error) + func (m *TryMarkDeleteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TryMarkDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TryMarkDeleteRequest) Reset() + func (m *TryMarkDeleteRequest) Size() (n int) + func (m *TryMarkDeleteRequest) String() string + func (m *TryMarkDeleteRequest) Unmarshal(dAtA []byte) error + func (m *TryMarkDeleteRequest) XXX_DiscardUnknown() + func (m *TryMarkDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TryMarkDeleteRequest) XXX_Merge(src proto.Message) + func (m *TryMarkDeleteRequest) XXX_Size() int + func (m *TryMarkDeleteRequest) XXX_Unmarshal(b []byte) error + type TryMarkDeleteResponse struct + Result *S3LockResult + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TryMarkDeleteResponse) Descriptor() ([]byte, []int) + func (*TryMarkDeleteResponse) ProtoMessage() + func (m *TryMarkDeleteResponse) GetResult() *S3LockResult + func (m *TryMarkDeleteResponse) Marshal() (dAtA []byte, err error) + func (m *TryMarkDeleteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TryMarkDeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TryMarkDeleteResponse) Reset() + func (m *TryMarkDeleteResponse) Size() (n int) + func (m *TryMarkDeleteResponse) String() string + func (m *TryMarkDeleteResponse) Unmarshal(dAtA []byte) error + func (m *TryMarkDeleteResponse) XXX_DiscardUnknown() + func (m *TryMarkDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TryMarkDeleteResponse) XXX_Merge(src proto.Message) + func (m *TryMarkDeleteResponse) XXX_Size() int + func (m *TryMarkDeleteResponse) XXX_Unmarshal(b []byte) error