disaggregated

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDisaggregated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDisaggregated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDisaggregated = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type CancelDisaggTaskRequest 

type CancelDisaggTaskRequest struct {
	Meta                 *DisaggTaskMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*CancelDisaggTaskRequest) Descriptor 

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

func (*CancelDisaggTaskRequest) GetMeta 

func (m *CancelDisaggTaskRequest) GetMeta() *DisaggTaskMeta

func (*CancelDisaggTaskRequest) Marshal 

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

func (*CancelDisaggTaskRequest) MarshalTo 

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

func (*CancelDisaggTaskRequest) MarshalToSizedBuffer 

func (m *CancelDisaggTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CancelDisaggTaskRequest) ProtoMessage 

func (*CancelDisaggTaskRequest) ProtoMessage()

func (*CancelDisaggTaskRequest) Reset 

func (m *CancelDisaggTaskRequest) Reset()

func (*CancelDisaggTaskRequest) Size 

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

func (*CancelDisaggTaskRequest) String 

func (m *CancelDisaggTaskRequest) String() string

func (*CancelDisaggTaskRequest) Unmarshal 

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

func (*CancelDisaggTaskRequest) XXX_DiscardUnknown 

func (m *CancelDisaggTaskRequest) XXX_DiscardUnknown()

func (*CancelDisaggTaskRequest) XXX_Marshal 

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

func (*CancelDisaggTaskRequest) XXX_Merge 

func (m *CancelDisaggTaskRequest) XXX_Merge(src proto.Message)

func (*CancelDisaggTaskRequest) XXX_Size 

func (m *CancelDisaggTaskRequest) XXX_Size() int

func (*CancelDisaggTaskRequest) XXX_Unmarshal 

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

type CancelDisaggTaskResponse 

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

func (*CancelDisaggTaskResponse) Descriptor 

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

func (*CancelDisaggTaskResponse) Marshal 

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

func (*CancelDisaggTaskResponse) MarshalTo 

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

func (*CancelDisaggTaskResponse) MarshalToSizedBuffer 

func (m *CancelDisaggTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CancelDisaggTaskResponse) ProtoMessage 

func (*CancelDisaggTaskResponse) ProtoMessage()

func (*CancelDisaggTaskResponse) Reset 

func (m *CancelDisaggTaskResponse) Reset()

func (*CancelDisaggTaskResponse) Size 

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

func (*CancelDisaggTaskResponse) String 

func (m *CancelDisaggTaskResponse) String() string

func (*CancelDisaggTaskResponse) Unmarshal 

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

func (*CancelDisaggTaskResponse) XXX_DiscardUnknown 

func (m *CancelDisaggTaskResponse) XXX_DiscardUnknown()

func (*CancelDisaggTaskResponse) XXX_Marshal 

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

func (*CancelDisaggTaskResponse) XXX_Merge 

func (m *CancelDisaggTaskResponse) XXX_Merge(src proto.Message)

func (*CancelDisaggTaskResponse) XXX_Size 

func (m *CancelDisaggTaskResponse) XXX_Size() int

func (*CancelDisaggTaskResponse) XXX_Unmarshal 

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

type Conflict 

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

Error caused by concurrency conflict, request cancel

func (*Conflict) Descriptor 

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

func (*Conflict) GetReason 

func (m *Conflict) GetReason() string

func (*Conflict) Marshal 

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

func (*Conflict) MarshalTo 

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

func (*Conflict) MarshalToSizedBuffer 

func (m *Conflict) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Conflict) ProtoMessage 

func (*Conflict) ProtoMessage()

func (*Conflict) Reset 

func (m *Conflict) Reset()

func (*Conflict) Size 

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

func (*Conflict) String 

func (m *Conflict) String() string

func (*Conflict) Unmarshal 

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

func (*Conflict) XXX_DiscardUnknown 

func (m *Conflict) XXX_DiscardUnknown()

func (*Conflict) XXX_Marshal 

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

func (*Conflict) XXX_Merge 

func (m *Conflict) XXX_Merge(src proto.Message)

func (*Conflict) XXX_Size 

func (m *Conflict) XXX_Size() int

func (*Conflict) XXX_Unmarshal 

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

type DisaggReadError 

type DisaggReadError struct {
	Code                 int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DisaggReadError) Descriptor 

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

func (*DisaggReadError) GetCode 

func (m *DisaggReadError) GetCode() int32

func (*DisaggReadError) GetMsg 

func (m *DisaggReadError) GetMsg() string

func (*DisaggReadError) Marshal 

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

func (*DisaggReadError) MarshalTo 

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

func (*DisaggReadError) MarshalToSizedBuffer 

func (m *DisaggReadError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DisaggReadError) ProtoMessage 

func (*DisaggReadError) ProtoMessage()

func (*DisaggReadError) Reset 

func (m *DisaggReadError) Reset()

func (*DisaggReadError) Size 

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

func (*DisaggReadError) String 

func (m *DisaggReadError) String() string

func (*DisaggReadError) Unmarshal 

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

func (*DisaggReadError) XXX_DiscardUnknown 

func (m *DisaggReadError) XXX_DiscardUnknown()

func (*DisaggReadError) XXX_Marshal 

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

func (*DisaggReadError) XXX_Merge 

func (m *DisaggReadError) XXX_Merge(src proto.Message)

func (*DisaggReadError) XXX_Size 

func (m *DisaggReadError) XXX_Size() int

func (*DisaggReadError) XXX_Unmarshal 

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

type DisaggS3Config 

