kvproto: github.com/pingcap/kvproto/pkg/kvrpcpb Index | Files

package kvrpcpb

import "github.com/pingcap/kvproto/pkg/kvrpcpb"

Index

Package Files

kvrpcpb.pb.go

Variables

var (
    ErrInvalidLengthKvrpcpb = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowKvrpcpb   = fmt.Errorf("proto: integer overflow")
)
var Action_name = map[int32]string{
    0:  "NoAction",
    1:  "TTLExpireRollback",
    2:  "LockNotExistRollback",
    3:  "MinCommitTSPushed",
}
var Action_value = map[string]int32{
    "NoAction":             0,
    "TTLExpireRollback":    1,
    "LockNotExistRollback": 2,
    "MinCommitTSPushed":    3,
}
var Assertion_name = map[int32]string{
    0:  "None",
    1:  "Exist",
    2:  "NotExist",
}
var Assertion_value = map[string]int32{
    "None":     0,
    "Exist":    1,
    "NotExist": 2,
}
var CommandPri_name = map[int32]string{
    0:  "Normal",
    1:  "Low",
    2:  "High",
}
var CommandPri_value = map[string]int32{
    "Normal": 0,
    "Low":    1,
    "High":   2,
}
var ExtraOp_name = map[int32]string{
    0:  "Noop",
    1:  "ReadOldValue",
}
var ExtraOp_value = map[string]int32{
    "Noop":         0,
    "ReadOldValue": 1,
}
var IsolationLevel_name = map[int32]string{
    0:  "SI",
    1:  "RC",
}
var IsolationLevel_value = map[string]int32{
    "SI": 0,
    "RC": 1,
}
var Op_name = map[int32]string{
    0:  "Put",
    1:  "Del",
    2:  "Lock",
    3:  "Rollback",
    4:  "Insert",
    5:  "PessimisticLock",
    6:  "CheckNotExists",
}
var Op_value = map[string]int32{
    "Put":             0,
    "Del":             1,
    "Lock":            2,
    "Rollback":        3,
    "Insert":          4,
    "PessimisticLock": 5,
    "CheckNotExists":  6,
}
var VerOp_name = map[int32]string{
    0:  "VerPut",
    1:  "VerDel",
}
var VerOp_value = map[string]int32{
    "VerPut": 0,
    "VerDel": 1,
}

type Action Uses

type Action int32
const (
    Action_NoAction             Action = 0
    Action_TTLExpireRollback    Action = 1
    Action_LockNotExistRollback Action = 2
    Action_MinCommitTSPushed    Action = 3
)

func (Action) EnumDescriptor Uses

func (Action) EnumDescriptor() ([]byte, []int)

func (Action) String Uses

func (x Action) String() string

type AlreadyExist Uses

type AlreadyExist struct {
    Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*AlreadyExist) Descriptor Uses

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

func (*AlreadyExist) GetKey Uses

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

func (*AlreadyExist) Marshal Uses

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

func (*AlreadyExist) MarshalTo Uses

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

func (*AlreadyExist) ProtoMessage Uses

func (*AlreadyExist) ProtoMessage()

func (*AlreadyExist) Reset Uses

func (m *AlreadyExist) Reset()

func (*AlreadyExist) Size Uses

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

func (*AlreadyExist) String Uses

func (m *AlreadyExist) String() string

func (*AlreadyExist) Unmarshal Uses

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

func (*AlreadyExist) XXX_DiscardUnknown Uses

func (m *AlreadyExist) XXX_DiscardUnknown()

func (*AlreadyExist) XXX_Marshal Uses

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

func (*AlreadyExist) XXX_Merge Uses

func (dst *AlreadyExist) XXX_Merge(src proto.Message)

func (*AlreadyExist) XXX_Size Uses

func (m *AlreadyExist) XXX_Size() int

func (*AlreadyExist) XXX_Unmarshal Uses

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

type Assertion Uses

type Assertion int32
const (
    Assertion_None     Assertion = 0
    Assertion_Exist    Assertion = 1
    Assertion_NotExist Assertion = 2
)

func (Assertion) EnumDescriptor Uses

func (Assertion) EnumDescriptor() ([]byte, []int)

func (Assertion) String Uses

func (x Assertion) String() string

type BatchGetRequest Uses

