errorpb

package
v0.0.0-...-e8eeb94 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 7 Imported by: 963

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthErrorpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowErrorpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupErrorpb = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type BucketVersionNotMatch 

type BucketVersionNotMatch struct {
	Version uint64   `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Keys    [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
}

BucketVersionNotMatch is the error variant that tells the request buckets version is not match. client should update the buckets version and retry.

func (*BucketVersionNotMatch) Descriptor 

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

func (*BucketVersionNotMatch) GetKeys 

func (m *BucketVersionNotMatch) GetKeys() [][]byte

func (*BucketVersionNotMatch) GetVersion 

func (m *BucketVersionNotMatch) GetVersion() uint64

func (*BucketVersionNotMatch) Marshal 

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

func (*BucketVersionNotMatch) MarshalTo 

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

func (*BucketVersionNotMatch) MarshalToSizedBuffer 

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

func (*BucketVersionNotMatch) ProtoMessage 

func (*BucketVersionNotMatch) ProtoMessage()

func (*BucketVersionNotMatch) Reset 

func (m *BucketVersionNotMatch) Reset()

func (*BucketVersionNotMatch) Size 

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

func (*BucketVersionNotMatch) String 

func (m *BucketVersionNotMatch) String() string

func (*BucketVersionNotMatch) Unmarshal 

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

func (*BucketVersionNotMatch) XXX_DiscardUnknown 

func (m *BucketVersionNotMatch) XXX_DiscardUnknown()

func (*BucketVersionNotMatch) XXX_Marshal 

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

func (*BucketVersionNotMatch) XXX_Merge 

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

func (*BucketVersionNotMatch) XXX_Size 

func (m *BucketVersionNotMatch) XXX_Size() int

func (*BucketVersionNotMatch) XXX_Unmarshal 

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

type DataIsNotReady 

type DataIsNotReady struct {
	// The requested region ID
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	PeerId   uint64 `protobuf:"varint,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	SafeTs   uint64 `protobuf:"varint,3,opt,name=safe_ts,json=safeTs,proto3" json:"safe_ts,omitempty"`
}

func (*DataIsNotReady) Descriptor 

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

func (*DataIsNotReady) GetPeerId 

func (m *DataIsNotReady) GetPeerId() uint64

func (*DataIsNotReady) GetRegionId 

func (m *DataIsNotReady) GetRegionId() uint64

func (*DataIsNotReady) GetSafeTs 

func (m *DataIsNotReady) GetSafeTs() uint64

func (*DataIsNotReady) Marshal 

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

func (*DataIsNotReady) MarshalTo 

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

func (*DataIsNotReady) MarshalToSizedBuffer 

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

func (*DataIsNotReady) ProtoMessage 

func (*DataIsNotReady) ProtoMessage()

func (*DataIsNotReady) Reset 

func (m *DataIsNotReady) Reset()

func (*DataIsNotReady) Size 

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

func (*DataIsNotReady) String 

func (m *DataIsNotReady) String() string

func (*DataIsNotReady) Unmarshal 

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

func (*DataIsNotReady) XXX_DiscardUnknown 

func (m *DataIsNotReady) XXX_DiscardUnknown()

func (*DataIsNotReady) XXX_Marshal 

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

func (*DataIsNotReady) XXX_Merge 

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

func (*DataIsNotReady) XXX_Size 

func (m *DataIsNotReady) XXX_Size() int

func (*DataIsNotReady) XXX_Unmarshal 

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

type DiskFull 