type DisaggS3Config struct {
	Bucket               string   `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Root                 string   `protobuf:"bytes,2,opt,name=root,proto3" json:"root,omitempty"`
	Endpoint             string   `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DisaggS3Config) Descriptor 

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

func (*DisaggS3Config) GetBucket 

func (m *DisaggS3Config) GetBucket() string

func (*DisaggS3Config) GetEndpoint 

func (m *DisaggS3Config) GetEndpoint() string

func (*DisaggS3Config) GetRoot 

func (m *DisaggS3Config) GetRoot() string

func (*DisaggS3Config) Marshal 

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

func (*DisaggS3Config) MarshalTo 

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

func (*DisaggS3Config) MarshalToSizedBuffer 

func (m *DisaggS3Config) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DisaggS3Config) ProtoMessage 

func (*DisaggS3Config) ProtoMessage()

func (*DisaggS3Config) Reset 

func (m *DisaggS3Config) Reset()

func (*DisaggS3Config) Size 

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

func (*DisaggS3Config) String 

func (m *DisaggS3Config) String() string

func (*DisaggS3Config) Unmarshal 

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

func (*DisaggS3Config) XXX_DiscardUnknown 

func (m *DisaggS3Config) XXX_DiscardUnknown()

func (*DisaggS3Config) XXX_Marshal 

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

func (*DisaggS3Config) XXX_Merge 

func (m *DisaggS3Config) XXX_Merge(src proto.Message)

func (*DisaggS3Config) XXX_Size 

func (m *DisaggS3Config) XXX_Size() int

func (*DisaggS3Config) XXX_Unmarshal 

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

type DisaggTaskMeta 

type DisaggTaskMeta struct {
	StartTs uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	// query_ts + server_id + local_query_id to represent a global unique query.
	QueryTs              uint64             `protobuf:"varint,2,opt,name=query_ts,json=queryTs,proto3" json:"query_ts,omitempty"`
	ServerId             uint64             `protobuf:"varint,3,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	LocalQueryId         uint64             `protobuf:"varint,4,opt,name=local_query_id,json=localQueryId,proto3" json:"local_query_id,omitempty"`
	TaskId               int64              `protobuf:"varint,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ExecutorId           string             `protobuf:"bytes,6,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	KeyspaceId           uint32             `protobuf:"varint,7,opt,name=keyspace_id,json=keyspaceId,proto3" json:"keyspace_id,omitempty"`
	ApiVersion           kvrpcpb.APIVersion `protobuf:"varint,8,opt,name=api_version,json=apiVersion,proto3,enum=kvrpcpb.APIVersion" json:"api_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*DisaggTaskMeta) Descriptor 

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

func (*DisaggTaskMeta) GetApiVersion 

func (m *DisaggTaskMeta) GetApiVersion() kvrpcpb.APIVersion

func (*DisaggTaskMeta) GetExecutorId 

func (m *DisaggTaskMeta) GetExecutorId() string

func (*DisaggTaskMeta) GetKeyspaceId 

func (m *DisaggTaskMeta) GetKeyspaceId() uint32

func (*DisaggTaskMeta) GetLocalQueryId 

func (m *DisaggTaskMeta) GetLocalQueryId() uint64

func (*DisaggTaskMeta) GetQueryTs 

func (m *DisaggTaskMeta) GetQueryTs() uint64

func (*DisaggTaskMeta) GetServerId 

func (m *DisaggTaskMeta) GetServerId() uint64

func (*DisaggTaskMeta) GetStartTs 

func (m *DisaggTaskMeta) GetStartTs() uint64

func (*DisaggTaskMeta) GetTaskId 

func (m *DisaggTaskMeta) GetTaskId() int64

func (*DisaggTaskMeta) Marshal 

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

func (*DisaggTaskMeta) MarshalTo 

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

func (*DisaggTaskMeta) MarshalToSizedBuffer 

func (m *DisaggTaskMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DisaggTaskMeta) ProtoMessage 

func (*DisaggTaskMeta) ProtoMessage()

func (*DisaggTaskMeta) Reset 

func (m *DisaggTaskMeta) Reset()

func (*DisaggTaskMeta) Size 

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

func (*DisaggTaskMeta) String 

func (m *DisaggTaskMeta) String() string

func (*DisaggTaskMeta) Unmarshal 

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

func (*DisaggTaskMeta) XXX_DiscardUnknown 

func (m *DisaggTaskMeta) XXX_DiscardUnknown()

func (*DisaggTaskMeta) XXX_Marshal 

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

func (*DisaggTaskMeta) XXX_Merge 

func (m *DisaggTaskMeta) XXX_Merge(src proto.Message)

func (*DisaggTaskMeta) XXX_Size 

func (m *DisaggTaskMeta) XXX_Size() int

func (*DisaggTaskMeta) XXX_Unmarshal 

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

type ErrorLocked 

type ErrorLocked struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// The read node needs to resolve these locks.
	Locked               []*kvrpcpb.LockInfo `protobuf:"bytes,2,rep,name=locked,proto3" json:"locked,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ErrorLocked) Descriptor 

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

func (*ErrorLocked) GetLocked 

func (m *ErrorLocked) GetLocked() []*kvrpcpb.LockInfo

func (*ErrorLocked) GetMsg 

func (m *ErrorLocked) GetMsg() string

func (*ErrorLocked) Marshal 

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

func (*ErrorLocked) MarshalTo 

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

func (*ErrorLocked) MarshalToSizedBuffer 

func (m *ErrorLocked) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ErrorLocked) ProtoMessage 

func (*ErrorLocked) ProtoMessage()