type BatchGetRequest struct {
    Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    Keys                 [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
    Version              uint64   `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Similar to a `Get` request.

func (*BatchGetRequest) Descriptor Uses

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

func (*BatchGetRequest) GetContext Uses

func (m *BatchGetRequest) GetContext() *Context

func (*BatchGetRequest) GetKeys Uses

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

func (*BatchGetRequest) GetVersion Uses

func (m *BatchGetRequest) GetVersion() uint64

func (*BatchGetRequest) Marshal Uses

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

func (*BatchGetRequest) MarshalTo Uses

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

func (*BatchGetRequest) ProtoMessage Uses

func (*BatchGetRequest) ProtoMessage()

func (*BatchGetRequest) Reset Uses

func (m *BatchGetRequest) Reset()

func (*BatchGetRequest) Size Uses

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

func (*BatchGetRequest) String Uses

func (m *BatchGetRequest) String() string

func (*BatchGetRequest) Unmarshal Uses

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

func (*BatchGetRequest) XXX_DiscardUnknown Uses

func (m *BatchGetRequest) XXX_DiscardUnknown()

func (*BatchGetRequest) XXX_Marshal Uses

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

func (*BatchGetRequest) XXX_Merge Uses

func (dst *BatchGetRequest) XXX_Merge(src proto.Message)

func (*BatchGetRequest) XXX_Size Uses

func (m *BatchGetRequest) XXX_Size() int

func (*BatchGetRequest) XXX_Unmarshal Uses

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

type BatchGetResponse Uses

type BatchGetResponse struct {
    RegionError          *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Pairs                []*KvPair      `protobuf:"bytes,2,rep,name=pairs" json:"pairs,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*BatchGetResponse) Descriptor Uses

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

func (*BatchGetResponse) GetPairs Uses

func (m *BatchGetResponse) GetPairs() []*KvPair

func (*BatchGetResponse) GetRegionError Uses

func (m *BatchGetResponse) GetRegionError() *errorpb.Error

func (*BatchGetResponse) Marshal Uses

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

func (*BatchGetResponse) MarshalTo Uses

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

func (*BatchGetResponse) ProtoMessage Uses

func (*BatchGetResponse) ProtoMessage()

func (*BatchGetResponse) Reset Uses

func (m *BatchGetResponse) Reset()

func (*BatchGetResponse) Size Uses

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

func (*BatchGetResponse) String Uses

func (m *BatchGetResponse) String() string

func (*BatchGetResponse) Unmarshal Uses

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

func (*BatchGetResponse) XXX_DiscardUnknown Uses

func (m *BatchGetResponse) XXX_DiscardUnknown()

func (*BatchGetResponse) XXX_Marshal Uses

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

func (*BatchGetResponse) XXX_Merge Uses

func (dst *BatchGetResponse) XXX_Merge(src proto.Message)

func (*BatchGetResponse) XXX_Size Uses

func (m *BatchGetResponse) XXX_Size() int

func (*BatchGetResponse) XXX_Unmarshal Uses

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

type BatchRollbackRequest Uses

type BatchRollbackRequest struct {
    Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    // Identify the transaction to be rolled back.
    StartVersion uint64 `protobuf:"varint,2,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
    // The keys to rollback.
    Keys                 [][]byte `protobuf:"bytes,3,rep,name=keys" json:"keys,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Rollback a prewritten transaction. This will remove the preliminary data from the database, unlock locks, and leave a rollback tombstone.

func (*BatchRollbackRequest) Descriptor Uses

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

func (*BatchRollbackRequest) GetContext Uses

func (m *BatchRollbackRequest) GetContext() *Context

func (*BatchRollbackRequest) GetKeys Uses

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

func (*BatchRollbackRequest) GetStartVersion Uses

func (m *BatchRollbackRequest) GetStartVersion() uint64

func (*BatchRollbackRequest) Marshal Uses

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

func (*BatchRollbackRequest) MarshalTo Uses

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

func (*BatchRollbackRequest) ProtoMessage Uses

func (*BatchRollbackRequest) ProtoMessage()

func (*BatchRollbackRequest) Reset Uses

func (m *BatchRollbackRequest) Reset()

func (*BatchRollbackRequest) Size Uses

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

func (*BatchRollbackRequest) String Uses

func (m *BatchRollbackRequest) String() string

func (*BatchRollbackRequest) Unmarshal Uses

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

func (*BatchRollbackRequest) XXX_DiscardUnknown Uses

func (m *BatchRollbackRequest) XXX_DiscardUnknown()

func (*BatchRollbackRequest) XXX_Marshal Uses

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

func (*BatchRollbackRequest) XXX_Merge Uses

func (dst *BatchRollbackRequest) XXX_Merge(src proto.Message)

func (*BatchRollbackRequest) XXX_Size Uses

func (m *BatchRollbackRequest) XXX_Size() int

func (*BatchRollbackRequest) XXX_Unmarshal Uses

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

type BatchRollbackResponse Uses

type BatchRollbackResponse struct {
    RegionError          *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Error                *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*BatchRollbackResponse) Descriptor Uses

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

func (*BatchRollbackResponse) GetError Uses

func (m *BatchRollbackResponse) GetError() *KeyError

func (*BatchRollbackResponse) GetRegionError Uses

func (m *BatchRollbackResponse) GetRegionError() *errorpb.Error

func (*BatchRollbackResponse) Marshal Uses

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

func (*BatchRollbackResponse) MarshalTo Uses

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

func (*BatchRollbackResponse) ProtoMessage Uses

func (*BatchRollbackResponse) ProtoMessage()

func (*BatchRollbackResponse) Reset Uses

func (m *BatchRollbackResponse) Reset()

func (*BatchRollbackResponse) Size Uses

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

func (*BatchRollbackResponse) String Uses

func (m *BatchRollbackResponse) String() string

func (*BatchRollbackResponse) Unmarshal Uses

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

func (*BatchRollbackResponse) XXX_DiscardUnknown Uses

func (m *BatchRollbackResponse) XXX_DiscardUnknown()

func (*BatchRollbackResponse) XXX_Marshal Uses

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

func (*BatchRollbackResponse) XXX_Merge Uses

func (dst *BatchRollbackResponse) XXX_Merge(src proto.Message)

func (*BatchRollbackResponse) XXX_Size Uses

func (m *BatchRollbackResponse) XXX_Size() int

func (*BatchRollbackResponse) XXX_Unmarshal Uses

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

type CheckLockObserverRequest Uses

type CheckLockObserverRequest struct {
    Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    MaxTs                uint64   `protobuf:"varint,2,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*CheckLockObserverRequest) Descriptor Uses

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

func (*CheckLockObserverRequest) GetContext Uses

func (m *CheckLockObserverRequest) GetContext() *Context

func (*CheckLockObserverRequest) GetMaxTs Uses

func (m *CheckLockObserverRequest) GetMaxTs() uint64

func (*CheckLockObserverRequest) Marshal Uses

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

func (*CheckLockObserverRequest) MarshalTo Uses

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

func (*CheckLockObserverRequest) ProtoMessage Uses

func (*CheckLockObserverRequest) ProtoMessage()

func (*CheckLockObserverRequest) Reset Uses

func (m *CheckLockObserverRequest) Reset()

func (*CheckLockObserverRequest) Size Uses

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

func (*CheckLockObserverRequest) String Uses

func (m *CheckLockObserverRequest) String() string

func (*CheckLockObserverRequest) Unmarshal Uses

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

func (*CheckLockObserverRequest) XXX_DiscardUnknown Uses

func (m *CheckLockObserverRequest) XXX_DiscardUnknown()

func (*CheckLockObserverRequest) XXX_Marshal Uses

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

func (*CheckLockObserverRequest) XXX_Merge Uses

func (dst *CheckLockObserverRequest) XXX_Merge(src proto.Message)

func (*CheckLockObserverRequest) XXX_Size Uses

func (m *CheckLockObserverRequest) XXX_Size() int

func (*CheckLockObserverRequest) XXX_Unmarshal Uses

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

type CheckLockObserverResponse Uses

type CheckLockObserverResponse struct {
    Error                string      `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
    IsClean              bool        `protobuf:"varint,2,opt,name=is_clean,json=isClean,proto3" json:"is_clean,omitempty"`
    Locks                []*LockInfo `protobuf:"bytes,3,rep,name=locks" json:"locks,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

func (*CheckLockObserverResponse) Descriptor Uses

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

func (*CheckLockObserverResponse) GetError Uses

func (m *CheckLockObserverResponse) GetError() string

func (*CheckLockObserverResponse) GetIsClean Uses

func (m *CheckLockObserverResponse) GetIsClean() bool

func (*CheckLockObserverResponse) GetLocks Uses

func (m *CheckLockObserverResponse) GetLocks() []*LockInfo

func (*CheckLockObserverResponse) Marshal Uses

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

func (*CheckLockObserverResponse) MarshalTo Uses

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

func (*CheckLockObserverResponse) ProtoMessage Uses

func (*CheckLockObserverResponse) ProtoMessage()

func (*CheckLockObserverResponse) Reset Uses

func (m *CheckLockObserverResponse) Reset()

func (*CheckLockObserverResponse) Size Uses

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

func (*CheckLockObserverResponse) String Uses

func (m *CheckLockObserverResponse) String() string

func (*CheckLockObserverResponse) Unmarshal Uses

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

func (*CheckLockObserverResponse) XXX_DiscardUnknown Uses

func (m *CheckLockObserverResponse) XXX_DiscardUnknown()

func (*CheckLockObserverResponse) XXX_Marshal Uses

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

func (*CheckLockObserverResponse) XXX_Merge Uses

func (dst *CheckLockObserverResponse) XXX_Merge(src proto.Message)

func (*CheckLockObserverResponse) XXX_Size Uses

func (m *CheckLockObserverResponse) XXX_Size() int

func (*CheckLockObserverResponse) XXX_Unmarshal Uses

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

type CheckSecondaryLocksRequest Uses

type CheckSecondaryLocksRequest struct {
    Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    Keys    [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
    // Identifies the transaction we are investigating.
    StartVersion         uint64   `protobuf:"varint,3,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Part of the async commit protocol, checks for locks on all supplied keys. If a lock is missing, does not have a successful status, or belongs to another transaction, TiKV will leave a rollback tombstone for that key.

func (*CheckSecondaryLocksRequest) Descriptor Uses

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

func (*CheckSecondaryLocksRequest) GetContext Uses

func (m *CheckSecondaryLocksRequest) GetContext() *Context

func (*CheckSecondaryLocksRequest) GetKeys Uses

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

func (*CheckSecondaryLocksRequest) GetStartVersion Uses

func (m *CheckSecondaryLocksRequest) GetStartVersion() uint64

func (*CheckSecondaryLocksRequest) Marshal Uses

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

func (*CheckSecondaryLocksRequest) MarshalTo Uses

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

func (*CheckSecondaryLocksRequest) ProtoMessage Uses

func (*CheckSecondaryLocksRequest) ProtoMessage()

func (*CheckSecondaryLocksRequest) Reset Uses

func (m *CheckSecondaryLocksRequest) Reset()

func (*CheckSecondaryLocksRequest) Size Uses

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

func (*CheckSecondaryLocksRequest) String Uses

func (m *CheckSecondaryLocksRequest) String() string

func (*CheckSecondaryLocksRequest) Unmarshal Uses

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

func (*CheckSecondaryLocksRequest) XXX_DiscardUnknown Uses

func (m *CheckSecondaryLocksRequest) XXX_DiscardUnknown()

func (*CheckSecondaryLocksRequest) XXX_Marshal Uses

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

func (*CheckSecondaryLocksRequest) XXX_Merge Uses

func (dst *CheckSecondaryLocksRequest) XXX_Merge(src proto.Message)

func (*CheckSecondaryLocksRequest) XXX_Size Uses

func (m *CheckSecondaryLocksRequest) XXX_Size() int

func (*CheckSecondaryLocksRequest) XXX_Unmarshal Uses

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

type CheckSecondaryLocksResponse Uses

type CheckSecondaryLocksResponse struct {
    RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Error       *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
    // For each key in `keys` in `CheckSecondaryLocks`, there will be a lock in
    // this list if there is a lock present and belonging to the correct transaction,
    // nil otherwise.
    Locks []*LockInfo `protobuf:"bytes,3,rep,name=locks" json:"locks,omitempty"`
    // If any of the locks have been committed, this is the commit ts used. If no
    // locks have been committed, it will be zero.
    CommitTs             uint64   `protobuf:"varint,4,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*CheckSecondaryLocksResponse) Descriptor Uses

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

func (*CheckSecondaryLocksResponse) GetCommitTs Uses

func (m *CheckSecondaryLocksResponse) GetCommitTs() uint64

func (*CheckSecondaryLocksResponse) GetError Uses

func (m *CheckSecondaryLocksResponse) GetError() *KeyError

func (*CheckSecondaryLocksResponse) GetLocks Uses

func (m *CheckSecondaryLocksResponse) GetLocks() []*LockInfo

func (*CheckSecondaryLocksResponse) GetRegionError Uses

func (m *CheckSecondaryLocksResponse) GetRegionError() *errorpb.Error

func (*CheckSecondaryLocksResponse) Marshal Uses

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

func (*CheckSecondaryLocksResponse) MarshalTo Uses

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

func (*CheckSecondaryLocksResponse) ProtoMessage Uses

func (*CheckSecondaryLocksResponse) ProtoMessage()

func (*CheckSecondaryLocksResponse) Reset Uses

func (m *CheckSecondaryLocksResponse) Reset()

func (*CheckSecondaryLocksResponse) Size Uses

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

func (*CheckSecondaryLocksResponse) String Uses

func (m *CheckSecondaryLocksResponse) String() string

func (*CheckSecondaryLocksResponse) Unmarshal Uses

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

func (*CheckSecondaryLocksResponse) XXX_DiscardUnknown Uses

func (m *CheckSecondaryLocksResponse) XXX_DiscardUnknown()

func (*CheckSecondaryLocksResponse) XXX_Marshal Uses

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

func (*CheckSecondaryLocksResponse) XXX_Merge Uses

func (dst *CheckSecondaryLocksResponse) XXX_Merge(src proto.Message)

func (*CheckSecondaryLocksResponse) XXX_Size Uses

func (m *CheckSecondaryLocksResponse) XXX_Size() int

func (*CheckSecondaryLocksResponse) XXX_Unmarshal Uses

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

type CheckTxnStatusRequest Uses

type CheckTxnStatusRequest struct {
    Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    // Primary key and lock ts together to locate the primary lock of a transaction.
    PrimaryKey []byte `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
    // Starting timestamp of the transaction being checked.
    LockTs uint64 `protobuf:"varint,3,opt,name=lock_ts,json=lockTs,proto3" json:"lock_ts,omitempty"`
    // The start timestamp of the transaction which this request is part of.
    CallerStartTs uint64 `protobuf:"varint,4,opt,name=caller_start_ts,json=callerStartTs,proto3" json:"caller_start_ts,omitempty"`
    // The client must specify the current time to TiKV using this timestamp. It is used to check TTL
    // timeouts. It may be inaccurate.
    CurrentTs uint64 `protobuf:"varint,5,opt,name=current_ts,json=currentTs,proto3" json:"current_ts,omitempty"`
    // If true, then TiKV will leave a rollback tombstone in the write CF for `primary_key`, even if
    // that key is not locked.
    RollbackIfNotExist   bool     `protobuf:"varint,6,opt,name=rollback_if_not_exist,json=rollbackIfNotExist,proto3" json:"rollback_if_not_exist,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

CheckTxnStatusRequest checks the status of a transaction. If the transaction is rollbacked/committed, return that result. If the TTL of the transaction is exhausted, abort that transaction and inform the caller. Otherwise, returns the TTL information for the transaction. CheckTxnStatusRequest may also push forward the minCommitTS of a large transaction.

func (*CheckTxnStatusRequest) Descriptor Uses

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

func (*CheckTxnStatusRequest) GetCallerStartTs Uses

func (m *CheckTxnStatusRequest) GetCallerStartTs() uint64

func (*CheckTxnStatusRequest) GetContext Uses

func (m *CheckTxnStatusRequest) GetContext() *Context

func (*CheckTxnStatusRequest) GetCurrentTs Uses

func (m *CheckTxnStatusRequest) GetCurrentTs() uint64

func (*CheckTxnStatusRequest) GetLockTs Uses

func (m *CheckTxnStatusRequest) GetLockTs() uint64

func (*CheckTxnStatusRequest) GetPrimaryKey Uses

func (m *CheckTxnStatusRequest) GetPrimaryKey() []byte

func (*CheckTxnStatusRequest) GetRollbackIfNotExist Uses

func (m *CheckTxnStatusRequest) GetRollbackIfNotExist() bool

func (*CheckTxnStatusRequest) Marshal Uses

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

func (*CheckTxnStatusRequest) MarshalTo Uses

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

func (*CheckTxnStatusRequest) ProtoMessage Uses

func (*CheckTxnStatusRequest) ProtoMessage()

func (*CheckTxnStatusRequest) Reset Uses

func (m *CheckTxnStatusRequest) Reset()

func (*CheckTxnStatusRequest) Size Uses

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

func (*CheckTxnStatusRequest) String Uses

func (m *CheckTxnStatusRequest) String() string

func (*CheckTxnStatusRequest) Unmarshal Uses

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

func (*CheckTxnStatusRequest) XXX_DiscardUnknown Uses

func (m *CheckTxnStatusRequest) XXX_DiscardUnknown()

func (*CheckTxnStatusRequest) XXX_Marshal Uses

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

func (*CheckTxnStatusRequest) XXX_Merge Uses

func (dst *CheckTxnStatusRequest) XXX_Merge(src proto.Message)

func (*CheckTxnStatusRequest) XXX_Size Uses

func (m *CheckTxnStatusRequest) XXX_Size() int

func (*CheckTxnStatusRequest) XXX_Unmarshal Uses

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

type CheckTxnStatusResponse Uses

type CheckTxnStatusResponse struct {
    RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Error       *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
    // Three kinds of transaction status:
    //   locked: lock_ttl > 0
    //   committed: commit_version > 0
    //   rollbacked: lock_ttl = 0 && commit_version = 0
    LockTtl       uint64 `protobuf:"varint,3,opt,name=lock_ttl,json=lockTtl,proto3" json:"lock_ttl,omitempty"`
    CommitVersion uint64 `protobuf:"varint,4,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
    // The action performed by TiKV (and why if the action is to rollback).
    Action               Action    `protobuf:"varint,5,opt,name=action,proto3,enum=kvrpcpb.Action" json:"action,omitempty"`
    LockInfo             *LockInfo `protobuf:"bytes,6,opt,name=lock_info,json=lockInfo" json:"lock_info,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*CheckTxnStatusResponse) Descriptor Uses

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

func (*CheckTxnStatusResponse) GetAction Uses

func (m *CheckTxnStatusResponse) GetAction() Action

func (*CheckTxnStatusResponse) GetCommitVersion Uses

func (m *CheckTxnStatusResponse) GetCommitVersion() uint64

func (*CheckTxnStatusResponse) GetError Uses

func (m *CheckTxnStatusResponse) GetError() *KeyError

func (*CheckTxnStatusResponse) GetLockInfo Uses

func (m *CheckTxnStatusResponse) GetLockInfo() *LockInfo

func (*CheckTxnStatusResponse) GetLockTtl Uses

func (m *CheckTxnStatusResponse) GetLockTtl() uint64

func (*CheckTxnStatusResponse) GetRegionError Uses

func (m *CheckTxnStatusResponse) GetRegionError() *errorpb.Error

func (*CheckTxnStatusResponse) Marshal Uses

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

func (*CheckTxnStatusResponse) MarshalTo Uses

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

func (*CheckTxnStatusResponse) ProtoMessage Uses

func (*CheckTxnStatusResponse) ProtoMessage()

func (*CheckTxnStatusResponse) Reset Uses

func (m *CheckTxnStatusResponse) Reset()

func (*CheckTxnStatusResponse) Size Uses

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

func (*CheckTxnStatusResponse) String Uses

func (m *CheckTxnStatusResponse) String() string

func (*CheckTxnStatusResponse) Unmarshal Uses

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

func (*CheckTxnStatusResponse) XXX_DiscardUnknown Uses

func (m *CheckTxnStatusResponse) XXX_DiscardUnknown()

func (*CheckTxnStatusResponse) XXX_Marshal Uses

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

func (*CheckTxnStatusResponse) XXX_Merge Uses

func (dst *CheckTxnStatusResponse) XXX_Merge(src proto.Message)

func (*CheckTxnStatusResponse) XXX_Size Uses

func (m *CheckTxnStatusResponse) XXX_Size() int

func (*CheckTxnStatusResponse) XXX_Unmarshal Uses

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

type CleanupRequest Uses

type CleanupRequest struct {
    Context      *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    Key          []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
    StartVersion uint64   `protobuf:"varint,3,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
    // The current timestamp, used in combination with a lock's TTL to determine
    // if the lock has expired. If `current_ts == 0`, then the key will be unlocked
    // irrespective of its TTL.
    CurrentTs            uint64   `protobuf:"varint,4,opt,name=current_ts,json=currentTs,proto3" json:"current_ts,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Cleanup a key by possibly unlocking it. From 4.0 onwards, this message is no longer used.

func (*CleanupRequest) Descriptor Uses

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

func (*CleanupRequest) GetContext Uses

func (m *CleanupRequest) GetContext() *Context

func (*CleanupRequest) GetCurrentTs Uses

func (m *CleanupRequest) GetCurrentTs() uint64

func (*CleanupRequest) GetKey Uses

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

func (*CleanupRequest) GetStartVersion Uses

func (m *CleanupRequest) GetStartVersion() uint64

func (*CleanupRequest) Marshal Uses

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

func (*CleanupRequest) MarshalTo Uses

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

func (*CleanupRequest) ProtoMessage Uses

func (*CleanupRequest) ProtoMessage()

func (*CleanupRequest) Reset Uses

func (m *CleanupRequest) Reset()

func (*CleanupRequest) Size Uses

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

func (*CleanupRequest) String Uses

func (m *CleanupRequest) String() string

func (*CleanupRequest) Unmarshal Uses

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

func (*CleanupRequest) XXX_DiscardUnknown Uses

func (m *CleanupRequest) XXX_DiscardUnknown()

func (*CleanupRequest) XXX_Marshal Uses

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

func (*CleanupRequest) XXX_Merge Uses

func (dst *CleanupRequest) XXX_Merge(src proto.Message)

func (*CleanupRequest) XXX_Size Uses

func (m *CleanupRequest) XXX_Size() int

func (*CleanupRequest) XXX_Unmarshal Uses

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

type CleanupResponse Uses

type CleanupResponse struct {
    RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Error       *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
    // Set if the key is already committed.
    CommitVersion        uint64   `protobuf:"varint,3,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*CleanupResponse) Descriptor Uses

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

func (*CleanupResponse) GetCommitVersion Uses

func (m *CleanupResponse) GetCommitVersion() uint64

func (*CleanupResponse) GetError Uses

func (m *CleanupResponse) GetError() *KeyError

func (*CleanupResponse) GetRegionError Uses

func (m *CleanupResponse) GetRegionError() *errorpb.Error

func (*CleanupResponse) Marshal Uses

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

func (*CleanupResponse) MarshalTo Uses

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

func (*CleanupResponse) ProtoMessage Uses

func (*CleanupResponse) ProtoMessage()

func (*CleanupResponse) Reset Uses

func (m *CleanupResponse) Reset()

func (*CleanupResponse) Size Uses

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

func (*CleanupResponse) String Uses

func (m *CleanupResponse) String() string

func (*CleanupResponse) Unmarshal Uses

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

func (*CleanupResponse) XXX_DiscardUnknown Uses

func (m *CleanupResponse) XXX_DiscardUnknown()

func (*CleanupResponse) XXX_Marshal Uses

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

func (*CleanupResponse) XXX_Merge Uses

func (dst *CleanupResponse) XXX_Merge(src proto.Message)

func (*CleanupResponse) XXX_Size Uses

func (m *CleanupResponse) XXX_Size() int

func (*CleanupResponse) XXX_Unmarshal Uses

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

type CommandPri Uses

type CommandPri int32
const (
    CommandPri_Normal CommandPri = 0
    CommandPri_Low    CommandPri = 1
    CommandPri_High   CommandPri = 2
)

func (CommandPri) EnumDescriptor Uses

func (CommandPri) EnumDescriptor() ([]byte, []int)

func (CommandPri) String Uses

func (x CommandPri) String() string

type CommitRequest Uses

type CommitRequest struct {
    Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    // Identifies the transaction.
    StartVersion uint64 `protobuf:"varint,2,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
    // All keys in the transaction (to be committed).
    Keys [][]byte `protobuf:"bytes,3,rep,name=keys" json:"keys,omitempty"`
    // Timestamp for the end of the transaction. Must be greater than `start_version`.
    CommitVersion        uint64   `protobuf:"varint,4,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

The second phase of writing to TiKV. If there are no errors or conflicts, then this request commits a transaction so that its data can be read by other transactions.

func (*CommitRequest) Descriptor Uses

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

func (*CommitRequest) GetCommitVersion Uses

func (m *CommitRequest) GetCommitVersion() uint64

func (*CommitRequest) GetContext Uses

func (m *CommitRequest) GetContext() *Context

func (*CommitRequest) GetKeys Uses

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

func (*CommitRequest) GetStartVersion Uses

func (m *CommitRequest) GetStartVersion() uint64

func (*CommitRequest) Marshal Uses

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

func (*CommitRequest) MarshalTo Uses

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

func (*CommitRequest) ProtoMessage Uses

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) Reset Uses

func (m *CommitRequest) Reset()

func (*CommitRequest) Size Uses

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

func (*CommitRequest) String Uses

func (m *CommitRequest) String() string

func (*CommitRequest) Unmarshal Uses

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

func (*CommitRequest) XXX_DiscardUnknown Uses

func (m *CommitRequest) XXX_DiscardUnknown()

func (*CommitRequest) XXX_Marshal Uses

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

func (*CommitRequest) XXX_Merge Uses

func (dst *CommitRequest) XXX_Merge(src proto.Message)

func (*CommitRequest) XXX_Size Uses

func (m *CommitRequest) XXX_Size() int

func (*CommitRequest) XXX_Unmarshal Uses

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

type CommitResponse Uses

type CommitResponse struct {
    RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Error       *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
    // If the commit ts is derived from min_commit_ts, this field should be set.
    CommitVersion        uint64   `protobuf:"varint,3,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*CommitResponse) Descriptor Uses

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

func (*CommitResponse) GetCommitVersion Uses

func (m *CommitResponse) GetCommitVersion() uint64

func (*CommitResponse) GetError Uses

func (m *CommitResponse) GetError() *KeyError

func (*CommitResponse) GetRegionError Uses

func (m *CommitResponse) GetRegionError() *errorpb.Error

func (*CommitResponse) Marshal Uses

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

func (*CommitResponse) MarshalTo Uses

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

func (*CommitResponse) ProtoMessage Uses

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) Reset Uses

func (m *CommitResponse) Reset()

func (*CommitResponse) Size Uses

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

func (*CommitResponse) String Uses

func (m *CommitResponse) String() string

func (*CommitResponse) Unmarshal Uses

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

func (*CommitResponse) XXX_DiscardUnknown Uses

func (m *CommitResponse) XXX_DiscardUnknown()

func (*CommitResponse) XXX_Marshal Uses

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

func (*CommitResponse) XXX_Merge Uses

func (dst *CommitResponse) XXX_Merge(src proto.Message)

func (*CommitResponse) XXX_Size Uses

func (m *CommitResponse) XXX_Size() int

func (*CommitResponse) XXX_Unmarshal Uses

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

type CommitTsExpired Uses

type CommitTsExpired struct {
    StartTs              uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
    AttemptedCommitTs    uint64   `protobuf:"varint,2,opt,name=attempted_commit_ts,json=attemptedCommitTs,proto3" json:"attempted_commit_ts,omitempty"`
    Key                  []byte   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
    MinCommitTs          uint64   `protobuf:"varint,4,opt,name=min_commit_ts,json=minCommitTs,proto3" json:"min_commit_ts,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*CommitTsExpired) Descriptor Uses

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

func (*CommitTsExpired) GetAttemptedCommitTs Uses

func (m *CommitTsExpired) GetAttemptedCommitTs() uint64

func (*CommitTsExpired) GetKey Uses

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

func (*CommitTsExpired) GetMinCommitTs Uses

func (m *CommitTsExpired) GetMinCommitTs() uint64

func (*CommitTsExpired) GetStartTs Uses

func (m *CommitTsExpired) GetStartTs() uint64

func (*CommitTsExpired) Marshal Uses

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

func (*CommitTsExpired) MarshalTo Uses

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

func (*CommitTsExpired) ProtoMessage Uses

func (*CommitTsExpired) ProtoMessage()

func (*CommitTsExpired) Reset Uses

func (m *CommitTsExpired) Reset()

func (*CommitTsExpired) Size Uses

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

func (*CommitTsExpired) String Uses

func (m *CommitTsExpired) String() string

func (*CommitTsExpired) Unmarshal Uses

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

func (*CommitTsExpired) XXX_DiscardUnknown Uses

func (m *CommitTsExpired) XXX_DiscardUnknown()

func (*CommitTsExpired) XXX_Marshal Uses

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

func (*CommitTsExpired) XXX_Merge Uses

func (dst *CommitTsExpired) XXX_Merge(src proto.Message)

func (*CommitTsExpired) XXX_Size Uses

func (m *CommitTsExpired) XXX_Size() int

func (*CommitTsExpired) XXX_Unmarshal Uses

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

type Context Uses

type Context struct {
    RegionId       uint64              `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
    RegionEpoch    *metapb.RegionEpoch `protobuf:"bytes,2,opt,name=region_epoch,json=regionEpoch" json:"region_epoch,omitempty"`
    Peer           *metapb.Peer        `protobuf:"bytes,3,opt,name=peer" json:"peer,omitempty"`
    Term           uint64              `protobuf:"varint,5,opt,name=term,proto3" json:"term,omitempty"`
    Priority       CommandPri          `protobuf:"varint,6,opt,name=priority,proto3,enum=kvrpcpb.CommandPri" json:"priority,omitempty"`
    IsolationLevel IsolationLevel      `protobuf:"varint,7,opt,name=isolation_level,json=isolationLevel,proto3,enum=kvrpcpb.IsolationLevel" json:"isolation_level,omitempty"`
    NotFillCache   bool                `protobuf:"varint,8,opt,name=not_fill_cache,json=notFillCache,proto3" json:"not_fill_cache,omitempty"`
    SyncLog        bool                `protobuf:"varint,9,opt,name=sync_log,json=syncLog,proto3" json:"sync_log,omitempty"`
    // True means return handle time detail.
    HandleTime bool `protobuf:"varint,10,opt,name=handle_time,json=handleTime,proto3" json:"handle_time,omitempty"`
    // True means return scan cf's detail.
    ScanDetail             bool     `protobuf:"varint,11,opt,name=scan_detail,json=scanDetail,proto3" json:"scan_detail,omitempty"`
    ReplicaRead            bool     `protobuf:"varint,12,opt,name=replica_read,json=replicaRead,proto3" json:"replica_read,omitempty"`
    ResolvedLocks          []uint64 `protobuf:"varint,13,rep,packed,name=resolved_locks,json=resolvedLocks" json:"resolved_locks,omitempty"`
    MaxExecutionDurationMs uint64   `protobuf:"varint,14,opt,name=max_execution_duration_ms,json=maxExecutionDurationMs,proto3" json:"max_execution_duration_ms,omitempty"`
    // After a region applies to `applied_index`, we can get a
    // snapshot for the region even if the peer is a follower.
    AppliedIndex uint64 `protobuf:"varint,15,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
    // A hint for TiKV to schedule tasks more fairly. Query with same task ID
    // may share same priority and resource quota.
    TaskId               uint64   `protobuf:"varint,16,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Miscellaneous metadata attached to most requests.

func (*Context) Descriptor Uses

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

func (*Context) GetAppliedIndex Uses

func (m *Context) GetAppliedIndex() uint64

func (*Context) GetHandleTime Uses

func (m *Context) GetHandleTime() bool

func (*Context) GetIsolationLevel Uses

func (m *Context) GetIsolationLevel() IsolationLevel

func (*Context) GetMaxExecutionDurationMs Uses

func (m *Context) GetMaxExecutionDurationMs() uint64

func (*Context) GetNotFillCache Uses

func (m *Context) GetNotFillCache() bool

func (*Context) GetPeer Uses

func (m *Context) GetPeer() *metapb.Peer

func (*Context) GetPriority Uses

func (m *Context) GetPriority() CommandPri

func (*Context) GetRegionEpoch Uses

func (m *Context) GetRegionEpoch() *metapb.RegionEpoch

func (*Context) GetRegionId Uses

func (m *Context) GetRegionId() uint64

func (*Context) GetReplicaRead Uses

func (m *Context) GetReplicaRead() bool

func (*Context) GetResolvedLocks Uses

func (m *Context) GetResolvedLocks() []uint64

func (*Context) GetScanDetail Uses

func (m *Context) GetScanDetail() bool

func (*Context) GetSyncLog Uses

func (m *Context) GetSyncLog() bool

func (*Context) GetTaskId Uses

func (m *Context) GetTaskId() uint64

func (*Context) GetTerm Uses

func (m *Context) GetTerm() uint64

func (*Context) Marshal Uses

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

func (*Context) MarshalTo Uses

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

func (*Context) ProtoMessage Uses

func (*Context) ProtoMessage()

func (*Context) Reset Uses

func (m *Context) Reset()

func (*Context) Size Uses

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

func (*Context) String Uses

func (m *Context) String() string

func (*Context) Unmarshal Uses

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

func (*Context) XXX_DiscardUnknown Uses

func (m *Context) XXX_DiscardUnknown()

func (*Context) XXX_Marshal Uses

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

func (*Context) XXX_Merge Uses

func (dst *Context) XXX_Merge(src proto.Message)

func (*Context) XXX_Size Uses

func (m *Context) XXX_Size() int

func (*Context) XXX_Unmarshal Uses

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

type Deadlock Uses

type Deadlock struct {
    LockTs               uint64   `protobuf:"varint,1,opt,name=lock_ts,json=lockTs,proto3" json:"lock_ts,omitempty"`
    LockKey              []byte   `protobuf:"bytes,2,opt,name=lock_key,json=lockKey,proto3" json:"lock_key,omitempty"`
    DeadlockKeyHash      uint64   `protobuf:"varint,3,opt,name=deadlock_key_hash,json=deadlockKeyHash,proto3" json:"deadlock_key_hash,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Deadlock) Descriptor Uses

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

func (*Deadlock) GetDeadlockKeyHash Uses

func (m *Deadlock) GetDeadlockKeyHash() uint64

func (*Deadlock) GetLockKey Uses

func (m *Deadlock) GetLockKey() []byte

func (*Deadlock) GetLockTs Uses

func (m *Deadlock) GetLockTs() uint64

func (*Deadlock) Marshal Uses

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

func (*Deadlock) MarshalTo Uses

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

func (*Deadlock) ProtoMessage Uses

func (*Deadlock) ProtoMessage()

func (*Deadlock) Reset Uses

func (m *Deadlock) Reset()

func (*Deadlock) Size Uses

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

func (*Deadlock) String Uses

func (m *Deadlock) String() string

func (*Deadlock) Unmarshal Uses

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

func (*Deadlock) XXX_DiscardUnknown Uses

func (m *Deadlock) XXX_DiscardUnknown()

func (*Deadlock) XXX_Marshal Uses

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

func (*Deadlock) XXX_Merge Uses

func (dst *Deadlock) XXX_Merge(src proto.Message)

func (*Deadlock) XXX_Size Uses

func (m *Deadlock) XXX_Size() int

func (*Deadlock) XXX_Unmarshal Uses

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

type DeleteRangeRequest Uses

type DeleteRangeRequest struct {
    Context  *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    StartKey []byte   `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
    EndKey   []byte   `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
    // If true, the data will not be immediately deleted, but the operation will
    // still be replicated via Raft. This is used to notify TiKV that the data
    // will be deleted using `unsafe_destroy_range` soon.
    NotifyOnly           bool     `protobuf:"varint,4,opt,name=notify_only,json=notifyOnly,proto3" json:"notify_only,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Delete a range of data from TiKV. This message should not be used.

func (*DeleteRangeRequest) Descriptor Uses

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

func (*DeleteRangeRequest) GetContext Uses

func (m *DeleteRangeRequest) GetContext() *Context

func (*DeleteRangeRequest) GetEndKey Uses

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

func (*DeleteRangeRequest) GetNotifyOnly Uses

func (m *DeleteRangeRequest) GetNotifyOnly() bool

func (*DeleteRangeRequest) GetStartKey Uses

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

func (*DeleteRangeRequest) Marshal Uses

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

func (*DeleteRangeRequest) MarshalTo Uses

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

func (*DeleteRangeRequest) ProtoMessage Uses

func (*DeleteRangeRequest) ProtoMessage()

func (*DeleteRangeRequest) Reset Uses

func (m *DeleteRangeRequest) Reset()

func (*DeleteRangeRequest) Size Uses

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

func (*DeleteRangeRequest) String Uses

func (m *DeleteRangeRequest) String() string

func (*DeleteRangeRequest) Unmarshal Uses

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

func (*DeleteRangeRequest) XXX_DiscardUnknown Uses

func (m *DeleteRangeRequest) XXX_DiscardUnknown()

func (*DeleteRangeRequest) XXX_Marshal Uses

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

func (*DeleteRangeRequest) XXX_Merge Uses

func (dst *DeleteRangeRequest) XXX_Merge(src proto.Message)

func (*DeleteRangeRequest) XXX_Size Uses

func (m *DeleteRangeRequest) XXX_Size() int

func (*DeleteRangeRequest) XXX_Unmarshal Uses

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

type DeleteRangeResponse Uses

type DeleteRangeResponse struct {
    RegionError          *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Error                string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*DeleteRangeResponse) Descriptor Uses

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

func (*DeleteRangeResponse) GetError Uses

func (m *DeleteRangeResponse) GetError() string

func (*DeleteRangeResponse) GetRegionError Uses

func (m *DeleteRangeResponse) GetRegionError() *errorpb.Error

func (*DeleteRangeResponse) Marshal Uses

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

func (*DeleteRangeResponse) MarshalTo Uses

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

func (*DeleteRangeResponse) ProtoMessage Uses

func (*DeleteRangeResponse) ProtoMessage()

func (*DeleteRangeResponse) Reset Uses

func (m *DeleteRangeResponse) Reset()

func (*DeleteRangeResponse) Size Uses

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

func (*DeleteRangeResponse) String Uses

func (m *DeleteRangeResponse) String() string

func (*DeleteRangeResponse) Unmarshal Uses

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

func (*DeleteRangeResponse) XXX_DiscardUnknown Uses

func (m *DeleteRangeResponse) XXX_DiscardUnknown()

func (*DeleteRangeResponse) XXX_Marshal Uses

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

func (*DeleteRangeResponse) XXX_Merge Uses

func (dst *DeleteRangeResponse) XXX_Merge(src proto.Message)

func (*DeleteRangeResponse) XXX_Size Uses

func (m *DeleteRangeResponse) XXX_Size() int

func (*DeleteRangeResponse) XXX_Unmarshal Uses

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

type ExecDetails Uses

type ExecDetails struct {
    HandleTime           *HandleTime   `protobuf:"bytes,1,opt,name=handle_time,json=handleTime" json:"handle_time,omitempty"`
    ScanDetail           *ScanDetail   `protobuf:"bytes,2,opt,name=scan_detail,json=scanDetail" json:"scan_detail,omitempty"`
    UseScanDetailV2      bool          `protobuf:"varint,3,opt,name=use_scan_detail_v2,json=useScanDetailV2,proto3" json:"use_scan_detail_v2,omitempty"`
    ScanDetailV2         *ScanDetailV2 `protobuf:"bytes,4,opt,name=scan_detail_v2,json=scanDetailV2" json:"scan_detail_v2,omitempty"`
    XXX_NoUnkeyedLiteral struct{}      `json:"-"`
    XXX_unrecognized     []byte        `json:"-"`
    XXX_sizecache        int32         `json:"-"`
}

func (*ExecDetails) Descriptor Uses

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

func (*ExecDetails) GetHandleTime Uses

func (m *ExecDetails) GetHandleTime() *HandleTime

func (*ExecDetails) GetScanDetail Uses

func (m *ExecDetails) GetScanDetail() *ScanDetail

func (*ExecDetails) GetScanDetailV2 Uses

func (m *ExecDetails) GetScanDetailV2() *ScanDetailV2

func (*ExecDetails) GetUseScanDetailV2 Uses

func (m *ExecDetails) GetUseScanDetailV2() bool

func (*ExecDetails) Marshal Uses

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

func (*ExecDetails) MarshalTo Uses

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

func (*ExecDetails) ProtoMessage Uses

func (*ExecDetails) ProtoMessage()

func (*ExecDetails) Reset Uses

func (m *ExecDetails) Reset()

func (*ExecDetails) Size Uses

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

func (*ExecDetails) String Uses

func (m *ExecDetails) String() string

func (*ExecDetails) Unmarshal Uses

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

func (*ExecDetails) XXX_DiscardUnknown Uses

func (m *ExecDetails) XXX_DiscardUnknown()

func (*ExecDetails) XXX_Marshal Uses

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

func (*ExecDetails) XXX_Merge Uses

func (dst *ExecDetails) XXX_Merge(src proto.Message)

func (*ExecDetails) XXX_Size Uses

func (m *ExecDetails) XXX_Size() int

func (*ExecDetails) XXX_Unmarshal Uses

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

type ExtraOp Uses

type ExtraOp int32
const (
    ExtraOp_Noop ExtraOp = 0
    // ReadOldValue represents to output the previous value for delete/update operations.
    ExtraOp_ReadOldValue ExtraOp = 1
)

func (ExtraOp) EnumDescriptor Uses

func (ExtraOp) EnumDescriptor() ([]byte, []int)

func (ExtraOp) String Uses

func (x ExtraOp) String() string

type GCRequest Uses

type GCRequest struct {
    Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    SafePoint            uint64   `protobuf:"varint,2,opt,name=safe_point,json=safePoint,proto3" json:"safe_point,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Request TiKV to garbage collect all non-current data older than `safe_point`.

func (*GCRequest) Descriptor Uses

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

func (*GCRequest) GetContext Uses

func (m *GCRequest) GetContext() *Context

func (*GCRequest) GetSafePoint Uses

func (m *GCRequest) GetSafePoint() uint64

func (*GCRequest) Marshal Uses

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

func (*GCRequest) MarshalTo Uses

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

func (*GCRequest) ProtoMessage Uses

func (*GCRequest) ProtoMessage()

func (*GCRequest) Reset Uses

func (m *GCRequest) Reset()

func (*GCRequest) Size Uses

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

func (*GCRequest) String Uses

func (m *GCRequest) String() string

func (*GCRequest) Unmarshal Uses

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

func (*GCRequest) XXX_DiscardUnknown Uses

func (m *GCRequest) XXX_DiscardUnknown()

func (*GCRequest) XXX_Marshal Uses

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

func (*GCRequest) XXX_Merge Uses

func (dst *GCRequest) XXX_Merge(src proto.Message)

func (*GCRequest) XXX_Size Uses

func (m *GCRequest) XXX_Size() int

func (*GCRequest) XXX_Unmarshal Uses

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

type GCResponse Uses

type GCResponse struct {
    RegionError          *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Error                *KeyError      `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*GCResponse) Descriptor Uses

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

func (*GCResponse) GetError Uses

func (m *GCResponse) GetError() *KeyError

func (*GCResponse) GetRegionError Uses

func (m *GCResponse) GetRegionError() *errorpb.Error

func (*GCResponse) Marshal Uses

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

func (*GCResponse) MarshalTo Uses

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

func (*GCResponse) ProtoMessage Uses

func (*GCResponse) ProtoMessage()

func (*GCResponse) Reset Uses

func (m *GCResponse) Reset()

func (*GCResponse) Size Uses

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

func (*GCResponse) String Uses

func (m *GCResponse) String() string

func (*GCResponse) Unmarshal Uses

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

func (*GCResponse) XXX_DiscardUnknown Uses

func (m *GCResponse) XXX_DiscardUnknown()

func (*GCResponse) XXX_Marshal Uses

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

func (*GCResponse) XXX_Merge Uses

func (dst *GCResponse) XXX_Merge(src proto.Message)

func (*GCResponse) XXX_Size Uses

func (m *GCResponse) XXX_Size() int

func (*GCResponse) XXX_Unmarshal Uses

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

type GetRequest Uses

type GetRequest struct {
    Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
    Version              uint64   `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A transactional get command. Lookup a value for `key` in the transaction with starting timestamp = `version`.

func (*GetRequest) Descriptor Uses

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

func (*GetRequest) GetContext Uses

func (m *GetRequest) GetContext() *Context

func (*GetRequest) GetKey Uses

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

func (*GetRequest) GetVersion Uses

func (m *GetRequest) GetVersion() uint64

func (*GetRequest) Marshal Uses

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

func (*GetRequest) MarshalTo Uses

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

func (*GetRequest) ProtoMessage Uses

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset Uses

func (m *GetRequest) Reset()

func (*GetRequest) Size Uses

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

func (*GetRequest) String Uses

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal Uses

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

func (*GetRequest) XXX_DiscardUnknown Uses

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal Uses

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

func (*GetRequest) XXX_Merge Uses

func (dst *GetRequest) XXX_Merge(src proto.Message)

func (*GetRequest) XXX_Size Uses

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal Uses

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

type GetResponse Uses

type GetResponse struct {
    // A region error indicates that the request was sent to the wrong TiKV node
    // (or other, similar errors).
    RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    // A value could not be retrieved due to the state of the database for the requested key.
    Error *KeyError `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
    // A successful result.
    Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
    // True if the key does not exist in the database.
    NotFound             bool     `protobuf:"varint,4,opt,name=not_found,json=notFound,proto3" json:"not_found,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetResponse) Descriptor Uses

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

func (*GetResponse) GetError Uses

func (m *GetResponse) GetError() *KeyError

func (*GetResponse) GetNotFound Uses

func (m *GetResponse) GetNotFound() bool

func (*GetResponse) GetRegionError Uses

func (m *GetResponse) GetRegionError() *errorpb.Error

func (*GetResponse) GetValue Uses

func (m *GetResponse) GetValue() []byte

func (*GetResponse) Marshal Uses

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

func (*GetResponse) MarshalTo Uses

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

func (*GetResponse) ProtoMessage Uses

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset Uses

func (m *GetResponse) Reset()

func (*GetResponse) Size Uses

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

func (*GetResponse) String Uses

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal Uses

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

func (*GetResponse) XXX_DiscardUnknown Uses

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal Uses

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

func (*GetResponse) XXX_Merge Uses

func (dst *GetResponse) XXX_Merge(src proto.Message)

func (*GetResponse) XXX_Size Uses

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal Uses

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

type HandleTime Uses

type HandleTime struct {
    // Time spent in queue.
    WaitMs int64 `protobuf:"varint,1,opt,name=wait_ms,json=waitMs,proto3" json:"wait_ms,omitempty"`
    // Processing time, excluding wait time.
    ProcessMs            int64    `protobuf:"varint,2,opt,name=process_ms,json=processMs,proto3" json:"process_ms,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*HandleTime) Descriptor Uses

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

func (*HandleTime) GetProcessMs Uses

func (m *HandleTime) GetProcessMs() int64

func (*HandleTime) GetWaitMs Uses

func (m *HandleTime) GetWaitMs() int64

func (*HandleTime) Marshal Uses

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

func (*HandleTime) MarshalTo Uses

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

func (*HandleTime) ProtoMessage Uses

func (*HandleTime) ProtoMessage()

func (*HandleTime) Reset Uses

func (m *HandleTime) Reset()

func (*HandleTime) Size Uses

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

func (*HandleTime) String Uses

func (m *HandleTime) String() string

func (*HandleTime) Unmarshal Uses

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

func (*HandleTime) XXX_DiscardUnknown Uses

func (m *HandleTime) XXX_DiscardUnknown()

func (*HandleTime) XXX_Marshal Uses

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

func (*HandleTime) XXX_Merge Uses

func (dst *HandleTime) XXX_Merge(src proto.Message)

func (*HandleTime) XXX_Size Uses

func (m *HandleTime) XXX_Size() int

func (*HandleTime) XXX_Unmarshal Uses

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

type ImportRequest Uses

type ImportRequest struct {
    Mutations            []*Mutation `protobuf:"bytes,1,rep,name=mutations" json:"mutations,omitempty"`
    CommitVersion        uint64      `protobuf:"varint,2,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

Not yet implemented.

func (*ImportRequest) Descriptor Uses

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

func (*ImportRequest) GetCommitVersion Uses

func (m *ImportRequest) GetCommitVersion() uint64

func (*ImportRequest) GetMutations Uses

func (m *ImportRequest) GetMutations() []*Mutation

func (*ImportRequest) Marshal Uses

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

func (*ImportRequest) MarshalTo Uses

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

func (*ImportRequest) ProtoMessage Uses

func (*ImportRequest) ProtoMessage()

func (*ImportRequest) Reset Uses

func (m *ImportRequest) Reset()

func (*ImportRequest) Size Uses

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

func (*ImportRequest) String Uses

func (m *ImportRequest) String() string

func (*ImportRequest) Unmarshal Uses

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

func (*ImportRequest) XXX_DiscardUnknown Uses

func (m *ImportRequest) XXX_DiscardUnknown()

func (*ImportRequest) XXX_Marshal Uses

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

func (*ImportRequest) XXX_Merge Uses

func (dst *ImportRequest) XXX_Merge(src proto.Message)

func (*ImportRequest) XXX_Size Uses

func (m *ImportRequest) XXX_Size() int

func (*ImportRequest) XXX_Unmarshal Uses

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

type ImportResponse Uses

type ImportResponse struct {
    RegionError          *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Error                string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*ImportResponse) Descriptor Uses

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

func (*ImportResponse) GetError Uses

func (m *ImportResponse) GetError() string

func (*ImportResponse) GetRegionError Uses

func (m *ImportResponse) GetRegionError() *errorpb.Error

func (*ImportResponse) Marshal Uses

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

func (*ImportResponse) MarshalTo Uses

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

func (*ImportResponse) ProtoMessage Uses

func (*ImportResponse) ProtoMessage()

func (*ImportResponse) Reset Uses

func (m *ImportResponse) Reset()

func (*ImportResponse) Size Uses

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

func (*ImportResponse) String Uses

func (m *ImportResponse) String() string

func (*ImportResponse) Unmarshal Uses

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

func (*ImportResponse) XXX_DiscardUnknown Uses

func (m *ImportResponse) XXX_DiscardUnknown()

func (*ImportResponse) XXX_Marshal Uses

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

func (*ImportResponse) XXX_Merge Uses

func (dst *ImportResponse) XXX_Merge(src proto.Message)

func (*ImportResponse) XXX_Size Uses

func (m *ImportResponse) XXX_Size() int

func (*ImportResponse) XXX_Unmarshal Uses

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

type IsolationLevel Uses

type IsolationLevel int32
const (
    IsolationLevel_SI IsolationLevel = 0
    IsolationLevel_RC IsolationLevel = 1
)

func (IsolationLevel) EnumDescriptor Uses

func (IsolationLevel) EnumDescriptor() ([]byte, []int)

func (IsolationLevel) String Uses

func (x IsolationLevel) String() string

type KeyError Uses

type KeyError struct {
    Locked               *LockInfo        `protobuf:"bytes,1,opt,name=locked" json:"locked,omitempty"`
    Retryable            string           `protobuf:"bytes,2,opt,name=retryable,proto3" json:"retryable,omitempty"`
    Abort                string           `protobuf:"bytes,3,opt,name=abort,proto3" json:"abort,omitempty"`
    Conflict             *WriteConflict   `protobuf:"bytes,4,opt,name=conflict" json:"conflict,omitempty"`
    AlreadyExist         *AlreadyExist    `protobuf:"bytes,5,opt,name=already_exist,json=alreadyExist" json:"already_exist,omitempty"`
    Deadlock             *Deadlock        `protobuf:"bytes,6,opt,name=deadlock" json:"deadlock,omitempty"`
    CommitTsExpired      *CommitTsExpired `protobuf:"bytes,7,opt,name=commit_ts_expired,json=commitTsExpired" json:"commit_ts_expired,omitempty"`
    TxnNotFound          *TxnNotFound     `protobuf:"bytes,8,opt,name=txn_not_found,json=txnNotFound" json:"txn_not_found,omitempty"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

func (*KeyError) Descriptor Uses

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

func (*KeyError) GetAbort Uses

func (m *KeyError) GetAbort() string

func (*KeyError) GetAlreadyExist Uses

func (m *KeyError) GetAlreadyExist() *AlreadyExist

func (*KeyError) GetCommitTsExpired Uses

func (m *KeyError) GetCommitTsExpired() *CommitTsExpired

func (*KeyError) GetConflict Uses

func (m *KeyError) GetConflict() *WriteConflict

func (*KeyError) GetDeadlock Uses

func (m *KeyError) GetDeadlock() *Deadlock

func (*KeyError) GetLocked Uses

func (m *KeyError) GetLocked() *LockInfo

func (*KeyError) GetRetryable Uses

func (m *KeyError) GetRetryable() string

func (*KeyError) GetTxnNotFound Uses

func (m *KeyError) GetTxnNotFound() *TxnNotFound

func (*KeyError) Marshal Uses

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

func (*KeyError) MarshalTo Uses

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

func (*KeyError) ProtoMessage Uses

func (*KeyError) ProtoMessage()

func (*KeyError) Reset Uses

func (m *KeyError) Reset()

func (*KeyError) Size Uses

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

func (*KeyError) String Uses

func (m *KeyError) String() string

func (*KeyError) Unmarshal Uses

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

func (*KeyError) XXX_DiscardUnknown Uses

func (m *KeyError) XXX_DiscardUnknown()

func (*KeyError) XXX_Marshal Uses

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

func (*KeyError) XXX_Merge Uses

func (dst *KeyError) XXX_Merge(src proto.Message)

func (*KeyError) XXX_Size Uses

func (m *KeyError) XXX_Size() int

func (*KeyError) XXX_Unmarshal Uses

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

type KeyRange Uses

type KeyRange struct {
    StartKey             []byte   `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
    EndKey               []byte   `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*KeyRange) Descriptor Uses

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

func (*KeyRange) GetEndKey Uses

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

func (*KeyRange) GetStartKey Uses

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

func (*KeyRange) Marshal Uses

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

func (*KeyRange) MarshalTo Uses

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

func (*KeyRange) ProtoMessage Uses

func (*KeyRange) ProtoMessage()

func (*KeyRange) Reset Uses

func (m *KeyRange) Reset()

func (*KeyRange) Size Uses

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

func (*KeyRange) String Uses

func (m *KeyRange) String() string

func (*KeyRange) Unmarshal Uses

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

func (*KeyRange) XXX_DiscardUnknown Uses

func (m *KeyRange) XXX_DiscardUnknown()

func (*KeyRange) XXX_Marshal Uses

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

func (*KeyRange) XXX_Merge Uses

func (dst *KeyRange) XXX_Merge(src proto.Message)

func (*KeyRange) XXX_Size Uses

func (m *KeyRange) XXX_Size() int

func (*KeyRange) XXX_Unmarshal Uses

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

type KvPair Uses

type KvPair struct {
    Error                *KeyError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
    Key                  []byte    `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
    Value                []byte    `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*KvPair) Descriptor Uses

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

func (*KvPair) GetError Uses

func (m *KvPair) GetError() *KeyError

func (*KvPair) GetKey Uses

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

func (*KvPair) GetValue Uses

func (m *KvPair) GetValue() []byte

func (*KvPair) Marshal Uses

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

func (*KvPair) MarshalTo Uses

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

func (*KvPair) ProtoMessage Uses

func (*KvPair) ProtoMessage()

func (*KvPair) Reset Uses

func (m *KvPair) Reset()

func (*KvPair) Size Uses

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

func (*KvPair) String Uses

func (m *KvPair) String() string

func (*KvPair) Unmarshal Uses

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

func (*KvPair) XXX_DiscardUnknown Uses

func (m *KvPair) XXX_DiscardUnknown()

func (*KvPair) XXX_Marshal Uses

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

func (*KvPair) XXX_Merge Uses

func (dst *KvPair) XXX_Merge(src proto.Message)

func (*KvPair) XXX_Size Uses

func (m *KvPair) XXX_Size() int

func (*KvPair) XXX_Unmarshal Uses

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

type LockInfo Uses

type LockInfo struct {
    PrimaryLock []byte `protobuf:"bytes,1,opt,name=primary_lock,json=primaryLock,proto3" json:"primary_lock,omitempty"`
    LockVersion uint64 `protobuf:"varint,2,opt,name=lock_version,json=lockVersion,proto3" json:"lock_version,omitempty"`
    Key         []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
    LockTtl     uint64 `protobuf:"varint,4,opt,name=lock_ttl,json=lockTtl,proto3" json:"lock_ttl,omitempty"`
    // How many keys this transaction involves in this region.
    TxnSize         uint64 `protobuf:"varint,5,opt,name=txn_size,json=txnSize,proto3" json:"txn_size,omitempty"`
    LockType        Op     `protobuf:"varint,6,opt,name=lock_type,json=lockType,proto3,enum=kvrpcpb.Op" json:"lock_type,omitempty"`
    LockForUpdateTs uint64 `protobuf:"varint,7,opt,name=lock_for_update_ts,json=lockForUpdateTs,proto3" json:"lock_for_update_ts,omitempty"`
    // Fields for transactions that are using Async Commit.
    UseAsyncCommit       bool     `protobuf:"varint,8,opt,name=use_async_commit,json=useAsyncCommit,proto3" json:"use_async_commit,omitempty"`
    MinCommitTs          uint64   `protobuf:"varint,9,opt,name=min_commit_ts,json=minCommitTs,proto3" json:"min_commit_ts,omitempty"`
    Secondaries          [][]byte `protobuf:"bytes,10,rep,name=secondaries" json:"secondaries,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*LockInfo) Descriptor Uses

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

func (*LockInfo) GetKey Uses

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

func (*LockInfo) GetLockForUpdateTs Uses

func (m *LockInfo) GetLockForUpdateTs() uint64

func (*LockInfo) GetLockTtl Uses

func (m *LockInfo) GetLockTtl() uint64

func (*LockInfo) GetLockType Uses

func (m *LockInfo) GetLockType() Op

func (*LockInfo) GetLockVersion Uses

func (m *LockInfo) GetLockVersion() uint64

func (*LockInfo) GetMinCommitTs Uses

func (m *LockInfo) GetMinCommitTs() uint64

func (*LockInfo) GetPrimaryLock Uses

func (m *LockInfo) GetPrimaryLock() []byte

func (*LockInfo) GetSecondaries Uses

func (m *LockInfo) GetSecondaries() [][]byte

func (*LockInfo) GetTxnSize Uses

func (m *LockInfo) GetTxnSize() uint64

func (*LockInfo) GetUseAsyncCommit Uses

func (m *LockInfo) GetUseAsyncCommit() bool

func (*LockInfo) Marshal Uses

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

func (*LockInfo) MarshalTo Uses

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

func (*LockInfo) ProtoMessage Uses

func (*LockInfo) ProtoMessage()

func (*LockInfo) Reset Uses

func (m *LockInfo) Reset()

func (*LockInfo) Size Uses

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

func (*LockInfo) String Uses

func (m *LockInfo) String() string

func (*LockInfo) Unmarshal Uses

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

func (*LockInfo) XXX_DiscardUnknown Uses

func (m *LockInfo) XXX_DiscardUnknown()

func (*LockInfo) XXX_Marshal Uses

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

func (*LockInfo) XXX_Merge Uses

func (dst *LockInfo) XXX_Merge(src proto.Message)

func (*LockInfo) XXX_Size Uses

func (m *LockInfo) XXX_Size() int

func (*LockInfo) XXX_Unmarshal Uses

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

type Mutation Uses

type Mutation struct {
    Op                   Op        `protobuf:"varint,1,opt,name=op,proto3,enum=kvrpcpb.Op" json:"op,omitempty"`
    Key                  []byte    `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
    Value                []byte    `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
    Assertion            Assertion `protobuf:"varint,4,opt,name=assertion,proto3,enum=kvrpcpb.Assertion" json:"assertion,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*Mutation) Descriptor Uses

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

func (*Mutation) GetAssertion Uses

func (m *Mutation) GetAssertion() Assertion

func (*Mutation) GetKey Uses

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

func (*Mutation) GetOp Uses

func (m *Mutation) GetOp() Op

func (*Mutation) GetValue Uses

func (m *Mutation) GetValue() []byte

func (*Mutation) Marshal Uses

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

func (*Mutation) MarshalTo Uses

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

func (*Mutation) ProtoMessage Uses

func (*Mutation) ProtoMessage()

func (*Mutation) Reset Uses

func (m *Mutation) Reset()

func (*Mutation) Size Uses

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

func (*Mutation) String Uses

func (m *Mutation) String() string

func (*Mutation) Unmarshal Uses

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

func (*Mutation) XXX_DiscardUnknown Uses

func (m *Mutation) XXX_DiscardUnknown()

func (*Mutation) XXX_Marshal Uses

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

func (*Mutation) XXX_Merge Uses

func (dst *Mutation) XXX_Merge(src proto.Message)

func (*Mutation) XXX_Size Uses

func (m *Mutation) XXX_Size() int

func (*Mutation) XXX_Unmarshal Uses

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

type MvccGetByKeyRequest Uses

type MvccGetByKeyRequest struct {
    Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*MvccGetByKeyRequest) Descriptor Uses

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

func (*MvccGetByKeyRequest) GetContext Uses

func (m *MvccGetByKeyRequest) GetContext() *Context

func (*MvccGetByKeyRequest) GetKey Uses

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

func (*MvccGetByKeyRequest) Marshal Uses

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

func (*MvccGetByKeyRequest) MarshalTo Uses

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

func (*MvccGetByKeyRequest) ProtoMessage Uses

func (*MvccGetByKeyRequest) ProtoMessage()

func (*MvccGetByKeyRequest) Reset Uses

func (m *MvccGetByKeyRequest) Reset()

func (*MvccGetByKeyRequest) Size Uses

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

func (*MvccGetByKeyRequest) String Uses

func (m *MvccGetByKeyRequest) String() string

func (*MvccGetByKeyRequest) Unmarshal Uses

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

func (*MvccGetByKeyRequest) XXX_DiscardUnknown Uses

func (m *MvccGetByKeyRequest) XXX_DiscardUnknown()

func (*MvccGetByKeyRequest) XXX_Marshal Uses

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

func (*MvccGetByKeyRequest) XXX_Merge Uses

func (dst *MvccGetByKeyRequest) XXX_Merge(src proto.Message)

func (*MvccGetByKeyRequest) XXX_Size Uses

func (m *MvccGetByKeyRequest) XXX_Size() int

func (*MvccGetByKeyRequest) XXX_Unmarshal Uses

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

type MvccGetByKeyResponse Uses

type MvccGetByKeyResponse struct {
    RegionError          *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Error                string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
    Info                 *MvccInfo      `protobuf:"bytes,3,opt,name=info" json:"info,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*MvccGetByKeyResponse) Descriptor Uses

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

func (*MvccGetByKeyResponse) GetError Uses

func (m *MvccGetByKeyResponse) GetError() string

func (*MvccGetByKeyResponse) GetInfo Uses

func (m *MvccGetByKeyResponse) GetInfo() *MvccInfo

func (*MvccGetByKeyResponse) GetRegionError Uses

func (m *MvccGetByKeyResponse) GetRegionError() *errorpb.Error

func (*MvccGetByKeyResponse) Marshal Uses

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

func (*MvccGetByKeyResponse) MarshalTo Uses

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

func (*MvccGetByKeyResponse) ProtoMessage Uses

func (*MvccGetByKeyResponse) ProtoMessage()

func (*MvccGetByKeyResponse) Reset Uses

func (m *MvccGetByKeyResponse) Reset()

func (*MvccGetByKeyResponse) Size Uses

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

func (*MvccGetByKeyResponse) String Uses

func (m *MvccGetByKeyResponse) String() string

func (*MvccGetByKeyResponse) Unmarshal Uses

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

func (*MvccGetByKeyResponse) XXX_DiscardUnknown Uses

func (m *MvccGetByKeyResponse) XXX_DiscardUnknown()

func (*MvccGetByKeyResponse) XXX_Marshal Uses

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

func (*MvccGetByKeyResponse) XXX_Merge Uses

func (dst *MvccGetByKeyResponse) XXX_Merge(src proto.Message)

func (*MvccGetByKeyResponse) XXX_Size Uses

func (m *MvccGetByKeyResponse) XXX_Size() int

func (*MvccGetByKeyResponse) XXX_Unmarshal Uses

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

type MvccGetByStartTsRequest Uses

type MvccGetByStartTsRequest struct {
    Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    StartTs              uint64   `protobuf:"varint,2,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*MvccGetByStartTsRequest) Descriptor Uses

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

func (*MvccGetByStartTsRequest) GetContext Uses

func (m *MvccGetByStartTsRequest) GetContext() *Context

func (*MvccGetByStartTsRequest) GetStartTs Uses

func (m *MvccGetByStartTsRequest) GetStartTs() uint64

func (*MvccGetByStartTsRequest) Marshal Uses

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

func (*MvccGetByStartTsRequest) MarshalTo Uses

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

func (*MvccGetByStartTsRequest) ProtoMessage Uses

func (*MvccGetByStartTsRequest) ProtoMessage()

func (*MvccGetByStartTsRequest) Reset Uses

func (m *MvccGetByStartTsRequest) Reset()

func (*MvccGetByStartTsRequest) Size Uses

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

func (*MvccGetByStartTsRequest) String Uses

func (m *MvccGetByStartTsRequest) String() string

func (*MvccGetByStartTsRequest) Unmarshal Uses

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

func (*MvccGetByStartTsRequest) XXX_DiscardUnknown Uses

func (m *MvccGetByStartTsRequest) XXX_DiscardUnknown()

func (*MvccGetByStartTsRequest) XXX_Marshal Uses

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

func (*MvccGetByStartTsRequest) XXX_Merge Uses

func (dst *MvccGetByStartTsRequest) XXX_Merge(src proto.Message)

func (*MvccGetByStartTsRequest) XXX_Size Uses

func (m *MvccGetByStartTsRequest) XXX_Size() int

func (*MvccGetByStartTsRequest) XXX_Unmarshal Uses

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

type MvccGetByStartTsResponse Uses

type MvccGetByStartTsResponse struct {
    RegionError          *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Error                string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
    Key                  []byte         `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
    Info                 *MvccInfo      `protobuf:"bytes,4,opt,name=info" json:"info,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*MvccGetByStartTsResponse) Descriptor Uses

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

func (*MvccGetByStartTsResponse) GetError Uses

func (m *MvccGetByStartTsResponse) GetError() string

func (*MvccGetByStartTsResponse) GetInfo Uses

func (m *MvccGetByStartTsResponse) GetInfo() *MvccInfo

func (*MvccGetByStartTsResponse) GetKey Uses

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

func (*MvccGetByStartTsResponse) GetRegionError Uses

func (m *MvccGetByStartTsResponse) GetRegionError() *errorpb.Error

func (*MvccGetByStartTsResponse) Marshal Uses

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

func (*MvccGetByStartTsResponse) MarshalTo Uses

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

func (*MvccGetByStartTsResponse) ProtoMessage Uses

func (*MvccGetByStartTsResponse) ProtoMessage()

func (*MvccGetByStartTsResponse) Reset Uses

func (m *MvccGetByStartTsResponse) Reset()

func (*MvccGetByStartTsResponse) Size Uses

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

func (*MvccGetByStartTsResponse) String Uses

func (m *MvccGetByStartTsResponse) String() string

func (*MvccGetByStartTsResponse) Unmarshal Uses

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

func (*MvccGetByStartTsResponse) XXX_DiscardUnknown Uses

func (m *MvccGetByStartTsResponse) XXX_DiscardUnknown()

func (*MvccGetByStartTsResponse) XXX_Marshal Uses

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

func (*MvccGetByStartTsResponse) XXX_Merge Uses

func (dst *MvccGetByStartTsResponse) XXX_Merge(src proto.Message)

func (*MvccGetByStartTsResponse) XXX_Size Uses

func (m *MvccGetByStartTsResponse) XXX_Size() int

func (*MvccGetByStartTsResponse) XXX_Unmarshal Uses

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

type MvccInfo Uses

type MvccInfo struct {
    Lock                 *MvccLock    `protobuf:"bytes,1,opt,name=lock" json:"lock,omitempty"`
    Writes               []*MvccWrite `protobuf:"bytes,2,rep,name=writes" json:"writes,omitempty"`
    Values               []*MvccValue `protobuf:"bytes,3,rep,name=values" json:"values,omitempty"`
    XXX_NoUnkeyedLiteral struct{}     `json:"-"`
    XXX_unrecognized     []byte       `json:"-"`
    XXX_sizecache        int32        `json:"-"`
}

func (*MvccInfo) Descriptor Uses

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

func (*MvccInfo) GetLock Uses

func (m *MvccInfo) GetLock() *MvccLock

func (*MvccInfo) GetValues Uses

func (m *MvccInfo) GetValues() []*MvccValue

func (*MvccInfo) GetWrites Uses

func (m *MvccInfo) GetWrites() []*MvccWrite

func (*MvccInfo) Marshal Uses

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

func (*MvccInfo) MarshalTo Uses

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

func (*MvccInfo) ProtoMessage Uses

func (*MvccInfo) ProtoMessage()

func (*MvccInfo) Reset Uses

func (m *MvccInfo) Reset()

func (*MvccInfo) Size Uses

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

func (*MvccInfo) String Uses

func (m *MvccInfo) String() string

func (*MvccInfo) Unmarshal Uses

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

func (*MvccInfo) XXX_DiscardUnknown Uses

func (m *MvccInfo) XXX_DiscardUnknown()

func (*MvccInfo) XXX_Marshal Uses

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

func (*MvccInfo) XXX_Merge Uses

func (dst *MvccInfo) XXX_Merge(src proto.Message)

func (*MvccInfo) XXX_Size Uses

func (m *MvccInfo) XXX_Size() int

func (*MvccInfo) XXX_Unmarshal Uses

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

type MvccLock Uses

type MvccLock struct {
    Type                 Op       `protobuf:"varint,1,opt,name=type,proto3,enum=kvrpcpb.Op" json:"type,omitempty"`
    StartTs              uint64   `protobuf:"varint,2,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
    Primary              []byte   `protobuf:"bytes,3,opt,name=primary,proto3" json:"primary,omitempty"`
    ShortValue           []byte   `protobuf:"bytes,4,opt,name=short_value,json=shortValue,proto3" json:"short_value,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*MvccLock) Descriptor Uses

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

func (*MvccLock) GetPrimary Uses

func (m *MvccLock) GetPrimary() []byte

func (*MvccLock) GetShortValue Uses

func (m *MvccLock) GetShortValue() []byte

func (*MvccLock) GetStartTs Uses

func (m *MvccLock) GetStartTs() uint64

func (*MvccLock) GetType Uses

func (m *MvccLock) GetType() Op

func (*MvccLock) Marshal Uses

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

func (*MvccLock) MarshalTo Uses

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

func (*MvccLock) ProtoMessage Uses

func (*MvccLock) ProtoMessage()

func (*MvccLock) Reset Uses

func (m *MvccLock) Reset()

func (*MvccLock) Size Uses

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

func (*MvccLock) String Uses

func (m *MvccLock) String() string

func (*MvccLock) Unmarshal Uses

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

func (*MvccLock) XXX_DiscardUnknown Uses

func (m *MvccLock) XXX_DiscardUnknown()

func (*MvccLock) XXX_Marshal Uses

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

func (*MvccLock) XXX_Merge Uses

func (dst *MvccLock) XXX_Merge(src proto.Message)

func (*MvccLock) XXX_Size Uses

func (m *MvccLock) XXX_Size() int

func (*MvccLock) XXX_Unmarshal Uses

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

type MvccValue Uses

type MvccValue struct {
    StartTs              uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
    Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*MvccValue) Descriptor Uses

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

func (*MvccValue) GetStartTs Uses

func (m *MvccValue) GetStartTs() uint64

func (*MvccValue) GetValue Uses

func (m *MvccValue) GetValue() []byte

func (*MvccValue) Marshal Uses

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

func (*MvccValue) MarshalTo Uses

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

func (*MvccValue) ProtoMessage Uses

func (*MvccValue) ProtoMessage()

func (*MvccValue) Reset Uses

func (m *MvccValue) Reset()

func (*MvccValue) Size Uses

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

func (*MvccValue) String Uses

func (m *MvccValue) String() string

func (*MvccValue) Unmarshal Uses

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

func (*MvccValue) XXX_DiscardUnknown Uses

func (m *MvccValue) XXX_DiscardUnknown()

func (*MvccValue) XXX_Marshal Uses

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

func (*MvccValue) XXX_Merge Uses

func (dst *MvccValue) XXX_Merge(src proto.Message)

func (*MvccValue) XXX_Size Uses

func (m *MvccValue) XXX_Size() int

func (*MvccValue) XXX_Unmarshal Uses

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

type MvccWrite Uses

type MvccWrite struct {
    Type                 Op       `protobuf:"varint,1,opt,name=type,proto3,enum=kvrpcpb.Op" json:"type,omitempty"`
    StartTs              uint64   `protobuf:"varint,2,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
    CommitTs             uint64   `protobuf:"varint,3,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
    ShortValue           []byte   `protobuf:"bytes,4,opt,name=short_value,json=shortValue,proto3" json:"short_value,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*MvccWrite) Descriptor Uses

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

func (*MvccWrite) GetCommitTs Uses

func (m *MvccWrite) GetCommitTs() uint64

func (*MvccWrite) GetShortValue Uses

func (m *MvccWrite) GetShortValue() []byte

func (*MvccWrite) GetStartTs Uses

func (m *MvccWrite) GetStartTs() uint64

func (*MvccWrite) GetType Uses

func (m *MvccWrite) GetType() Op

func (*MvccWrite) Marshal Uses

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

func (*MvccWrite) MarshalTo Uses

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

func (*MvccWrite) ProtoMessage Uses

func (*MvccWrite) ProtoMessage()

func (*MvccWrite) Reset Uses

func (m *MvccWrite) Reset()

func (*MvccWrite) Size Uses

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

func (*MvccWrite) String Uses

func (m *MvccWrite) String() string

func (*MvccWrite) Unmarshal Uses

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

func (*MvccWrite) XXX_DiscardUnknown Uses

func (m *MvccWrite) XXX_DiscardUnknown()

func (*MvccWrite) XXX_Marshal Uses

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

func (*MvccWrite) XXX_Merge Uses

func (dst *MvccWrite) XXX_Merge(src proto.Message)

func (*MvccWrite) XXX_Size Uses

func (m *MvccWrite) XXX_Size() int

func (*MvccWrite) XXX_Unmarshal Uses

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

type Op Uses

type Op int32
const (
    Op_Put      Op  = 0
    Op_Del      Op  = 1
    Op_Lock     Op  = 2
    Op_Rollback Op  = 3
    // insert operation has a constraint that key should not exist before.
    Op_Insert          Op  = 4
    Op_PessimisticLock Op  = 5
    Op_CheckNotExists  Op  = 6
)

func (Op) EnumDescriptor Uses

func (Op) EnumDescriptor() ([]byte, []int)

func (Op) String Uses

func (x Op) String() string

type PessimisticLockRequest Uses

type PessimisticLockRequest struct {
    Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    // In this case every `Op` of the mutations must be `PessimisticLock`.
    Mutations    []*Mutation `protobuf:"bytes,2,rep,name=mutations" json:"mutations,omitempty"`
    PrimaryLock  []byte      `protobuf:"bytes,3,opt,name=primary_lock,json=primaryLock,proto3" json:"primary_lock,omitempty"`
    StartVersion uint64      `protobuf:"varint,4,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
    LockTtl      uint64      `protobuf:"varint,5,opt,name=lock_ttl,json=lockTtl,proto3" json:"lock_ttl,omitempty"`
    // Each locking command in a pessimistic transaction has its own timestamp. If locking fails, then
    // the corresponding SQL statement can be retried with a later timestamp, TiDB does not need to
    // retry the whole transaction. The name comes from the `SELECT ... FOR UPDATE` SQL statement which
    // is a locking read. Each `SELECT ... FOR UPDATE` in a transaction will be assigned its own
    // timestamp.
    ForUpdateTs uint64 `protobuf:"varint,6,opt,name=for_update_ts,json=forUpdateTs,proto3" json:"for_update_ts,omitempty"`
    // If the request is the first lock request, we don't need to detect deadlock.
    IsFirstLock bool `protobuf:"varint,7,opt,name=is_first_lock,json=isFirstLock,proto3" json:"is_first_lock,omitempty"`
    // Time to wait for lock released in milliseconds when encountering locks.
    // 0 means using default timeout in TiKV. Negative means no wait.
    WaitTimeout int64 `protobuf:"varint,8,opt,name=wait_timeout,json=waitTimeout,proto3" json:"wait_timeout,omitempty"`
    // If it is true, TiKV will acquire the pessimistic lock regardless of write conflict
    // and return the latest value. It's only supported for single mutation.
    Force bool `protobuf:"varint,9,opt,name=force,proto3" json:"force,omitempty"`
    // If it is true, TiKV will return values of the keys if no error, so TiDB can cache the values for
    // later read in the same transaction.
    // When 'force' is set to true, this field is ignored.
    ReturnValues bool `protobuf:"varint,10,opt,name=return_values,json=returnValues,proto3" json:"return_values,omitempty"`
    // If min_commit_ts > 0, this is large transaction proto, the final commit_ts
    // would be infered from min_commit_ts.
    MinCommitTs          uint64   `protobuf:"varint,11,opt,name=min_commit_ts,json=minCommitTs,proto3" json:"min_commit_ts,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Lock a set of keys to prepare to write to them.

func (*PessimisticLockRequest) Descriptor Uses

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

func (*PessimisticLockRequest) GetContext Uses

func (m *PessimisticLockRequest) GetContext() *Context

func (*PessimisticLockRequest) GetForUpdateTs Uses

func (m *PessimisticLockRequest) GetForUpdateTs() uint64

func (*PessimisticLockRequest) GetForce Uses

func (m *PessimisticLockRequest) GetForce() bool

func (*PessimisticLockRequest) GetIsFirstLock Uses

func (m *PessimisticLockRequest) GetIsFirstLock() bool

func (*PessimisticLockRequest) GetLockTtl Uses

func (m *PessimisticLockRequest) GetLockTtl() uint64

func (*PessimisticLockRequest) GetMinCommitTs Uses

func (m *PessimisticLockRequest) GetMinCommitTs() uint64

func (*PessimisticLockRequest) GetMutations Uses

func (m *PessimisticLockRequest) GetMutations() []*Mutation

func (*PessimisticLockRequest) GetPrimaryLock Uses

func (m *PessimisticLockRequest) GetPrimaryLock() []byte

func (*PessimisticLockRequest) GetReturnValues Uses

func (m *PessimisticLockRequest) GetReturnValues() bool

func (*PessimisticLockRequest) GetStartVersion Uses

func (m *PessimisticLockRequest) GetStartVersion() uint64

func (*PessimisticLockRequest) GetWaitTimeout Uses

func (m *PessimisticLockRequest) GetWaitTimeout() int64

func (*PessimisticLockRequest) Marshal Uses

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

func (*PessimisticLockRequest) MarshalTo Uses

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

func (*PessimisticLockRequest) ProtoMessage Uses

func (*PessimisticLockRequest) ProtoMessage()

func (*PessimisticLockRequest) Reset Uses

func (m *PessimisticLockRequest) Reset()

func (*PessimisticLockRequest) Size Uses

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

func (*PessimisticLockRequest) String Uses

func (m *PessimisticLockRequest) String() string

func (*PessimisticLockRequest) Unmarshal Uses

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

func (*PessimisticLockRequest) XXX_DiscardUnknown Uses

func (m *PessimisticLockRequest) XXX_DiscardUnknown()

func (*PessimisticLockRequest) XXX_Marshal Uses

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

func (*PessimisticLockRequest) XXX_Merge Uses

func (dst *PessimisticLockRequest) XXX_Merge(src proto.Message)

func (*PessimisticLockRequest) XXX_Size Uses

func (m *PessimisticLockRequest) XXX_Size() int

func (*PessimisticLockRequest) XXX_Unmarshal Uses

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

type PessimisticLockResponse Uses

type PessimisticLockResponse struct {
    RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Errors      []*KeyError    `protobuf:"bytes,2,rep,name=errors" json:"errors,omitempty"`
    // It carries the latest value and its commit ts if force in PessimisticLockRequest is true.
    CommitTs uint64 `protobuf:"varint,3,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
    Value    []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
    // The values is set if 'return_values' is true in the request and no error.
    // If 'force' is true, this field is not used.
    Values               [][]byte `protobuf:"bytes,5,rep,name=values" json:"values,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*PessimisticLockResponse) Descriptor Uses

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

func (*PessimisticLockResponse) GetCommitTs Uses

func (m *PessimisticLockResponse) GetCommitTs() uint64

func (*PessimisticLockResponse) GetErrors Uses

func (m *PessimisticLockResponse) GetErrors() []*KeyError

func (*PessimisticLockResponse) GetRegionError Uses

func (m *PessimisticLockResponse) GetRegionError() *errorpb.Error

func (*PessimisticLockResponse) GetValue Uses

func (m *PessimisticLockResponse) GetValue() []byte

func (*PessimisticLockResponse) GetValues Uses

func (m *PessimisticLockResponse) GetValues() [][]byte

func (*PessimisticLockResponse) Marshal Uses

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

func (*PessimisticLockResponse) MarshalTo Uses

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

func (*PessimisticLockResponse) ProtoMessage Uses

func (*PessimisticLockResponse) ProtoMessage()

func (*PessimisticLockResponse) Reset Uses

func (m *PessimisticLockResponse) Reset()

func (*PessimisticLockResponse) Size Uses

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

func (*PessimisticLockResponse) String Uses

func (m *PessimisticLockResponse) String() string

func (*PessimisticLockResponse) Unmarshal Uses

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

func (*PessimisticLockResponse) XXX_DiscardUnknown Uses

func (m *PessimisticLockResponse) XXX_DiscardUnknown()

func (*PessimisticLockResponse) XXX_Marshal Uses

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

func (*PessimisticLockResponse) XXX_Merge Uses

func (dst *PessimisticLockResponse) XXX_Merge(src proto.Message)

func (*PessimisticLockResponse) XXX_Size Uses

func (m *PessimisticLockResponse) XXX_Size() int

func (*PessimisticLockResponse) XXX_Unmarshal Uses

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

type PessimisticRollbackRequest Uses

type PessimisticRollbackRequest struct {
    Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    StartVersion         uint64   `protobuf:"varint,2,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
    ForUpdateTs          uint64   `protobuf:"varint,3,opt,name=for_update_ts,json=forUpdateTs,proto3" json:"for_update_ts,omitempty"`
    Keys                 [][]byte `protobuf:"bytes,4,rep,name=keys" json:"keys,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Unlock keys locked using `PessimisticLockRequest`.

func (*PessimisticRollbackRequest) Descriptor Uses

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

func (*PessimisticRollbackRequest) GetContext Uses

func (m *PessimisticRollbackRequest) GetContext() *Context

func (*PessimisticRollbackRequest) GetForUpdateTs Uses

func (m *PessimisticRollbackRequest) GetForUpdateTs() uint64

func (*PessimisticRollbackRequest) GetKeys Uses

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

func (*PessimisticRollbackRequest) GetStartVersion Uses

func (m *PessimisticRollbackRequest) GetStartVersion() uint64

func (*PessimisticRollbackRequest) Marshal Uses

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

func (*PessimisticRollbackRequest) MarshalTo Uses

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

func (*PessimisticRollbackRequest) ProtoMessage Uses

func (*PessimisticRollbackRequest) ProtoMessage()

func (*PessimisticRollbackRequest) Reset Uses

func (m *PessimisticRollbackRequest) Reset()

func (*PessimisticRollbackRequest) Size Uses

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

func (*PessimisticRollbackRequest) String Uses

func (m *PessimisticRollbackRequest) String() string

func (*PessimisticRollbackRequest) Unmarshal Uses

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

func (*PessimisticRollbackRequest) XXX_DiscardUnknown Uses

func (m *PessimisticRollbackRequest) XXX_DiscardUnknown()

func (*PessimisticRollbackRequest) XXX_Marshal Uses

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

func (*PessimisticRollbackRequest) XXX_Merge Uses

func (dst *PessimisticRollbackRequest) XXX_Merge(src proto.Message)

func (*PessimisticRollbackRequest) XXX_Size Uses

func (m *PessimisticRollbackRequest) XXX_Size() int

func (*PessimisticRollbackRequest) XXX_Unmarshal Uses

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

type PessimisticRollbackResponse Uses

type PessimisticRollbackResponse struct {
    RegionError          *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Errors               []*KeyError    `protobuf:"bytes,2,rep,name=errors" json:"errors,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*PessimisticRollbackResponse) Descriptor Uses

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

func (*PessimisticRollbackResponse) GetErrors Uses

func (m *PessimisticRollbackResponse) GetErrors() []*KeyError

func (*PessimisticRollbackResponse) GetRegionError Uses

func (m *PessimisticRollbackResponse) GetRegionError() *errorpb.Error

func (*PessimisticRollbackResponse) Marshal Uses

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

func (*PessimisticRollbackResponse) MarshalTo Uses

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

func (*PessimisticRollbackResponse) ProtoMessage Uses

func (*PessimisticRollbackResponse) ProtoMessage()

func (*PessimisticRollbackResponse) Reset Uses

func (m *PessimisticRollbackResponse) Reset()

func (*PessimisticRollbackResponse) Size Uses

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

func (*PessimisticRollbackResponse) String Uses

func (m *PessimisticRollbackResponse) String() string

func (*PessimisticRollbackResponse) Unmarshal Uses

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

func (*PessimisticRollbackResponse) XXX_DiscardUnknown Uses

func (m *PessimisticRollbackResponse) XXX_DiscardUnknown()

func (*PessimisticRollbackResponse) XXX_Marshal Uses

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

func (*PessimisticRollbackResponse) XXX_Merge Uses

func (dst *PessimisticRollbackResponse) XXX_Merge(src proto.Message)

func (*PessimisticRollbackResponse) XXX_Size Uses

func (m *PessimisticRollbackResponse) XXX_Size() int

func (*PessimisticRollbackResponse) XXX_Unmarshal Uses

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

type PhysicalScanLockRequest Uses

type PhysicalScanLockRequest struct {
    Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    MaxTs                uint64   `protobuf:"varint,2,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
    StartKey             []byte   `protobuf:"bytes,3,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
    Limit                uint32   `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*PhysicalScanLockRequest) Descriptor Uses

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

func (*PhysicalScanLockRequest) GetContext Uses

func (m *PhysicalScanLockRequest) GetContext() *Context

func (*PhysicalScanLockRequest) GetLimit Uses

func (m *PhysicalScanLockRequest) GetLimit() uint32

func (*PhysicalScanLockRequest) GetMaxTs Uses

func (m *PhysicalScanLockRequest) GetMaxTs() uint64

func (*PhysicalScanLockRequest) GetStartKey Uses

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

func (*PhysicalScanLockRequest) Marshal Uses

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

func (*PhysicalScanLockRequest) MarshalTo Uses

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

func (*PhysicalScanLockRequest) ProtoMessage Uses

func (*PhysicalScanLockRequest) ProtoMessage()

func (*PhysicalScanLockRequest) Reset Uses

func (m *PhysicalScanLockRequest) Reset()

func (*PhysicalScanLockRequest) Size Uses

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

func (*PhysicalScanLockRequest) String Uses

func (m *PhysicalScanLockRequest) String() string

func (*PhysicalScanLockRequest) Unmarshal Uses

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

func (*PhysicalScanLockRequest) XXX_DiscardUnknown Uses

func (m *PhysicalScanLockRequest) XXX_DiscardUnknown()

func (*PhysicalScanLockRequest) XXX_Marshal Uses

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

func (*PhysicalScanLockRequest) XXX_Merge Uses

func (dst *PhysicalScanLockRequest) XXX_Merge(src proto.Message)

func (*PhysicalScanLockRequest) XXX_Size Uses

func (m *PhysicalScanLockRequest) XXX_Size() int

func (*PhysicalScanLockRequest) XXX_Unmarshal Uses

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

type PhysicalScanLockResponse Uses

type PhysicalScanLockResponse struct {
    Error                string      `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
    Locks                []*LockInfo `protobuf:"bytes,2,rep,name=locks" json:"locks,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

func (*PhysicalScanLockResponse) Descriptor Uses

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

func (*PhysicalScanLockResponse) GetError Uses

func (m *PhysicalScanLockResponse) GetError() string

func (*PhysicalScanLockResponse) GetLocks Uses

func (m *PhysicalScanLockResponse) GetLocks() []*LockInfo

func (*PhysicalScanLockResponse) Marshal Uses

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

func (*PhysicalScanLockResponse) MarshalTo Uses

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

func (*PhysicalScanLockResponse) ProtoMessage Uses

func (*PhysicalScanLockResponse) ProtoMessage()

func (*PhysicalScanLockResponse) Reset Uses

func (m *PhysicalScanLockResponse) Reset()

func (*PhysicalScanLockResponse) Size Uses

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

func (*PhysicalScanLockResponse) String Uses

func (m *PhysicalScanLockResponse) String() string

func (*PhysicalScanLockResponse) Unmarshal Uses

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

func (*PhysicalScanLockResponse) XXX_DiscardUnknown Uses

func (m *PhysicalScanLockResponse) XXX_DiscardUnknown()

func (*PhysicalScanLockResponse) XXX_Marshal Uses

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

func (*PhysicalScanLockResponse) XXX_Merge Uses

func (dst *PhysicalScanLockResponse) XXX_Merge(src proto.Message)

func (*PhysicalScanLockResponse) XXX_Size Uses

func (m *PhysicalScanLockResponse) XXX_Size() int

func (*PhysicalScanLockResponse) XXX_Unmarshal Uses

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

type PrewriteRequest Uses

type PrewriteRequest struct {
    Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    // The data to be written to the database.
    Mutations []*Mutation `protobuf:"bytes,2,rep,name=mutations" json:"mutations,omitempty"`
    // The client picks one key to be primary (unrelated to the primary key concept in SQL). This
    // key's lock is the source of truth for the state of a transaction. All other locks due to a
    // transaction will point to the primary lock.
    PrimaryLock []byte `protobuf:"bytes,3,opt,name=primary_lock,json=primaryLock,proto3" json:"primary_lock,omitempty"`
    // Identifies the transaction being written.
    StartVersion uint64 `protobuf:"varint,4,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
    LockTtl      uint64 `protobuf:"varint,5,opt,name=lock_ttl,json=lockTtl,proto3" json:"lock_ttl,omitempty"`
    // TiKV can skip some checks, used for speeding up data migration.
    SkipConstraintCheck bool `protobuf:"varint,6,opt,name=skip_constraint_check,json=skipConstraintCheck,proto3" json:"skip_constraint_check,omitempty"`
    // For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
    IsPessimisticLock []bool `protobuf:"varint,7,rep,packed,name=is_pessimistic_lock,json=isPessimisticLock" json:"is_pessimistic_lock,omitempty"`
    // How many keys this transaction involves in this region.
    TxnSize uint64 `protobuf:"varint,8,opt,name=txn_size,json=txnSize,proto3" json:"txn_size,omitempty"`
    // For pessimistic transactions only; used to check if a conflict lock is already committed.
    ForUpdateTs uint64 `protobuf:"varint,9,opt,name=for_update_ts,json=forUpdateTs,proto3" json:"for_update_ts,omitempty"`
    // If min_commit_ts > 0, this is a large transaction request, the final commit_ts
    // will be inferred from `min_commit_ts`.
    MinCommitTs uint64 `protobuf:"varint,10,opt,name=min_commit_ts,json=minCommitTs,proto3" json:"min_commit_ts,omitempty"`
    // When async commit is enabled, `secondaries` should be set as the key list of all secondary
    // locks if the request prewrites the primary lock.
    UseAsyncCommit       bool     `protobuf:"varint,11,opt,name=use_async_commit,json=useAsyncCommit,proto3" json:"use_async_commit,omitempty"`
    Secondaries          [][]byte `protobuf:"bytes,12,rep,name=secondaries" json:"secondaries,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A prewrite is the first phase of writing to TiKV. It contains all data to be written in a transaction. TiKV will write the data in a preliminary state. Data cannot be read until it has been committed. The client should only commit a transaction once all prewrites succeed.

func (*PrewriteRequest) Descriptor Uses

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

func (*PrewriteRequest) GetContext Uses

func (m *PrewriteRequest) GetContext() *Context

func (*PrewriteRequest) GetForUpdateTs Uses

func (m *PrewriteRequest) GetForUpdateTs() uint64

func (*PrewriteRequest) GetIsPessimisticLock Uses

func (m *PrewriteRequest) GetIsPessimisticLock() []bool

func (*PrewriteRequest) GetLockTtl Uses

func (m *PrewriteRequest) GetLockTtl() uint64

func (*PrewriteRequest) GetMinCommitTs Uses

func (m *PrewriteRequest) GetMinCommitTs() uint64

func (*PrewriteRequest) GetMutations Uses

func (m *PrewriteRequest) GetMutations() []*Mutation

func (*PrewriteRequest) GetPrimaryLock Uses

func (m *PrewriteRequest) GetPrimaryLock() []byte

func (*PrewriteRequest) GetSecondaries Uses

func (m *PrewriteRequest) GetSecondaries() [][]byte

func (*PrewriteRequest) GetSkipConstraintCheck Uses

func (m *PrewriteRequest) GetSkipConstraintCheck() bool

func (*PrewriteRequest) GetStartVersion Uses

func (m *PrewriteRequest) GetStartVersion() uint64

func (*PrewriteRequest) GetTxnSize Uses

func (m *PrewriteRequest) GetTxnSize() uint64

func (*PrewriteRequest) GetUseAsyncCommit Uses

func (m *PrewriteRequest) GetUseAsyncCommit() bool

func (*PrewriteRequest) Marshal Uses

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

func (*PrewriteRequest) MarshalTo Uses

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

func (*PrewriteRequest) ProtoMessage Uses

func (*PrewriteRequest) ProtoMessage()

func (*PrewriteRequest) Reset Uses

func (m *PrewriteRequest) Reset()

func (*PrewriteRequest) Size Uses

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

func (*PrewriteRequest) String Uses

func (m *PrewriteRequest) String() string

func (*PrewriteRequest) Unmarshal Uses

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

func (*PrewriteRequest) XXX_DiscardUnknown Uses

func (m *PrewriteRequest) XXX_DiscardUnknown()

func (*PrewriteRequest) XXX_Marshal Uses

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

func (*PrewriteRequest) XXX_Merge Uses

func (dst *PrewriteRequest) XXX_Merge(src proto.Message)

func (*PrewriteRequest) XXX_Size Uses

func (m *PrewriteRequest) XXX_Size() int

func (*PrewriteRequest) XXX_Unmarshal Uses

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

type PrewriteResponse Uses

type PrewriteResponse struct {
    RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Errors      []*KeyError    `protobuf:"bytes,2,rep,name=errors" json:"errors,omitempty"`
    // 0 if the min_commit_ts is not ready or any other reason that async
    // commit cannot proceed. The client can then fallback to normal way to
    // continue committing the transaction if prewrite are all finished.
    MinCommitTs          uint64   `protobuf:"varint,3,opt,name=min_commit_ts,json=minCommitTs,proto3" json:"min_commit_ts,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*PrewriteResponse) Descriptor Uses

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

func (*PrewriteResponse) GetErrors Uses

func (m *PrewriteResponse) GetErrors() []*KeyError

func (*PrewriteResponse) GetMinCommitTs Uses

func (m *PrewriteResponse) GetMinCommitTs() uint64

func (*PrewriteResponse) GetRegionError Uses

func (m *PrewriteResponse) GetRegionError() *errorpb.Error

func (*PrewriteResponse) Marshal Uses

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

func (*PrewriteResponse) MarshalTo Uses

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

func (*PrewriteResponse) ProtoMessage Uses

func (*PrewriteResponse) ProtoMessage()

func (*PrewriteResponse) Reset Uses

func (m *PrewriteResponse) Reset()

func (*PrewriteResponse) Size Uses

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

func (*PrewriteResponse) String Uses

func (m *PrewriteResponse) String() string

func (*PrewriteResponse) Unmarshal Uses

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

func (*PrewriteResponse) XXX_DiscardUnknown Uses

func (m *PrewriteResponse) XXX_DiscardUnknown()

func (*PrewriteResponse) XXX_Marshal Uses

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

func (*PrewriteResponse) XXX_Merge Uses

func (dst *PrewriteResponse) XXX_Merge(src proto.Message)

func (*PrewriteResponse) XXX_Size Uses

func (m *PrewriteResponse) XXX_Size() int

func (*PrewriteResponse) XXX_Unmarshal Uses

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

type RawBatchDeleteRequest Uses

type RawBatchDeleteRequest struct {
    Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
    Keys                 [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
    Cf                   string   `protobuf:"bytes,3,opt,name=cf,proto3" json:"cf,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*RawBatchDeleteRequest) Descriptor Uses

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

func (*RawBatchDeleteRequest) GetCf Uses

func (m *RawBatchDeleteRequest) GetCf() string

func (*RawBatchDeleteRequest) GetContext Uses

func (m *RawBatchDeleteRequest) GetContext() *Context

func (*RawBatchDeleteRequest) GetKeys Uses

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

func (*RawBatchDeleteRequest) Marshal Uses

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

func (*RawBatchDeleteRequest) MarshalTo Uses

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

func (*RawBatchDeleteRequest) ProtoMessage Uses

func (*RawBatchDeleteRequest) ProtoMessage()

func (*RawBatchDeleteRequest) Reset Uses

func (m *RawBatchDeleteRequest) Reset()

func (*RawBatchDeleteRequest) Size Uses

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

func (*RawBatchDeleteRequest) String Uses

func (m *RawBatchDeleteRequest) String() string

func (*RawBatchDeleteRequest) Unmarshal Uses

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

func (*RawBatchDeleteRequest) XXX_DiscardUnknown Uses

func (m *RawBatchDeleteRequest) XXX_DiscardUnknown()

func (*RawBatchDeleteRequest) XXX_Marshal Uses

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

func (*RawBatchDeleteRequest) XXX_Merge Uses

func (dst *RawBatchDeleteRequest) XXX_Merge(src proto.Message)

func (*RawBatchDeleteRequest) XXX_Size Uses

func (m *RawBatchDeleteRequest) XXX_Size() int

func (*RawBatchDeleteRequest) XXX_Unmarshal Uses

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

type RawBatchDeleteResponse Uses

type RawBatchDeleteResponse struct {
    RegionError          *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
    Error                string         `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*RawBatchDeleteResponse) Descriptor Uses

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

func (*RawBatchDeleteResponse) GetError Uses

func (m *RawBatchDeleteResponse) GetError() string

func (*RawBatchDeleteResponse) GetRegionError Uses

func (m *RawBatchDeleteResponse) GetRegionError() *errorpb.Error

func (*RawBatchDeleteResponse) Marshal Uses

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

func (*RawBatchDeleteResponse) MarshalTo Uses

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

func (*RawBatchDeleteResponse) ProtoMessage Uses

func (*RawBatchDeleteResponse) ProtoMessage()

func (*RawBatchDeleteResponse) Reset Uses

func (m *RawBatchDeleteResponse) Reset()

func (*RawBatchDeleteResponse) Size Uses

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

func (*RawBatchDeleteResponse) String Uses

func (m *RawBatchDeleteResponse) String() string

func (*RawBatchDeleteResponse) Unmarshal Uses

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

func (*RawBatchDeleteResponse) XXX_DiscardUnknown