type DiskFull struct {
	// The requested store ID
	StoreId []uint64 `protobuf:"varint,1,rep,packed,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	// The detailed info
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
}

func (*DiskFull) Descriptor 

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

func (*DiskFull) GetReason 

func (m *DiskFull) GetReason() string

func (*DiskFull) GetStoreId 

func (m *DiskFull) GetStoreId() []uint64

func (*DiskFull) Marshal 

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

func (*DiskFull) MarshalTo 

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

func (*DiskFull) MarshalToSizedBuffer 

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

func (*DiskFull) ProtoMessage 

func (*DiskFull) ProtoMessage()

func (*DiskFull) Reset 

func (m *DiskFull) Reset()

func (*DiskFull) Size 

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

func (*DiskFull) String 

func (m *DiskFull) String() string

func (*DiskFull) Unmarshal 

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

func (*DiskFull) XXX_DiscardUnknown 

func (m *DiskFull) XXX_DiscardUnknown()

func (*DiskFull) XXX_Marshal 

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

func (*DiskFull) XXX_Merge 

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

func (*DiskFull) XXX_Size 

func (m *DiskFull) XXX_Size() int

func (*DiskFull) XXX_Unmarshal 

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

type EpochNotMatch 

type EpochNotMatch struct {
	// Available regions that may be siblings of the requested one.
	CurrentRegions []*metapb.Region `protobuf:"bytes,1,rep,name=current_regions,json=currentRegions,proto3" json:"current_regions,omitempty"`
}

EpochNotMatch is the error variant that tells a region has been updated. (e.g. by splitting / merging, or raft Confchange.) Hence, a command is based on a stale version of a region.

func (*EpochNotMatch) Descriptor 

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

func (*EpochNotMatch) GetCurrentRegions 

func (m *EpochNotMatch) GetCurrentRegions() []*metapb.Region

func (*EpochNotMatch) Marshal 

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

func (*EpochNotMatch) MarshalTo 

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

func (*EpochNotMatch) MarshalToSizedBuffer 

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

func (*EpochNotMatch) ProtoMessage 

func (*EpochNotMatch) ProtoMessage()

func (*EpochNotMatch) Reset 

func (m *EpochNotMatch) Reset()

func (*EpochNotMatch) Size 

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

func (*EpochNotMatch) String 

func (m *EpochNotMatch) String() string

func (*EpochNotMatch) Unmarshal 

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

func (*EpochNotMatch) XXX_DiscardUnknown 

func (m *EpochNotMatch) XXX_DiscardUnknown()

func (*EpochNotMatch) XXX_Marshal 

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

func (*EpochNotMatch) XXX_Merge 

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

func (*EpochNotMatch) XXX_Size 

func (m *EpochNotMatch) XXX_Size() int

func (*EpochNotMatch) XXX_Unmarshal 

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

type Error 

type Error struct {
	// The error message
	Message               string                 `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	NotLeader             *NotLeader             `protobuf:"bytes,2,opt,name=not_leader,json=notLeader,proto3" json:"not_leader,omitempty"`
	RegionNotFound        *RegionNotFound        `protobuf:"bytes,3,opt,name=region_not_found,json=regionNotFound,proto3" json:"region_not_found,omitempty"`
	KeyNotInRegion        *KeyNotInRegion        `protobuf:"bytes,4,opt,name=key_not_in_region,json=keyNotInRegion,proto3" json:"key_not_in_region,omitempty"`
	EpochNotMatch         *EpochNotMatch         `protobuf:"bytes,5,opt,name=epoch_not_match,json=epochNotMatch,proto3" json:"epoch_not_match,omitempty"`
	ServerIsBusy          *ServerIsBusy          `protobuf:"bytes,6,opt,name=server_is_busy,json=serverIsBusy,proto3" json:"server_is_busy,omitempty"`
	StaleCommand          *StaleCommand          `protobuf:"bytes,7,opt,name=stale_command,json=staleCommand,proto3" json:"stale_command,omitempty"`
	StoreNotMatch         *StoreNotMatch         `protobuf:"bytes,8,opt,name=store_not_match,json=storeNotMatch,proto3" json:"store_not_match,omitempty"`
	RaftEntryTooLarge     *RaftEntryTooLarge     `protobuf:"bytes,9,opt,name=raft_entry_too_large,json=raftEntryTooLarge,proto3" json:"raft_entry_too_large,omitempty"`
	MaxTimestampNotSynced *MaxTimestampNotSynced `` /* 129-byte string literal not displayed */
	ReadIndexNotReady     *ReadIndexNotReady     `protobuf:"bytes,11,opt,name=read_index_not_ready,json=readIndexNotReady,proto3" json:"read_index_not_ready,omitempty"`
	ProposalInMergingMode *ProposalInMergingMode `` /* 129-byte string literal not displayed */
	DataIsNotReady        *DataIsNotReady        `protobuf:"bytes,13,opt,name=data_is_not_ready,json=dataIsNotReady,proto3" json:"data_is_not_ready,omitempty"`
	RegionNotInitialized  *RegionNotInitialized  `protobuf:"bytes,14,opt,name=region_not_initialized,json=regionNotInitialized,proto3" json:"region_not_initialized,omitempty"`
	DiskFull              *DiskFull              `protobuf:"bytes,15,opt,name=disk_full,json=diskFull,proto3" json:"disk_full,omitempty"`
	// Online recovery is still in performing, reject writes to avoid potential issues
	RecoveryInProgress *RecoveryInProgress `protobuf:"bytes,16,opt,name=RecoveryInProgress,proto3" json:"RecoveryInProgress,omitempty"`
	// Flashback is still in performing, reject any read or write to avoid potential issues.
	// NOTICE: this error is non-retryable, the request should fail ASAP when it meets this error.
	FlashbackInProgress *FlashbackInProgress `protobuf:"bytes,17,opt,name=FlashbackInProgress,proto3" json:"FlashbackInProgress,omitempty"`
	// If the second phase flashback request is sent to a region that is not prepared for the flashback,
	// this error will be returned.
	// NOTICE: this error is non-retryable, the client should retry the first phase flashback request when it meets this error.
	FlashbackNotPrepared *FlashbackNotPrepared `protobuf:"bytes,18,opt,name=FlashbackNotPrepared,proto3" json:"FlashbackNotPrepared,omitempty"`
	// IsWitness is the error variant that tells a request be handle by witness
	// which should be forbidden and retry.
	IsWitness      *IsWitness      `protobuf:"bytes,19,opt,name=is_witness,json=isWitness,proto3" json:"is_witness,omitempty"`
	MismatchPeerId *MismatchPeerId `protobuf:"bytes,20,opt,name=mismatch_peer_id,json=mismatchPeerId,proto3" json:"mismatch_peer_id,omitempty"`
	// BucketVersionNotMatch is the error variant that tells the request buckets version is not match.
	BucketVersionNotMatch *BucketVersionNotMatch `` /* 129-byte string literal not displayed */
}