func (*ErrorLocked) Reset 

func (m *ErrorLocked) Reset()

func (*ErrorLocked) Size 

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

func (*ErrorLocked) String 

func (m *ErrorLocked) String() string

func (*ErrorLocked) Unmarshal 

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

func (*ErrorLocked) XXX_DiscardUnknown 

func (m *ErrorLocked) XXX_DiscardUnknown()

func (*ErrorLocked) XXX_Marshal 

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

func (*ErrorLocked) XXX_Merge 

func (m *ErrorLocked) XXX_Merge(src proto.Message)

func (*ErrorLocked) XXX_Size 

func (m *ErrorLocked) XXX_Size() int

func (*ErrorLocked) XXX_Unmarshal 

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

type ErrorOther 

type ErrorOther struct {
	Code                 int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ErrorOther) Descriptor 

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

func (*ErrorOther) GetCode 

func (m *ErrorOther) GetCode() int32

func (*ErrorOther) GetMsg 

func (m *ErrorOther) GetMsg() string

func (*ErrorOther) Marshal 

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

func (*ErrorOther) MarshalTo 

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

func (*ErrorOther) MarshalToSizedBuffer 

func (m *ErrorOther) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ErrorOther) ProtoMessage 

func (*ErrorOther) ProtoMessage()

func (*ErrorOther) Reset 

func (m *ErrorOther) Reset()

func (*ErrorOther) Size 

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

func (*ErrorOther) String 

func (m *ErrorOther) String() string

func (*ErrorOther) Unmarshal 

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

func (*ErrorOther) XXX_DiscardUnknown 

func (m *ErrorOther) XXX_DiscardUnknown()

func (*ErrorOther) XXX_Marshal 

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

func (*ErrorOther) XXX_Merge 

func (m *ErrorOther) XXX_Merge(src proto.Message)

func (*ErrorOther) XXX_Size 

func (m *ErrorOther) XXX_Size() int

func (*ErrorOther) XXX_Unmarshal 

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

type ErrorRegion 

type ErrorRegion struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// The read node needs to update its region cache about these regions.
	RegionIds            []uint64 `protobuf:"varint,2,rep,packed,name=region_ids,json=regionIds,proto3" json:"region_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ErrorRegion) Descriptor 

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

func (*ErrorRegion) GetMsg 

func (m *ErrorRegion) GetMsg() string

func (*ErrorRegion) GetRegionIds 

func (m *ErrorRegion) GetRegionIds() []uint64

func (*ErrorRegion) Marshal 

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

func (*ErrorRegion) MarshalTo 

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

func (*ErrorRegion) MarshalToSizedBuffer 

func (m *ErrorRegion) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ErrorRegion) ProtoMessage 

func (*ErrorRegion) ProtoMessage()

func (*ErrorRegion) Reset 

func (m *ErrorRegion) Reset()

func (*ErrorRegion) Size 

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

func (*ErrorRegion) String 

func (m *ErrorRegion) String() string

func (*ErrorRegion) Unmarshal 

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

func (*ErrorRegion) XXX_DiscardUnknown 

func (m *ErrorRegion) XXX_DiscardUnknown()

func (*ErrorRegion) XXX_Marshal 

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

func (*ErrorRegion) XXX_Merge 

func (m *ErrorRegion) XXX_Merge(src proto.Message)

func (*ErrorRegion) XXX_Size 

func (m *ErrorRegion) XXX_Size() int

func (*ErrorRegion) XXX_Unmarshal 

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

type EstablishDisaggTaskError 

type EstablishDisaggTaskError struct {
	// Types that are valid to be assigned to Errors:
	//	*EstablishDisaggTaskError_ErrorRegion
	//	*EstablishDisaggTaskError_ErrorLocked
	//	*EstablishDisaggTaskError_ErrorOther
	Errors               isEstablishDisaggTaskError_Errors `protobuf_oneof:"errors"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*EstablishDisaggTaskError) Descriptor 

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

func (*EstablishDisaggTaskError) GetErrorLocked 

func (m *EstablishDisaggTaskError) GetErrorLocked() *ErrorLocked

func (*EstablishDisaggTaskError) GetErrorOther 

func (m *EstablishDisaggTaskError) GetErrorOther() *ErrorOther

func (*EstablishDisaggTaskError) GetErrorRegion 

func (m *EstablishDisaggTaskError) GetErrorRegion() *ErrorRegion

func (*EstablishDisaggTaskError) GetErrors 

func (m *EstablishDisaggTaskError) GetErrors() isEstablishDisaggTaskError_Errors

func (*EstablishDisaggTaskError) Marshal 

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

func (*EstablishDisaggTaskError) MarshalTo 

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

func (*EstablishDisaggTaskError) MarshalToSizedBuffer 

func (m *EstablishDisaggTaskError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EstablishDisaggTaskError) ProtoMessage 

func (*EstablishDisaggTaskError) ProtoMessage()

func (*EstablishDisaggTaskError) Reset 

func (m *EstablishDisaggTaskError) Reset()

func (*EstablishDisaggTaskError) Size 

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

func (*EstablishDisaggTaskError) String 

func (m *EstablishDisaggTaskError) String() string

func (*EstablishDisaggTaskError) Unmarshal 

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

func (*EstablishDisaggTaskError) XXX_DiscardUnknown 

func (m *EstablishDisaggTaskError) XXX_DiscardUnknown()

func (*EstablishDisaggTaskError) XXX_Marshal 

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

func (*EstablishDisaggTaskError) XXX_Merge 

