Documentation ¶
Index ¶
- Variables
- type EpochNotMatch
- func (*EpochNotMatch) Descriptor() ([]byte, []int)
- func (m *EpochNotMatch) GetCurrentRegions() []*metapb.Region
- func (m *EpochNotMatch) Marshal() (dAtA []byte, err error)
- func (m *EpochNotMatch) MarshalTo(dAtA []byte) (int, error)
- func (*EpochNotMatch) ProtoMessage()
- func (m *EpochNotMatch) Reset()
- func (m *EpochNotMatch) Size() (n int)
- func (m *EpochNotMatch) String() string
- func (m *EpochNotMatch) Unmarshal(dAtA []byte) error
- func (m *EpochNotMatch) XXX_DiscardUnknown()
- func (m *EpochNotMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *EpochNotMatch) XXX_Merge(src proto.Message)
- func (m *EpochNotMatch) XXX_Size() int
- func (m *EpochNotMatch) XXX_Unmarshal(b []byte) error
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) GetEpochNotMatch() *EpochNotMatch
- func (m *Error) GetKeyNotInRegion() *KeyNotInRegion
- func (m *Error) GetMessage() string
- func (m *Error) GetNotLeader() *NotLeader
- func (m *Error) GetRegionNotFound() *RegionNotFound
- func (m *Error) GetStaleCommand() *StaleCommand
- func (m *Error) GetStoreNotMatch() *StoreNotMatch
- func (m *Error) Marshal() (dAtA []byte, err error)
- func (m *Error) MarshalTo(dAtA []byte) (int, error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (m *Error) String() string
- func (m *Error) Unmarshal(dAtA []byte) error
- func (m *Error) XXX_DiscardUnknown()
- func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Error) XXX_Merge(src proto.Message)
- func (m *Error) XXX_Size() int
- func (m *Error) XXX_Unmarshal(b []byte) error
- type KeyNotInRegion
- func (*KeyNotInRegion) Descriptor() ([]byte, []int)
- func (m *KeyNotInRegion) GetEndKey() []byte
- func (m *KeyNotInRegion) GetKey() []byte
- func (m *KeyNotInRegion) GetRegionId() uint64
- func (m *KeyNotInRegion) GetStartKey() []byte
- func (m *KeyNotInRegion) Marshal() (dAtA []byte, err error)
- func (m *KeyNotInRegion) MarshalTo(dAtA []byte) (int, error)
- func (*KeyNotInRegion) ProtoMessage()
- func (m *KeyNotInRegion) Reset()
- func (m *KeyNotInRegion) Size() (n int)
- func (m *KeyNotInRegion) String() string
- func (m *KeyNotInRegion) Unmarshal(dAtA []byte) error
- func (m *KeyNotInRegion) XXX_DiscardUnknown()
- func (m *KeyNotInRegion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KeyNotInRegion) XXX_Merge(src proto.Message)
- func (m *KeyNotInRegion) XXX_Size() int
- func (m *KeyNotInRegion) XXX_Unmarshal(b []byte) error
- type NotLeader
- func (*NotLeader) Descriptor() ([]byte, []int)
- func (m *NotLeader) GetLeader() *metapb.Peer
- func (m *NotLeader) GetRegionId() uint64
- func (m *NotLeader) Marshal() (dAtA []byte, err error)
- func (m *NotLeader) MarshalTo(dAtA []byte) (int, error)
- func (*NotLeader) ProtoMessage()
- func (m *NotLeader) Reset()
- func (m *NotLeader) Size() (n int)
- func (m *NotLeader) String() string
- func (m *NotLeader) Unmarshal(dAtA []byte) error
- func (m *NotLeader) XXX_DiscardUnknown()
- func (m *NotLeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *NotLeader) XXX_Merge(src proto.Message)
- func (m *NotLeader) XXX_Size() int
- func (m *NotLeader) XXX_Unmarshal(b []byte) error
- type RegionNotFound
- func (*RegionNotFound) Descriptor() ([]byte, []int)
- func (m *RegionNotFound) GetRegionId() uint64
- func (m *RegionNotFound) Marshal() (dAtA []byte, err error)
- func (m *RegionNotFound) MarshalTo(dAtA []byte) (int, error)
- func (*RegionNotFound) ProtoMessage()
- func (m *RegionNotFound) Reset()
- func (m *RegionNotFound) Size() (n int)
- func (m *RegionNotFound) String() string
- func (m *RegionNotFound) Unmarshal(dAtA []byte) error
- func (m *RegionNotFound) XXX_DiscardUnknown()
- func (m *RegionNotFound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RegionNotFound) XXX_Merge(src proto.Message)
- func (m *RegionNotFound) XXX_Size() int
- func (m *RegionNotFound) XXX_Unmarshal(b []byte) error
- type StaleCommand
- func (*StaleCommand) Descriptor() ([]byte, []int)
- func (m *StaleCommand) Marshal() (dAtA []byte, err error)
- func (m *StaleCommand) MarshalTo(dAtA []byte) (int, error)
- func (*StaleCommand) ProtoMessage()
- func (m *StaleCommand) Reset()
- func (m *StaleCommand) Size() (n int)
- func (m *StaleCommand) String() string
- func (m *StaleCommand) Unmarshal(dAtA []byte) error
- func (m *StaleCommand) XXX_DiscardUnknown()
- func (m *StaleCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StaleCommand) XXX_Merge(src proto.Message)
- func (m *StaleCommand) XXX_Size() int
- func (m *StaleCommand) XXX_Unmarshal(b []byte) error
- type StoreNotMatch
- func (*StoreNotMatch) Descriptor() ([]byte, []int)
- func (m *StoreNotMatch) GetActualStoreId() uint64
- func (m *StoreNotMatch) GetRequestStoreId() uint64
- func (m *StoreNotMatch) Marshal() (dAtA []byte, err error)
- func (m *StoreNotMatch) MarshalTo(dAtA []byte) (int, error)
- func (*StoreNotMatch) ProtoMessage()
- func (m *StoreNotMatch) Reset()
- func (m *StoreNotMatch) Size() (n int)
- func (m *StoreNotMatch) String() string
- func (m *StoreNotMatch) Unmarshal(dAtA []byte) error
- func (m *StoreNotMatch) XXX_DiscardUnknown()
- func (m *StoreNotMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StoreNotMatch) XXX_Merge(src proto.Message)
- func (m *StoreNotMatch) XXX_Size() int
- func (m *StoreNotMatch) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthErrorpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowErrorpb = fmt.Errorf("proto: integer overflow") )
Functions ¶
This section is empty.
Types ¶
type EpochNotMatch ¶
type EpochNotMatch struct { CurrentRegions []*metapb.Region `protobuf:"bytes,1,rep,name=current_regions,json=currentRegions" json:"current_regions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
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) 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 (dst *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 { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` NotLeader *NotLeader `protobuf:"bytes,2,opt,name=not_leader,json=notLeader" json:"not_leader,omitempty"` RegionNotFound *RegionNotFound `protobuf:"bytes,3,opt,name=region_not_found,json=regionNotFound" json:"region_not_found,omitempty"` KeyNotInRegion *KeyNotInRegion `protobuf:"bytes,4,opt,name=key_not_in_region,json=keyNotInRegion" json:"key_not_in_region,omitempty"` EpochNotMatch *EpochNotMatch `protobuf:"bytes,5,opt,name=epoch_not_match,json=epochNotMatch" json:"epoch_not_match,omitempty"` StaleCommand *StaleCommand `protobuf:"bytes,7,opt,name=stale_command,json=staleCommand" json:"stale_command,omitempty"` StoreNotMatch *StoreNotMatch `protobuf:"bytes,8,opt,name=store_not_match,json=storeNotMatch" json:"store_not_match,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Error) Descriptor ¶
func (*Error) GetEpochNotMatch ¶
func (m *Error) GetEpochNotMatch() *EpochNotMatch
func (*Error) GetKeyNotInRegion ¶
func (m *Error) GetKeyNotInRegion() *KeyNotInRegion
func (*Error) GetMessage ¶
func (*Error) GetNotLeader ¶
func (*Error) GetRegionNotFound ¶
func (m *Error) GetRegionNotFound() *RegionNotFound
func (*Error) GetStaleCommand ¶
func (m *Error) GetStaleCommand() *StaleCommand
func (*Error) GetStoreNotMatch ¶
func (m *Error) GetStoreNotMatch() *StoreNotMatch
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) XXX_DiscardUnknown ¶
func (m *Error) XXX_DiscardUnknown()
func (*Error) XXX_Marshal ¶
func (*Error) XXX_Unmarshal ¶
type KeyNotInRegion ¶
type KeyNotInRegion struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` RegionId uint64 `protobuf:"varint,2,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"` StartKey []byte `protobuf:"bytes,3,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"` 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:"-"` }
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) 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 (dst *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 NotLeader ¶
type NotLeader struct { RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"` Leader *metapb.Peer `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NotLeader) Descriptor ¶
func (*NotLeader) GetRegionId ¶
func (*NotLeader) ProtoMessage ¶
func (*NotLeader) ProtoMessage()
func (*NotLeader) XXX_DiscardUnknown ¶
func (m *NotLeader) XXX_DiscardUnknown()
func (*NotLeader) XXX_Marshal ¶
func (*NotLeader) XXX_Unmarshal ¶
type RegionNotFound ¶
type RegionNotFound struct { 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 (*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) 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 (dst *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 StaleCommand ¶
type StaleCommand struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StaleCommand) Descriptor ¶
func (*StaleCommand) Descriptor() ([]byte, []int)
func (*StaleCommand) Marshal ¶
func (m *StaleCommand) Marshal() (dAtA []byte, err 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 (dst *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 { RequestStoreId uint64 `protobuf:"varint,1,opt,name=request_store_id,json=requestStoreId,proto3" json:"request_store_id,omitempty"` 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:"-"` }
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) 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 (dst *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
Click to show internal directories.
Click to hide internal directories.