Error wraps all region errors, indicates an error encountered by a request.

func (*Error) Descriptor 

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

func (*Error) GetBucketVersionNotMatch 

func (m *Error) GetBucketVersionNotMatch() *BucketVersionNotMatch

func (*Error) GetDataIsNotReady 

func (m *Error) GetDataIsNotReady() *DataIsNotReady

func (*Error) GetDiskFull 

func (m *Error) GetDiskFull() *DiskFull

func (*Error) GetEpochNotMatch 

func (m *Error) GetEpochNotMatch() *EpochNotMatch

func (*Error) GetFlashbackInProgress 

func (m *Error) GetFlashbackInProgress() *FlashbackInProgress

func (*Error) GetFlashbackNotPrepared 

func (m *Error) GetFlashbackNotPrepared() *FlashbackNotPrepared

func (*Error) GetIsWitness 

func (m *Error) GetIsWitness() *IsWitness

func (*Error) GetKeyNotInRegion 

func (m *Error) GetKeyNotInRegion() *KeyNotInRegion

func (*Error) GetMaxTimestampNotSynced 

func (m *Error) GetMaxTimestampNotSynced() *MaxTimestampNotSynced

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) GetMismatchPeerId 

func (m *Error) GetMismatchPeerId() *MismatchPeerId

func (*Error) GetNotLeader 

func (m *Error) GetNotLeader() *NotLeader

func (*Error) GetProposalInMergingMode 

func (m *Error) GetProposalInMergingMode() *ProposalInMergingMode

func (*Error) GetRaftEntryTooLarge 

func (m *Error) GetRaftEntryTooLarge() *RaftEntryTooLarge

func (*Error) GetReadIndexNotReady 

func (m *Error) GetReadIndexNotReady() *ReadIndexNotReady

func (*Error) GetRecoveryInProgress 

func (m *Error) GetRecoveryInProgress() *RecoveryInProgress

func (*Error) GetRegionNotFound 

func (m *Error) GetRegionNotFound() *RegionNotFound

func (*Error) GetRegionNotInitialized 

func (m *Error) GetRegionNotInitialized() *RegionNotInitialized

func (*Error) GetServerIsBusy 

func (m *Error) GetServerIsBusy() *ServerIsBusy

func (*Error) GetStaleCommand 

func (m *Error) GetStaleCommand() *StaleCommand

func (*Error) GetStoreNotMatch 

func (m *Error) GetStoreNotMatch() *StoreNotMatch

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) MarshalToSizedBuffer 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type FlashbackInProgress 

type FlashbackInProgress struct {
	// The requested region ID
	RegionId         uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	FlashbackStartTs uint64 `protobuf:"varint,2,opt,name=flashback_start_ts,json=flashbackStartTs,proto3" json:"flashback_start_ts,omitempty"`
}

func (*FlashbackInProgress) Descriptor 

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

func (*FlashbackInProgress) GetFlashbackStartTs 

func (m *FlashbackInProgress) GetFlashbackStartTs() uint64

func (*FlashbackInProgress) GetRegionId 

func (m *FlashbackInProgress) GetRegionId() uint64

func (*FlashbackInProgress) Marshal 

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

func (*FlashbackInProgress) MarshalTo 

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

func (*FlashbackInProgress) MarshalToSizedBuffer 

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

func (*FlashbackInProgress) ProtoMessage 

func (*FlashbackInProgress) ProtoMessage()

func (*FlashbackInProgress) Reset 

func (m *FlashbackInProgress) Reset()

func (*FlashbackInProgress) Size 

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

func (*FlashbackInProgress) String 

func (m *FlashbackInProgress) String() string

func (*FlashbackInProgress) Unmarshal 

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