func (m *EstablishDisaggTaskError) XXX_Merge(src proto.Message)

func (*EstablishDisaggTaskError) XXX_OneofWrappers 

func (*EstablishDisaggTaskError) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*EstablishDisaggTaskError) XXX_Size 

func (m *EstablishDisaggTaskError) XXX_Size() int

func (*EstablishDisaggTaskError) XXX_Unmarshal 

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

type EstablishDisaggTaskError_ErrorLocked 

type EstablishDisaggTaskError_ErrorLocked struct {
	ErrorLocked *ErrorLocked `protobuf:"bytes,2,opt,name=error_locked,json=errorLocked,proto3,oneof" json:"error_locked,omitempty"`
}

func (*EstablishDisaggTaskError_ErrorLocked) MarshalTo 

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

func (*EstablishDisaggTaskError_ErrorLocked) MarshalToSizedBuffer 

func (m *EstablishDisaggTaskError_ErrorLocked) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EstablishDisaggTaskError_ErrorLocked) Size 

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

type EstablishDisaggTaskError_ErrorOther 

type EstablishDisaggTaskError_ErrorOther struct {
	ErrorOther *ErrorOther `protobuf:"bytes,99,opt,name=error_other,json=errorOther,proto3,oneof" json:"error_other,omitempty"`
}

func (*EstablishDisaggTaskError_ErrorOther) MarshalTo 

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

func (*EstablishDisaggTaskError_ErrorOther) MarshalToSizedBuffer 

func (m *EstablishDisaggTaskError_ErrorOther) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EstablishDisaggTaskError_ErrorOther) Size 

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

type EstablishDisaggTaskError_ErrorRegion 

type EstablishDisaggTaskError_ErrorRegion struct {
	ErrorRegion *ErrorRegion `protobuf:"bytes,1,opt,name=error_region,json=errorRegion,proto3,oneof" json:"error_region,omitempty"`
}

func (*EstablishDisaggTaskError_ErrorRegion) MarshalTo 

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

func (*EstablishDisaggTaskError_ErrorRegion) MarshalToSizedBuffer 

func (m *EstablishDisaggTaskError_ErrorRegion) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EstablishDisaggTaskError_ErrorRegion) Size 

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

type EstablishDisaggTaskRequest 

