errorpb

package
v0.0.0-...-3b3056d Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

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 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"`
	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) GetDataIsNotReady 

func (m *Error) GetDataIsNotReady() *DataIsNotReady

func (*Error) GetDiskFull 

func (m *Error) GetDiskFull() *DiskFull

func (*Error) GetEpochNotMatch 

func (m *Error) GetEpochNotMatch() *EpochNotMatch

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) 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 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 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"`
	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) GetBackoffMs 

func (m *ServerIsBusy) GetBackoffMs() uint64

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

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.