errorpb

package
v0.0.0-...-4fa2b26 Latest Latest
Warning

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

Go to latest
Published: Apr 17, 2024 License: Apache-2.0 Imports: 7 Imported by: 934

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

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 */
	XXX_NoUnkeyedLiteral  struct{}               `json:"-"`
	XXX_unrecognized      []byte                 `json:"-"`
	XXX_sizecache         int32                  `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

Jump to

Keyboard shortcuts

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