type EstablishDisaggTaskRequest struct {
	Meta    *DisaggTaskMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Address string          `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// The write node needs to ensure that subsequent
	// FetchDisaggPagesRequest can be processed within timeout_s.
	// unit: seconds
	TimeoutS int64 `protobuf:"varint,3,opt,name=timeout_s,json=timeoutS,proto3" json:"timeout_s,omitempty"`
	// The key ranges, Region meta that read node need to execute TableScan
	Regions   []*coprocessor.RegionInfo `protobuf:"bytes,4,rep,name=regions,proto3" json:"regions,omitempty"`
	SchemaVer int64                     `protobuf:"varint,5,opt,name=schema_ver,json=schemaVer,proto3" json:"schema_ver,omitempty"`
	// Used for PartitionTableScan
	TableRegions []*coprocessor.TableRegions `protobuf:"bytes,6,rep,name=table_regions,json=tableRegions,proto3" json:"table_regions,omitempty"`
	// The encoded TableScan/PartitionTableScan + Selection.
	EncodedPlan          []byte   `protobuf:"bytes,7,opt,name=encoded_plan,json=encodedPlan,proto3" json:"encoded_plan,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EstablishDisaggTaskRequest) Descriptor 

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

func (*EstablishDisaggTaskRequest) GetAddress 

func (m *EstablishDisaggTaskRequest) GetAddress() string

func (*EstablishDisaggTaskRequest) GetEncodedPlan 

func (m *EstablishDisaggTaskRequest) GetEncodedPlan() []byte

func (*EstablishDisaggTaskRequest) GetMeta 

func (m *EstablishDisaggTaskRequest) GetMeta() *DisaggTaskMeta

func (*EstablishDisaggTaskRequest) GetRegions 

func (m *EstablishDisaggTaskRequest) GetRegions() []*coprocessor.RegionInfo

func (*EstablishDisaggTaskRequest) GetSchemaVer 

func (m *EstablishDisaggTaskRequest) GetSchemaVer() int64

func (*EstablishDisaggTaskRequest) GetTableRegions 

func (m *EstablishDisaggTaskRequest) GetTableRegions() []*coprocessor.TableRegions

func (*EstablishDisaggTaskRequest) GetTimeoutS 

func (m *EstablishDisaggTaskRequest) GetTimeoutS() int64

func (*EstablishDisaggTaskRequest) Marshal 

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

func (*EstablishDisaggTaskRequest) MarshalTo 

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

func (*EstablishDisaggTaskRequest) MarshalToSizedBuffer 

func (m *EstablishDisaggTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EstablishDisaggTaskRequest) ProtoMessage 

func (*EstablishDisaggTaskRequest) ProtoMessage()

func (*EstablishDisaggTaskRequest) Reset 

func (m *EstablishDisaggTaskRequest) Reset()

func (*EstablishDisaggTaskRequest) Size 

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

func (*EstablishDisaggTaskRequest) String 

func (m *EstablishDisaggTaskRequest) String() string

func (*EstablishDisaggTaskRequest) Unmarshal 

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

func (*EstablishDisaggTaskRequest) XXX_DiscardUnknown 

func (m *EstablishDisaggTaskRequest) XXX_DiscardUnknown()

func (*EstablishDisaggTaskRequest) XXX_Marshal 

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

func (*EstablishDisaggTaskRequest) XXX_Merge 

func (m *EstablishDisaggTaskRequest) XXX_Merge(src proto.Message)

func (*EstablishDisaggTaskRequest) XXX_Size 

func (m *EstablishDisaggTaskRequest) XXX_Size() int

func (*EstablishDisaggTaskRequest) XXX_Unmarshal 

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

type EstablishDisaggTaskResponse 

type EstablishDisaggTaskResponse struct {
	Error *EstablishDisaggTaskError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// Write node maintains a snapshot with a lease time.
	// Read node should read the delta pages
	// (ColumnFileInMemory and ColumnFileTiny)
	// along with this store_id and snapshot_id.
	StoreId    uint64          `protobuf:"varint,3,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	SnapshotId *DisaggTaskMeta `protobuf:"bytes,4,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
	// Serialized disaggregated tasks (per physical table)
	Tables               [][]byte `protobuf:"bytes,5,rep,name=tables,proto3" json:"tables,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EstablishDisaggTaskResponse) Descriptor 

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

func (*EstablishDisaggTaskResponse) GetError 

func (m *EstablishDisaggTaskResponse) GetError() *EstablishDisaggTaskError

func (*EstablishDisaggTaskResponse) GetSnapshotId 

func (m *EstablishDisaggTaskResponse) GetSnapshotId() *DisaggTaskMeta

func (*EstablishDisaggTaskResponse) GetStoreId 

func (m *EstablishDisaggTaskResponse) GetStoreId() uint64

func (*EstablishDisaggTaskResponse) GetTables 

func (m *EstablishDisaggTaskResponse) GetTables() [][]byte

func (*EstablishDisaggTaskResponse) Marshal 

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

func (*EstablishDisaggTaskResponse) MarshalTo 

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

func (*EstablishDisaggTaskResponse) MarshalToSizedBuffer 

func (m *EstablishDisaggTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EstablishDisaggTaskResponse) ProtoMessage 

func (*EstablishDisaggTaskResponse) ProtoMessage()

func (*EstablishDisaggTaskResponse) Reset 

func (m *EstablishDisaggTaskResponse) Reset()

func (*EstablishDisaggTaskResponse) Size 

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

func (*EstablishDisaggTaskResponse) String 

func (m *EstablishDisaggTaskResponse) String() string

func (*EstablishDisaggTaskResponse) Unmarshal 

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

func (*EstablishDisaggTaskResponse) XXX_DiscardUnknown 

func (m *EstablishDisaggTaskResponse) XXX_DiscardUnknown()

func (*EstablishDisaggTaskResponse) XXX_Marshal 

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

func (*EstablishDisaggTaskResponse) XXX_Merge 

func (m *EstablishDisaggTaskResponse) XXX_Merge(src proto.Message)

func (*EstablishDisaggTaskResponse) XXX_Size 

func (m *EstablishDisaggTaskResponse) XXX_Size() int

func (*EstablishDisaggTaskResponse) XXX_Unmarshal 

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

type FetchDisaggPagesRequest 

type FetchDisaggPagesRequest struct {
	// The snapshot id to fetch pages
	SnapshotId *DisaggTaskMeta `protobuf:"bytes,1,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
	TableId    int64           `protobuf:"varint,2,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	SegmentId  uint64          `protobuf:"varint,3,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	// It must be a subset of the delta pages ids returned
	// in EstablishDisaggTaskResponse.segments
	PageIds              []uint64 `protobuf:"varint,4,rep,packed,name=page_ids,json=pageIds,proto3" json:"page_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FetchDisaggPagesRequest) Descriptor 

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

func (*FetchDisaggPagesRequest) GetPageIds 

func (m *FetchDisaggPagesRequest) GetPageIds() []uint64

func (*FetchDisaggPagesRequest) GetSegmentId 

func (m *FetchDisaggPagesRequest) GetSegmentId() uint64

func (*FetchDisaggPagesRequest) GetSnapshotId 

func (m *FetchDisaggPagesRequest) GetSnapshotId() *DisaggTaskMeta

func (*FetchDisaggPagesRequest) GetTableId 

func (m *FetchDisaggPagesRequest) GetTableId() int64

func (*FetchDisaggPagesRequest) Marshal 

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

func (*FetchDisaggPagesRequest) MarshalTo 

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

func (*FetchDisaggPagesRequest) MarshalToSizedBuffer 

func (m *FetchDisaggPagesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FetchDisaggPagesRequest) ProtoMessage 

func (*FetchDisaggPagesRequest) ProtoMessage()

func (*FetchDisaggPagesRequest) Reset 

func (m *FetchDisaggPagesRequest) Reset()

func (*FetchDisaggPagesRequest) Size 

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

func (*FetchDisaggPagesRequest) String 

func (m *FetchDisaggPagesRequest) String() string

func (*FetchDisaggPagesRequest) Unmarshal 

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

func (*FetchDisaggPagesRequest) XXX_DiscardUnknown 

func (m *FetchDisaggPagesRequest) XXX_DiscardUnknown()

func (*FetchDisaggPagesRequest) XXX_Marshal 

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

func (*FetchDisaggPagesRequest) XXX_Merge 

func (m *FetchDisaggPagesRequest) XXX_Merge(src proto.Message)

func (*FetchDisaggPagesRequest) XXX_Size 

func (m *FetchDisaggPagesRequest) XXX_Size() int

func (*FetchDisaggPagesRequest) XXX_Unmarshal 

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

type GetDisaggConfigRequest 

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

func (*GetDisaggConfigRequest) Descriptor 

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

func (*GetDisaggConfigRequest) Marshal 

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

func (*GetDisaggConfigRequest) MarshalTo 

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

func (*GetDisaggConfigRequest) MarshalToSizedBuffer 

func (m *GetDisaggConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDisaggConfigRequest) ProtoMessage 

func (*GetDisaggConfigRequest) ProtoMessage()

func (*GetDisaggConfigRequest) Reset 

func (m *GetDisaggConfigRequest) Reset()

func (*GetDisaggConfigRequest) Size 

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

func (*GetDisaggConfigRequest) String 

func (m *GetDisaggConfigRequest) String() string

func (*GetDisaggConfigRequest) Unmarshal 

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

func (*GetDisaggConfigRequest) XXX_DiscardUnknown 

func (m *GetDisaggConfigRequest) XXX_DiscardUnknown()

func (*GetDisaggConfigRequest) XXX_Marshal 

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

func (*GetDisaggConfigRequest) XXX_Merge 

func (m *GetDisaggConfigRequest) XXX_Merge(src proto.Message)

func (*GetDisaggConfigRequest) XXX_Size 

func (m *GetDisaggConfigRequest) XXX_Size() int

func (*GetDisaggConfigRequest) XXX_Unmarshal 

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

type GetDisaggConfigResponse 

type GetDisaggConfigResponse struct {
	S3Config             *DisaggS3Config `protobuf:"bytes,1,opt,name=s3_config,json=s3Config,proto3" json:"s3_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetDisaggConfigResponse) Descriptor 

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

func (*GetDisaggConfigResponse) GetS3Config 

func (m *GetDisaggConfigResponse) GetS3Config() *DisaggS3Config

func (*GetDisaggConfigResponse) Marshal 

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

func (*GetDisaggConfigResponse) MarshalTo 

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

func (*GetDisaggConfigResponse) MarshalToSizedBuffer 

func (m *GetDisaggConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDisaggConfigResponse) ProtoMessage 

func (*GetDisaggConfigResponse) ProtoMessage()

func (*GetDisaggConfigResponse) Reset 

func (m *GetDisaggConfigResponse) Reset()

func (*GetDisaggConfigResponse) Size 

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

func (*GetDisaggConfigResponse) String 

func (m *GetDisaggConfigResponse) String() string

func (*GetDisaggConfigResponse) Unmarshal 

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

func (*GetDisaggConfigResponse) XXX_DiscardUnknown 

func (m *GetDisaggConfigResponse) XXX_DiscardUnknown()

func (*GetDisaggConfigResponse) XXX_Marshal 

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

func (*GetDisaggConfigResponse) XXX_Merge 

func (m *GetDisaggConfigResponse) XXX_Merge(src proto.Message)

func (*GetDisaggConfigResponse) XXX_Size 

func (m *GetDisaggConfigResponse) XXX_Size() int

func (*GetDisaggConfigResponse) XXX_Unmarshal 

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

type NotOwner 

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

Error caused by S3GC owner changed client should retry

func (*NotOwner) Descriptor 

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

func (*NotOwner) Marshal 

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

func (*NotOwner) MarshalTo 

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

func (*NotOwner) MarshalToSizedBuffer 

func (m *NotOwner) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NotOwner) ProtoMessage 

func (*NotOwner) ProtoMessage()

func (*NotOwner) Reset 

func (m *NotOwner) Reset()

func (*NotOwner) Size 

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

func (*NotOwner) String 

func (m *NotOwner) String() string

func (*NotOwner) Unmarshal 

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

func (*NotOwner) XXX_DiscardUnknown 

func (m *NotOwner) XXX_DiscardUnknown()

func (*NotOwner) XXX_Marshal 

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

func (*NotOwner) XXX_Merge 

func (m *NotOwner) XXX_Merge(src proto.Message)

func (*NotOwner) XXX_Size 

func (m *NotOwner) XXX_Size() int

func (*NotOwner) XXX_Unmarshal 

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

type PagesPacket 

type PagesPacket struct {
	Error *DisaggReadError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// Serialized column file data
	// * ColumnFilePersisted alone with its schema, page data, field offsets
	Pages [][]byte `protobuf:"bytes,2,rep,name=pages,proto3" json:"pages,omitempty"`
	// * ColumnFileInMemory alone with its serialized block
	Chunks [][]byte `protobuf:"bytes,3,rep,name=chunks,proto3" json:"chunks,omitempty"`
	// Return tipb.SelectResponse.execution_summaries in the
	// last packet
	Summaries            [][]byte `protobuf:"bytes,4,rep,name=summaries,proto3" json:"summaries,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PagesPacket) Descriptor 

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

func (*PagesPacket) GetChunks 

func (m *PagesPacket) GetChunks() [][]byte

func (*PagesPacket) GetError 

func (m *PagesPacket) GetError() *DisaggReadError

func (*PagesPacket) GetPages 

func (m *PagesPacket) GetPages() [][]byte

func (*PagesPacket) GetSummaries 

func (m *PagesPacket) GetSummaries() [][]byte

func (*PagesPacket) Marshal 

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

func (*PagesPacket) MarshalTo 

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

func (*PagesPacket) MarshalToSizedBuffer 

func (m *PagesPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PagesPacket) ProtoMessage 

func (*PagesPacket) ProtoMessage()

func (*PagesPacket) Reset 

func (m *PagesPacket) Reset()

func (*PagesPacket) Size 

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

func (*PagesPacket) String 

func (m *PagesPacket) String() string

func (*PagesPacket) Unmarshal 

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

func (*PagesPacket) XXX_DiscardUnknown 

func (m *PagesPacket) XXX_DiscardUnknown()

func (*PagesPacket) XXX_Marshal 

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

func (*PagesPacket) XXX_Merge 

func (m *PagesPacket) XXX_Merge(src proto.Message)

func (*PagesPacket) XXX_Size 

func (m *PagesPacket) XXX_Size() int

func (*PagesPacket) XXX_Unmarshal 

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

type S3LockResult 

type S3LockResult struct {
	// Types that are valid to be assigned to Error:
	//	*S3LockResult_Success
	//	*S3LockResult_NotOwner
	//	*S3LockResult_Conflict
	Error                isS3LockResult_Error `protobuf_oneof:"error"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*S3LockResult) Descriptor 

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

func (*S3LockResult) GetConflict 

func (m *S3LockResult) GetConflict() *Conflict

func (*S3LockResult) GetError 

func (m *S3LockResult) GetError() isS3LockResult_Error

func (*S3LockResult) GetNotOwner 

func (m *S3LockResult) GetNotOwner() *NotOwner

func (*S3LockResult) GetSuccess 

func (m *S3LockResult) GetSuccess() *Success

func (*S3LockResult) Marshal 

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

func (*S3LockResult) MarshalTo 

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

func (*S3LockResult) MarshalToSizedBuffer 

func (m *S3LockResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*S3LockResult) ProtoMessage 

func (*S3LockResult) ProtoMessage()

func (*S3LockResult) Reset 

func (m *S3LockResult) Reset()

func (*S3LockResult) Size 

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

func (*S3LockResult) String 

func (m *S3LockResult) String() string

func (*S3LockResult) Unmarshal 

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

func (*S3LockResult) XXX_DiscardUnknown 

func (m *S3LockResult) XXX_DiscardUnknown()

func (*S3LockResult) XXX_Marshal 

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

func (*S3LockResult) XXX_Merge 

func (m *S3LockResult) XXX_Merge(src proto.Message)

func (*S3LockResult) XXX_OneofWrappers 

func (*S3LockResult) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*S3LockResult) XXX_Size 