func (*FlashbackInProgress) XXX_DiscardUnknown 

func (m *FlashbackInProgress) XXX_DiscardUnknown()

func (*FlashbackInProgress) XXX_Marshal 

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

func (*FlashbackInProgress) XXX_Merge 

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

func (*FlashbackInProgress) XXX_Size 

func (m *FlashbackInProgress) XXX_Size() int

func (*FlashbackInProgress) XXX_Unmarshal 

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

type FlashbackNotPrepared 

type FlashbackNotPrepared struct {
	// The requested region ID
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

func (*FlashbackNotPrepared) Descriptor 

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

func (*FlashbackNotPrepared) GetRegionId 

func (m *FlashbackNotPrepared) GetRegionId() uint64

func (*FlashbackNotPrepared) Marshal 

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

func (*FlashbackNotPrepared) MarshalTo 

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

func (*FlashbackNotPrepared) MarshalToSizedBuffer 

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

func (*FlashbackNotPrepared) ProtoMessage 

func (*FlashbackNotPrepared) ProtoMessage()

func (*FlashbackNotPrepared) Reset 

func (m *FlashbackNotPrepared) Reset()

func (*FlashbackNotPrepared) Size 

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

func (*FlashbackNotPrepared) String 

func (m *FlashbackNotPrepared) String() string

func (*FlashbackNotPrepared) Unmarshal 

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

func (*FlashbackNotPrepared) XXX_DiscardUnknown 

func (m *FlashbackNotPrepared) XXX_DiscardUnknown()

func (*FlashbackNotPrepared) XXX_Marshal 

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

func (*FlashbackNotPrepared) XXX_Merge 

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

func (*FlashbackNotPrepared) XXX_Size 

func (m *FlashbackNotPrepared) XXX_Size() int

func (*FlashbackNotPrepared) XXX_Unmarshal 

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

type IsWitness 

type IsWitness struct {
	// The requested region ID
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

IsWitness is the error variant that tells a request be handle by witness which should be forbidden and retry.

func (*IsWitness) Descriptor 

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

func (*IsWitness) GetRegionId 

func (m *IsWitness) GetRegionId() uint64

func (*IsWitness) Marshal 

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

func (*IsWitness) MarshalTo 

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

func (*IsWitness) MarshalToSizedBuffer 

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

func (*IsWitness) ProtoMessage 

func (*IsWitness) ProtoMessage()

func (*IsWitness) Reset 

func (m *IsWitness) Reset()

func (*IsWitness) Size 

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

func (*IsWitness) String 

func (m *IsWitness) String() string

func (*IsWitness) Unmarshal 

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

func (*IsWitness) XXX_DiscardUnknown 

func (m *IsWitness) XXX_DiscardUnknown()

func (*IsWitness) XXX_Marshal 

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

func (*IsWitness) XXX_Merge 

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

func (*IsWitness) XXX_Size 

func (m *IsWitness) XXX_Size() int

func (*IsWitness) XXX_Unmarshal 

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

type KeyNotInRegion 

type KeyNotInRegion struct {
	// The requested key
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The requested region ID
	RegionId uint64 `protobuf:"varint,2,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	// Start key of the requested region
	StartKey []byte `protobuf:"bytes,3,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	// Snd key of the requested region
	EndKey []byte `protobuf:"bytes,4,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
}

KeyNotInRegion is the error variant that tells the key the request requires isn't present in this region.

func (*KeyNotInRegion) Descriptor 

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

func (*KeyNotInRegion) GetEndKey 

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

func (*KeyNotInRegion) GetKey 

func (m *KeyNotInRegion) GetKey() []byte

func (*KeyNotInRegion) GetRegionId 

func (m *KeyNotInRegion) GetRegionId() uint64

func (*KeyNotInRegion) GetStartKey 

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

func (*KeyNotInRegion) Marshal 

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

func (*KeyNotInRegion) MarshalTo 

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

func (*KeyNotInRegion) MarshalToSizedBuffer 

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

func (*KeyNotInRegion) ProtoMessage 

func (*KeyNotInRegion) ProtoMessage()

func (*KeyNotInRegion) Reset 

func (m *KeyNotInRegion) Reset()

func (*KeyNotInRegion) Size 

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

func (*KeyNotInRegion) String 

func (m *KeyNotInRegion) String() string

func (*KeyNotInRegion) Unmarshal 

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

func (*KeyNotInRegion) XXX_DiscardUnknown 

func (m *KeyNotInRegion) XXX_DiscardUnknown()

func (*KeyNotInRegion) XXX_Marshal 

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

func (*KeyNotInRegion) XXX_Merge 

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

func (*KeyNotInRegion) XXX_Size 

func (m *KeyNotInRegion) XXX_Size() int

func (*KeyNotInRegion) XXX_Unmarshal 

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

type MaxTimestampNotSynced 

type MaxTimestampNotSynced struct {
}

MaxTimestampNotSynced is the error variant that tells the peer has just become a leader and updating the max timestamp in the concurrency manager from PD TSO is ongoing. In this case, the prewrite of an async commit transaction cannot succeed. The client can backoff and resend the request.

func (*MaxTimestampNotSynced) Descriptor 

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

func (*MaxTimestampNotSynced) Marshal 

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

func (*MaxTimestampNotSynced) MarshalTo 

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

func (*MaxTimestampNotSynced) MarshalToSizedBuffer 

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

func (*MaxTimestampNotSynced) ProtoMessage 

func (*MaxTimestampNotSynced) ProtoMessage()

func (*MaxTimestampNotSynced) Reset 

func (m *MaxTimestampNotSynced) Reset()

func (*MaxTimestampNotSynced) Size 

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

func (*MaxTimestampNotSynced) String 

func (m *MaxTimestampNotSynced) String() string

func (*MaxTimestampNotSynced) Unmarshal 

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

func (*MaxTimestampNotSynced) XXX_DiscardUnknown 

func (m *MaxTimestampNotSynced) XXX_DiscardUnknown()

func (*MaxTimestampNotSynced) XXX_Marshal 

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

func (*MaxTimestampNotSynced) XXX_Merge 

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

func (*MaxTimestampNotSynced) XXX_Size 

func (m *MaxTimestampNotSynced) XXX_Size() int

func (*MaxTimestampNotSynced) XXX_Unmarshal 

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

type MismatchPeerId 

type MismatchPeerId struct {
	RequestPeerId uint64 `protobuf:"varint,1,opt,name=request_peer_id,json=requestPeerId,proto3" json:"request_peer_id,omitempty"`
	StorePeerId   uint64 `protobuf:"varint,2,opt,name=store_peer_id,json=storePeerId,proto3" json:"store_peer_id,omitempty"`
}

MismatchPeerId is the error variant that tells the request is sent to wrong peer. Client receives this error should reload the region info and retry.

func (*MismatchPeerId) Descriptor 

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

func (*MismatchPeerId) GetRequestPeerId 

func (m *MismatchPeerId) GetRequestPeerId() uint64

func (*MismatchPeerId) GetStorePeerId 

func (m *MismatchPeerId) GetStorePeerId() uint64

func (*MismatchPeerId) Marshal 

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

func (*MismatchPeerId) MarshalTo 

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

func (*MismatchPeerId) MarshalToSizedBuffer 

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

func (*MismatchPeerId) ProtoMessage 

func (*MismatchPeerId) ProtoMessage()

func (*MismatchPeerId) Reset 

func (m *MismatchPeerId) Reset()

func (*MismatchPeerId) Size 

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

func (*MismatchPeerId) String 

func (m *MismatchPeerId) String() string

func (*MismatchPeerId) Unmarshal 

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

func (*MismatchPeerId) XXX_DiscardUnknown 

func (m *MismatchPeerId) XXX_DiscardUnknown()

func (*MismatchPeerId) XXX_Marshal 

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

func (*MismatchPeerId) XXX_Merge 

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

func (*MismatchPeerId) XXX_Size 

func (m *MismatchPeerId) XXX_Size() int

func (*MismatchPeerId) XXX_Unmarshal 

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

type NotLeader 

type NotLeader struct {
	// The requested region ID
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	// Region leader of the requested region
	Leader *metapb.Peer `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
}

NotLeader is the error variant that tells a request be handle by raft leader is sent to raft follower or learner.

func (*NotLeader) Descriptor 

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

func (*NotLeader) GetLeader 

func (m *NotLeader) GetLeader() *metapb.Peer

func (*NotLeader) GetRegionId 

func (m *NotLeader) GetRegionId() uint64

func (*NotLeader) Marshal 

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

func (*NotLeader) MarshalTo 

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

func (*NotLeader) MarshalToSizedBuffer 

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

func (*NotLeader) ProtoMessage 

func (*NotLeader) ProtoMessage()

func (*NotLeader) Reset 

func (m *NotLeader) Reset()

func (*NotLeader) Size 

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

func (*NotLeader) String 

func (m *NotLeader) String() string

func (*NotLeader) Unmarshal 

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

func (*NotLeader) XXX_DiscardUnknown 

func (m *NotLeader) XXX_DiscardUnknown()

func (*NotLeader) XXX_Marshal 

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

func (*NotLeader) XXX_Merge 

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

func (*NotLeader) XXX_Size 

func (m *NotLeader) XXX_Size() int

func (*NotLeader) XXX_Unmarshal 

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

type ProposalInMergingMode 

type ProposalInMergingMode struct {
	// The requested region ID
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

ProposalInMergingMode is the error variant that tells the proposal is rejected because raft is in the merging mode. This may happen when BR/Lightning try to ingest SST. This can be retried at most time.

func (*ProposalInMergingMode) Descriptor 

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

func (*ProposalInMergingMode) GetRegionId 

func (m *ProposalInMergingMode) GetRegionId() uint64

func (*ProposalInMergingMode) Marshal 

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

func (*ProposalInMergingMode) MarshalTo 

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

func (*ProposalInMergingMode) MarshalToSizedBuffer 

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

func (*ProposalInMergingMode) ProtoMessage 

func (*ProposalInMergingMode) ProtoMessage()

func (*ProposalInMergingMode) Reset 

func (m *ProposalInMergingMode) Reset()

func (*ProposalInMergingMode) Size 

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

func (*ProposalInMergingMode) String 

func (m *ProposalInMergingMode) String() string

func (*ProposalInMergingMode) Unmarshal 

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

func (*ProposalInMergingMode) XXX_DiscardUnknown 

func (m *ProposalInMergingMode) XXX_DiscardUnknown()

func (*ProposalInMergingMode) XXX_Marshal 

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

func (*ProposalInMergingMode) XXX_Merge 

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

func (*ProposalInMergingMode) XXX_Size 

func (m *ProposalInMergingMode) XXX_Size() int

func (*ProposalInMergingMode) XXX_Unmarshal 

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

type RaftEntryTooLarge 

type RaftEntryTooLarge struct {
	// The requested region ID
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	// Size of the raft entry
	EntrySize uint64 `protobuf:"varint,2,opt,name=entry_size,json=entrySize,proto3" json:"entry_size,omitempty"`
}

RaftEntryTooLarge is the error variant that tells the request is too large to be serialized to a reasonable small raft entry. (i.e. greater than the configured value `raft_entry_max_size` in `raftstore`)

func (*RaftEntryTooLarge) Descriptor 

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

func (*RaftEntryTooLarge) GetEntrySize 

func (m *RaftEntryTooLarge) GetEntrySize() uint64

func (*RaftEntryTooLarge) GetRegionId 

func (m *RaftEntryTooLarge) GetRegionId() uint64

func (*RaftEntryTooLarge) Marshal 

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

func (*RaftEntryTooLarge) MarshalTo 

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

func (*RaftEntryTooLarge) MarshalToSizedBuffer 

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

func (*RaftEntryTooLarge) ProtoMessage 

func (*RaftEntryTooLarge) ProtoMessage()

func (*RaftEntryTooLarge) Reset 

func (m *RaftEntryTooLarge) Reset()

func (*RaftEntryTooLarge) Size 

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

func (*RaftEntryTooLarge) String 

func (m *RaftEntryTooLarge) String() string

func (*RaftEntryTooLarge) Unmarshal 

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

func (*RaftEntryTooLarge) XXX_DiscardUnknown 

func (m *RaftEntryTooLarge) XXX_DiscardUnknown()

func (*RaftEntryTooLarge) XXX_Marshal 

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

func (*RaftEntryTooLarge) XXX_Merge 

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

func (*RaftEntryTooLarge) XXX_Size 

func (m *RaftEntryTooLarge) XXX_Size() int

func (*RaftEntryTooLarge) XXX_Unmarshal 

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

type ReadIndexNotReady 

type ReadIndexNotReady struct {
	// The reason why the region is not ready to serve read index request
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// The requested region ID
	RegionId uint64 `protobuf:"varint,2,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

ReadIndexNotReady is the error variant that tells the read index request is not ready, that is, the current region is in a status that not ready to serve the read index request. For example, region is in splitting or merging status. This can be retried at most time.

func (*ReadIndexNotReady) Descriptor 

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

func (*ReadIndexNotReady) GetReason 

func (m *ReadIndexNotReady) GetReason() string

func (*ReadIndexNotReady) GetRegionId 

func (m *ReadIndexNotReady) GetRegionId() uint64

func (*ReadIndexNotReady) Marshal 

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

func (*ReadIndexNotReady) MarshalTo 

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

func (*ReadIndexNotReady) MarshalToSizedBuffer 

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

func (*ReadIndexNotReady) ProtoMessage 

func (*ReadIndexNotReady) ProtoMessage()

func (*ReadIndexNotReady) Reset 

func (m *ReadIndexNotReady) Reset()

func (*ReadIndexNotReady) Size 

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

func (*ReadIndexNotReady) String 

func (m *ReadIndexNotReady) String() string

func (*ReadIndexNotReady) Unmarshal 

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

func (*ReadIndexNotReady) XXX_DiscardUnknown 

func (m *ReadIndexNotReady) XXX_DiscardUnknown()

func (*ReadIndexNotReady) XXX_Marshal 

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

func (*ReadIndexNotReady) XXX_Merge 

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

func (*ReadIndexNotReady) XXX_Size 

func (m *ReadIndexNotReady) XXX_Size() int

func (*ReadIndexNotReady) XXX_Unmarshal 

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

type RecoveryInProgress 

type RecoveryInProgress struct {
	// The requested region ID
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

func (*RecoveryInProgress) Descriptor 

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

func (*RecoveryInProgress) GetRegionId 

func (m *RecoveryInProgress) GetRegionId() uint64

func (*RecoveryInProgress) Marshal 

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

func (*RecoveryInProgress) MarshalTo 

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

func (*RecoveryInProgress) MarshalToSizedBuffer 

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

func (*RecoveryInProgress) ProtoMessage 

func (*RecoveryInProgress) ProtoMessage()

func (*RecoveryInProgress) Reset 

func (m *RecoveryInProgress) Reset()

func (*RecoveryInProgress) Size 

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

func (*RecoveryInProgress) String 

func (m *RecoveryInProgress) String() string

func (*RecoveryInProgress) Unmarshal 

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

func (*RecoveryInProgress) XXX_DiscardUnknown 

func (m *RecoveryInProgress) XXX_DiscardUnknown()

func (*RecoveryInProgress) XXX_Marshal 

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

func (*RecoveryInProgress) XXX_Merge 

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

func (*RecoveryInProgress) XXX_Size 

func (m *RecoveryInProgress) XXX_Size() int

func (*RecoveryInProgress) XXX_Unmarshal 

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

type RegionNotFound 

type RegionNotFound struct {
	// The requested region ID
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

RegionNotFound is the error variant that tells there isn't any region in this TiKV matches the requested region ID.

func (*RegionNotFound) Descriptor 

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

func (*RegionNotFound) GetRegionId 

func (m *RegionNotFound) GetRegionId() uint64

func (*RegionNotFound) Marshal 

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

func (*RegionNotFound) MarshalTo 

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

func (*RegionNotFound) MarshalToSizedBuffer 

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

func (*RegionNotFound) ProtoMessage 

func (*RegionNotFound) ProtoMessage()

func (*RegionNotFound) Reset 

func (m *RegionNotFound) Reset()

func (*RegionNotFound) Size 

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

func (*RegionNotFound) String 

func (m *RegionNotFound) String() string

func (*RegionNotFound) Unmarshal 

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

func (*RegionNotFound) XXX_DiscardUnknown 

func (m *RegionNotFound) XXX_DiscardUnknown()

func (*RegionNotFound) XXX_Marshal 

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

func (*RegionNotFound) XXX_Merge 

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

func (*RegionNotFound) XXX_Size 

func (m *RegionNotFound) XXX_Size() int

func (*RegionNotFound) XXX_Unmarshal 

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

type RegionNotInitialized 

type RegionNotInitialized struct {
	// The request region ID
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

RegionNotInitialized is the error variant that tells there isn't any initialized peer matchesthe request region ID.

func (*RegionNotInitialized) Descriptor 

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

func (*RegionNotInitialized) GetRegionId 

func (m *RegionNotInitialized) GetRegionId() uint64

func (*RegionNotInitialized) Marshal 

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

func (*RegionNotInitialized) MarshalTo 

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

func (*RegionNotInitialized) MarshalToSizedBuffer 

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

func (*RegionNotInitialized) ProtoMessage 

func (*RegionNotInitialized) ProtoMessage()

func (*RegionNotInitialized) Reset 

func (m *RegionNotInitialized) Reset()

func (*RegionNotInitialized) Size 

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

func (*RegionNotInitialized) String 

func (m *RegionNotInitialized) String() string

func (*RegionNotInitialized) Unmarshal 

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

func (*RegionNotInitialized) XXX_DiscardUnknown 

func (m *RegionNotInitialized) XXX_DiscardUnknown()

func (*RegionNotInitialized) XXX_Marshal 

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

func (*RegionNotInitialized) XXX_Merge 

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

func (*RegionNotInitialized) XXX_Size 

func (m *RegionNotInitialized) XXX_Size() int

func (*RegionNotInitialized) XXX_Unmarshal 

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

type ServerIsBusy 

type ServerIsBusy struct {
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// The suggested backoff time
	BackoffMs       uint64 `protobuf:"varint,2,opt,name=backoff_ms,json=backoffMs,proto3" json:"backoff_ms,omitempty"`
	EstimatedWaitMs uint32 `protobuf:"varint,3,opt,name=estimated_wait_ms,json=estimatedWaitMs,proto3" json:"estimated_wait_ms,omitempty"`
	// Current applied_index at the leader, may be used in replica read.
	AppliedIndex uint64 `protobuf:"varint,4,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
}

ServerIsBusy is the error variant that tells the server is too busy to response.

func (*ServerIsBusy) Descriptor 

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

func (*ServerIsBusy) GetAppliedIndex 

func (m *ServerIsBusy) GetAppliedIndex() uint64

func (*ServerIsBusy) GetBackoffMs 

func (m *ServerIsBusy) GetBackoffMs() uint64

func (*ServerIsBusy) GetEstimatedWaitMs 

func (m *ServerIsBusy) GetEstimatedWaitMs() uint32

func (*ServerIsBusy) GetReason 

func (m *ServerIsBusy) GetReason() string

func (*ServerIsBusy) Marshal 

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

func (*ServerIsBusy) MarshalTo 

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

func (*ServerIsBusy) MarshalToSizedBuffer 

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

func (*ServerIsBusy) ProtoMessage 

func (*ServerIsBusy) ProtoMessage()

func (*ServerIsBusy) Reset 

func (m *ServerIsBusy) Reset()

func (*ServerIsBusy) Size 

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

func (*ServerIsBusy) String 

func (m *ServerIsBusy) String() string

func (*ServerIsBusy) Unmarshal 

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

func (*ServerIsBusy) XXX_DiscardUnknown 

func (m *ServerIsBusy) XXX_DiscardUnknown()

func (*ServerIsBusy) XXX_Marshal 

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

func (*ServerIsBusy) XXX_Merge 

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

func (*ServerIsBusy) XXX_Size 

func (m *ServerIsBusy) XXX_Size() int

func (*ServerIsBusy) XXX_Unmarshal 

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

type StaleCommand 

type StaleCommand struct {
}

StaleCommand is the error variant that tells the command is stale, that is, the current request term is lower than current raft term. This can be retried at most time.

func (*StaleCommand) Descriptor 

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

func (*StaleCommand) Marshal 

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

func (*StaleCommand) MarshalTo 

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

func (*StaleCommand) MarshalToSizedBuffer 

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

func (*StaleCommand) ProtoMessage 

func (*StaleCommand) ProtoMessage()

func (*StaleCommand) Reset 

func (m *StaleCommand) Reset()

func (*StaleCommand) Size 

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

func (*StaleCommand) String 

func (m *StaleCommand) String() string

func (*StaleCommand) Unmarshal 

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

func (*StaleCommand) XXX_DiscardUnknown 

func (m *StaleCommand) XXX_DiscardUnknown()

func (*StaleCommand) XXX_Marshal 

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

func (*StaleCommand) XXX_Merge 

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

func (*StaleCommand) XXX_Size 

func (m *StaleCommand) XXX_Size() int

func (*StaleCommand) XXX_Unmarshal 

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

type StoreNotMatch 

type StoreNotMatch struct {
	// Store id in request
	RequestStoreId uint64 `protobuf:"varint,1,opt,name=request_store_id,json=requestStoreId,proto3" json:"request_store_id,omitempty"`
	// Actual store id
	ActualStoreId uint64 `protobuf:"varint,2,opt,name=actual_store_id,json=actualStoreId,proto3" json:"actual_store_id,omitempty"`
}

StoreNotMatch is the error variant that tells the request is sent to wrong store. (i.e. inconsistency of the store ID that request shows and the real store ID of this server.)

func (*StoreNotMatch) Descriptor 

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

func (*StoreNotMatch) GetActualStoreId 

func (m *StoreNotMatch) GetActualStoreId() uint64

func (*StoreNotMatch) GetRequestStoreId 

func (m *StoreNotMatch) GetRequestStoreId() uint64

func (*StoreNotMatch) Marshal 

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

func (*StoreNotMatch) MarshalTo 

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

func (*StoreNotMatch) MarshalToSizedBuffer 

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

func (*StoreNotMatch) ProtoMessage 

func (*StoreNotMatch) ProtoMessage()

func (*StoreNotMatch) Reset 

func (m *StoreNotMatch) Reset()

func (*StoreNotMatch) Size 

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

func (*StoreNotMatch) String 

func (m *StoreNotMatch) String() string

func (*StoreNotMatch) Unmarshal 

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

func (*StoreNotMatch) XXX_DiscardUnknown 

func (m *StoreNotMatch) XXX_DiscardUnknown()

func (*StoreNotMatch) XXX_Marshal 

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

func (*StoreNotMatch) XXX_Merge 

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

func (*StoreNotMatch) XXX_Size 

func (m *StoreNotMatch) XXX_Size() int

func (*StoreNotMatch) XXX_Unmarshal 

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