func (m *S3LockResult) XXX_Size() int

func (*S3LockResult) XXX_Unmarshal 

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

type S3LockResult_Conflict 

type S3LockResult_Conflict struct {
	Conflict *Conflict `protobuf:"bytes,3,opt,name=conflict,proto3,oneof" json:"conflict,omitempty"`
}

func (*S3LockResult_Conflict) MarshalTo 

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

func (*S3LockResult_Conflict) MarshalToSizedBuffer 

func (m *S3LockResult_Conflict) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*S3LockResult_Conflict) Size 

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

type S3LockResult_NotOwner 

type S3LockResult_NotOwner struct {
	NotOwner *NotOwner `protobuf:"bytes,2,opt,name=not_owner,json=notOwner,proto3,oneof" json:"not_owner,omitempty"`
}

func (*S3LockResult_NotOwner) MarshalTo 

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

func (*S3LockResult_NotOwner) MarshalToSizedBuffer 

func (m *S3LockResult_NotOwner) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*S3LockResult_NotOwner) Size 

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

type S3LockResult_Success 

type S3LockResult_Success struct {
	Success *Success `protobuf:"bytes,1,opt,name=success,proto3,oneof" json:"success,omitempty"`
}

func (*S3LockResult_Success) MarshalTo 

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

func (*S3LockResult_Success) MarshalToSizedBuffer 

func (m *S3LockResult_Success) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*S3LockResult_Success) Size 

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

type Success 

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

func (*Success) Descriptor 

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

func (*Success) Marshal 

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

func (*Success) MarshalTo 

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

func (*Success) MarshalToSizedBuffer 

func (m *Success) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Success) ProtoMessage 

func (*Success) ProtoMessage()

func (*Success) Reset 

func (m *Success) Reset()

func (*Success) Size 

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

func (*Success) String 

func (m *Success) String() string

func (*Success) Unmarshal 

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

func (*Success) XXX_DiscardUnknown 

func (m *Success) XXX_DiscardUnknown()

func (*Success) XXX_Marshal 

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

func (*Success) XXX_Merge 

func (m *Success) XXX_Merge(src proto.Message)

func (*Success) XXX_Size 

func (m *Success) XXX_Size() int

func (*Success) XXX_Unmarshal 

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

type TryAddLockRequest 

type TryAddLockRequest struct {
	// The data file key to add lock
	DataFileKey []byte `protobuf:"bytes,1,opt,name=data_file_key,json=dataFileKey,proto3" json:"data_file_key,omitempty"`
	// The lock store id
	LockStoreId uint64 `protobuf:"varint,3,opt,name=lock_store_id,json=lockStoreId,proto3" json:"lock_store_id,omitempty"`
	// The upload sequence number of lock store
	LockSeq              uint64   `protobuf:"varint,4,opt,name=lock_seq,json=lockSeq,proto3" json:"lock_seq,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TryAddLockRequest) Descriptor 

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

func (*TryAddLockRequest) GetDataFileKey 

func (m *TryAddLockRequest) GetDataFileKey() []byte

func (*TryAddLockRequest) GetLockSeq 

func (m *TryAddLockRequest) GetLockSeq() uint64

func (*TryAddLockRequest) GetLockStoreId 

func (m *TryAddLockRequest) GetLockStoreId() uint64

func (*TryAddLockRequest) Marshal 

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

func (*TryAddLockRequest) MarshalTo 

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

func (*TryAddLockRequest) MarshalToSizedBuffer 

func (m *TryAddLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TryAddLockRequest) ProtoMessage 

func (*TryAddLockRequest) ProtoMessage()

func (*TryAddLockRequest) Reset 

func (m *TryAddLockRequest) Reset()

func (*TryAddLockRequest) Size 

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

func (*TryAddLockRequest) String 

func (m *TryAddLockRequest) String() string

func (*TryAddLockRequest) Unmarshal 

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

func (*TryAddLockRequest) XXX_DiscardUnknown 

func (m *TryAddLockRequest) XXX_DiscardUnknown()

func (*TryAddLockRequest) XXX_Marshal 

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

func (*TryAddLockRequest) XXX_Merge 

func (m *TryAddLockRequest) XXX_Merge(src proto.Message)

func (*TryAddLockRequest) XXX_Size 

func (m *TryAddLockRequest) XXX_Size() int

func (*TryAddLockRequest) XXX_Unmarshal 

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

type TryAddLockResponse 

type TryAddLockResponse struct {
	Result               *S3LockResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*TryAddLockResponse) Descriptor 

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

func (*TryAddLockResponse) GetResult 

func (m *TryAddLockResponse) GetResult() *S3LockResult

func (*TryAddLockResponse) Marshal 

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

func (*TryAddLockResponse) MarshalTo 

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

func (*TryAddLockResponse) MarshalToSizedBuffer 

func (m *TryAddLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TryAddLockResponse) ProtoMessage 

func (*TryAddLockResponse) ProtoMessage()

func (*TryAddLockResponse) Reset 

func (m *TryAddLockResponse) Reset()

func (*TryAddLockResponse) Size 

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

func (*TryAddLockResponse) String 

func (m *TryAddLockResponse) String() string

func (*TryAddLockResponse) Unmarshal 

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

func (*TryAddLockResponse) XXX_DiscardUnknown 

func (m *TryAddLockResponse) XXX_DiscardUnknown()

func (*TryAddLockResponse) XXX_Marshal 

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

func (*TryAddLockResponse) XXX_Merge 

func (m *TryAddLockResponse) XXX_Merge(src proto.Message)

func (*TryAddLockResponse) XXX_Size 

func (m *TryAddLockResponse) XXX_Size() int

func (*TryAddLockResponse) XXX_Unmarshal 

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

type TryMarkDeleteRequest 

type TryMarkDeleteRequest struct {
	// The data file key to be marked as deleted
	DataFileKey          []byte   `protobuf:"bytes,1,opt,name=data_file_key,json=dataFileKey,proto3" json:"data_file_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TryMarkDeleteRequest) Descriptor 

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

func (*TryMarkDeleteRequest) GetDataFileKey 

func (m *TryMarkDeleteRequest) GetDataFileKey() []byte

func (*TryMarkDeleteRequest) Marshal 

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

func (*TryMarkDeleteRequest) MarshalTo 

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

func (*TryMarkDeleteRequest) MarshalToSizedBuffer 

func (m *TryMarkDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TryMarkDeleteRequest) ProtoMessage 

func (*TryMarkDeleteRequest) ProtoMessage()

func (*TryMarkDeleteRequest) Reset 

func (m *TryMarkDeleteRequest) Reset()

func (*TryMarkDeleteRequest) Size 

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

func (*TryMarkDeleteRequest) String 

func (m *TryMarkDeleteRequest) String() string

func (*TryMarkDeleteRequest) Unmarshal 

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

func (*TryMarkDeleteRequest) XXX_DiscardUnknown 

func (m *TryMarkDeleteRequest) XXX_DiscardUnknown()

func (*TryMarkDeleteRequest) XXX_Marshal 

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

func (*TryMarkDeleteRequest) XXX_Merge 

func (m *TryMarkDeleteRequest) XXX_Merge(src proto.Message)

func (*TryMarkDeleteRequest) XXX_Size 

func (m *TryMarkDeleteRequest) XXX_Size() int

func (*TryMarkDeleteRequest) XXX_Unmarshal 

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

type TryMarkDeleteResponse 

type TryMarkDeleteResponse struct {
	Result               *S3LockResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*TryMarkDeleteResponse) Descriptor 

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

func (*TryMarkDeleteResponse) GetResult 

func (m *TryMarkDeleteResponse) GetResult() *S3LockResult

func (*TryMarkDeleteResponse) Marshal 

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

func (*TryMarkDeleteResponse) MarshalTo 

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

func (*TryMarkDeleteResponse) MarshalToSizedBuffer 

func (m *TryMarkDeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TryMarkDeleteResponse) ProtoMessage 

func (*TryMarkDeleteResponse) ProtoMessage()

func (*TryMarkDeleteResponse) Reset 

func (m *TryMarkDeleteResponse) Reset()

func (*TryMarkDeleteResponse) Size 

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

func (*TryMarkDeleteResponse) String 

func (m *TryMarkDeleteResponse) String() string

func (*TryMarkDeleteResponse) Unmarshal 

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

func (*TryMarkDeleteResponse) XXX_DiscardUnknown 

func (m *TryMarkDeleteResponse) XXX_DiscardUnknown()

func (*TryMarkDeleteResponse) XXX_Marshal 

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

func (*TryMarkDeleteResponse) XXX_Merge 

func (m *TryMarkDeleteResponse) XXX_Merge(src proto.Message)

func (*TryMarkDeleteResponse) XXX_Size 

func (m *TryMarkDeleteResponse) XXX_Size() int

func (*TryMarkDeleteResponse) XXX_Unmarshal 

func (m *TryMarkDeleteResponse) 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.