kvrpcpb

package
v0.0.0-...-1338f1b Latest Latest
Warning

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

 Go to latest Published: Mar 15, 2024 License: Apache-2.0 Imports: 7 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthKvrpcpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKvrpcpb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Action_name = map[int32]string{
	0: "NoAction",
	1: "TTLExpireRollback",
	2: "LockNotExistRollback",
}
View Source 
var Action_value = map[string]int32{
	"NoAction":             0,
	"TTLExpireRollback":    1,
	"LockNotExistRollback": 2,
}
View Source 
var Op_name = map[int32]string{
	0: "Put",
	1: "Del",
	2: "Rollback",
	3: "Lock",
}
View Source 
var Op_value = map[string]int32{
	"Put":      0,
	"Del":      1,
	"Rollback": 2,
	"Lock":     3,
}

Functions

This section is empty.

Types

type Action 

type Action int32
const (
	Action_NoAction Action = 0
	// The lock is rolled back because it has expired.
	Action_TTLExpireRollback Action = 1
	// The lock does not exist, TinyKV left a record of the rollback, but did not
	// have to delete a lock.
	Action_LockNotExistRollback Action = 2
)

func (Action) EnumDescriptor 

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

func (Action) String 

func (x Action) String() string

type BatchRollbackRequest 

type BatchRollbackRequest 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"`
	Keys                 [][]byte `protobuf:"bytes,3,rep,name=keys" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Rollback an un-committed transaction. Will fail if the transaction has already been committed or keys are locked by a different transaction. If the keys were never locked, no action is needed but it is not an error. If successful all keys will be unlocked and all uncommitted values removed.

func (*BatchRollbackRequest) Descriptor 

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

func (*BatchRollbackRequest) GetContext 

func (m *BatchRollbackRequest) GetContext() *Context

func (*BatchRollbackRequest) GetKeys 

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

func (*BatchRollbackRequest) GetStartVersion 

func (m *BatchRollbackRequest) GetStartVersion() uint64

func (*BatchRollbackRequest) Marshal 

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

func (*BatchRollbackRequest) MarshalTo 

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

func (*BatchRollbackRequest) ProtoMessage 

func (*BatchRollbackRequest) ProtoMessage()

func (*BatchRollbackRequest) Reset 

func (m *BatchRollbackRequest) Reset()

func (*BatchRollbackRequest) Size 

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

func (*BatchRollbackRequest) String 

func (m *BatchRollbackRequest) String() string

func (*BatchRollbackRequest) Unmarshal 

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

func (*BatchRollbackRequest) XXX_DiscardUnknown 

func (m *BatchRollbackRequest) XXX_DiscardUnknown()

func (*BatchRollbackRequest) XXX_Marshal 

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

func (*BatchRollbackRequest) XXX_Merge 

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

func (*BatchRollbackRequest) XXX_Size 

func (m *BatchRollbackRequest) XXX_Size() int

func (*BatchRollbackRequest) XXX_Unmarshal 

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

type BatchRollbackResponse 

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:"-"`
}

Empty if the rollback is successful.

func (*BatchRollbackResponse) Descriptor 

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

func (*BatchRollbackResponse) GetError 

func (m *BatchRollbackResponse) GetError() *KeyError

func (*BatchRollbackResponse) GetRegionError 

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

func (*BatchRollbackResponse) Marshal 

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

func (*BatchRollbackResponse) MarshalTo 

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

func (*BatchRollbackResponse) ProtoMessage 

func (*BatchRollbackResponse) ProtoMessage()

func (*BatchRollbackResponse) Reset 

func (m *BatchRollbackResponse) Reset()

func (*BatchRollbackResponse) Size 

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

func (*BatchRollbackResponse) String 

func (m *BatchRollbackResponse) String() string

func (*BatchRollbackResponse) Unmarshal 

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

func (*BatchRollbackResponse) XXX_DiscardUnknown 

func (m *BatchRollbackResponse) XXX_DiscardUnknown()

func (*BatchRollbackResponse) XXX_Marshal 

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

func (*BatchRollbackResponse) XXX_Merge 

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

func (*BatchRollbackResponse) XXX_Size 

func (m *BatchRollbackResponse) XXX_Size() int

func (*BatchRollbackResponse) XXX_Unmarshal 

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

type CheckTxnStatusRequest 

type CheckTxnStatusRequest struct {
	Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	PrimaryKey           []byte   `protobuf:"bytes,2,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	LockTs               uint64   `protobuf:"varint,3,opt,name=lock_ts,json=lockTs,proto3" json:"lock_ts,omitempty"`
	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:"-"`
}

CheckTxnStatus reports on the status of a transaction and may take action to rollback expired locks. If the transaction has previously been rolled back or committed, return that information. If the TTL of the transaction is exhausted, abort that transaction and roll back the primary lock. Otherwise, returns the TTL information.

func (*CheckTxnStatusRequest) Descriptor 

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

func (*CheckTxnStatusRequest) GetContext 

func (m *CheckTxnStatusRequest) GetContext() *Context

func (*CheckTxnStatusRequest) GetCurrentTs 

func (m *CheckTxnStatusRequest) GetCurrentTs() uint64

func (*CheckTxnStatusRequest) GetLockTs 

func (m *CheckTxnStatusRequest) GetLockTs() uint64

func (*CheckTxnStatusRequest) GetPrimaryKey 

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

func (*CheckTxnStatusRequest) Marshal 

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

func (*CheckTxnStatusRequest) MarshalTo 

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

func (*CheckTxnStatusRequest) ProtoMessage 

func (*CheckTxnStatusRequest) ProtoMessage()

func (*CheckTxnStatusRequest) Reset 

func (m *CheckTxnStatusRequest) Reset()

func (*CheckTxnStatusRequest) Size 

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

func (*CheckTxnStatusRequest) String 

func (m *CheckTxnStatusRequest) String() string

func (*CheckTxnStatusRequest) Unmarshal 

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

func (*CheckTxnStatusRequest) XXX_DiscardUnknown 

func (m *CheckTxnStatusRequest) XXX_DiscardUnknown()

func (*CheckTxnStatusRequest) XXX_Marshal 

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

func (*CheckTxnStatusRequest) XXX_Merge 

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

func (*CheckTxnStatusRequest) XXX_Size 

func (m *CheckTxnStatusRequest) XXX_Size() int

func (*CheckTxnStatusRequest) XXX_Unmarshal 

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

type CheckTxnStatusResponse 

type CheckTxnStatusResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	// Three kinds of txn status:
	// locked: lock_ttl > 0
	// committed: commit_version > 0
	// rolled back: lock_ttl == 0 && commit_version == 0
	LockTtl       uint64 `protobuf:"varint,2,opt,name=lock_ttl,json=lockTtl,proto3" json:"lock_ttl,omitempty"`
	CommitVersion uint64 `protobuf:"varint,3,opt,name=commit_version,json=commitVersion,proto3" json:"commit_version,omitempty"`
	// The action performed by TinyKV in response to the CheckTxnStatus request.
	Action               Action   `protobuf:"varint,4,opt,name=action,proto3,enum=kvrpcpb.Action" json:"action,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckTxnStatusResponse) Descriptor 

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

func (*CheckTxnStatusResponse) GetAction 

func (m *CheckTxnStatusResponse) GetAction() Action

func (*CheckTxnStatusResponse) GetCommitVersion 

func (m *CheckTxnStatusResponse) GetCommitVersion() uint64

func (*CheckTxnStatusResponse) GetLockTtl 

func (m *CheckTxnStatusResponse) GetLockTtl() uint64

func (*CheckTxnStatusResponse) GetRegionError 

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

func (*CheckTxnStatusResponse) Marshal 

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

func (*CheckTxnStatusResponse) MarshalTo 

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

func (*CheckTxnStatusResponse) ProtoMessage 

func (*CheckTxnStatusResponse) ProtoMessage()

func (*CheckTxnStatusResponse) Reset 

func (m *CheckTxnStatusResponse) Reset()

func (*CheckTxnStatusResponse) Size 

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

func (*CheckTxnStatusResponse) String 

func (m *CheckTxnStatusResponse) String() string

func (*CheckTxnStatusResponse) Unmarshal 

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

func (*CheckTxnStatusResponse) XXX_DiscardUnknown 

func (m *CheckTxnStatusResponse) XXX_DiscardUnknown()

func (*CheckTxnStatusResponse) XXX_Marshal 

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

func (*CheckTxnStatusResponse) XXX_Merge 

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

func (*CheckTxnStatusResponse) XXX_Size 

func (m *CheckTxnStatusResponse) XXX_Size() int

func (*CheckTxnStatusResponse) XXX_Unmarshal 

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

type CommitRequest 

type CommitRequest struct {
	Context *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	// Identifies the transaction, must match the start_version in the transaction's
	// prewrite request.
	StartVersion uint64 `protobuf:"varint,2,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	// Must match the keys mutated by the transaction's prewrite request.
	Keys [][]byte `protobuf:"bytes,3,rep,name=keys" json:"keys,omitempty"`
	// 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:"-"`
}

Commit is the second phase of 2pc. The client must have successfully prewritten the transaction to all nodes. If all keys are locked by the given transaction, then the commit should succeed. If any keys are locked by a different transaction or are not locked at all (rolled back or expired), the commit fails.

func (*CommitRequest) Descriptor 

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

func (*CommitRequest) GetCommitVersion 

func (m *CommitRequest) GetCommitVersion() uint64

func (*CommitRequest) GetContext 

func (m *CommitRequest) GetContext() *Context

func (*CommitRequest) GetKeys 

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

func (*CommitRequest) GetStartVersion 

func (m *CommitRequest) GetStartVersion() uint64

func (*CommitRequest) Marshal 

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

func (*CommitRequest) MarshalTo 

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

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) Reset 

func (m *CommitRequest) Reset()

func (*CommitRequest) Size 

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

func (*CommitRequest) String 

func (m *CommitRequest) String() string

func (*CommitRequest) Unmarshal 

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

func (*CommitRequest) XXX_DiscardUnknown 

func (m *CommitRequest) XXX_DiscardUnknown()

func (*CommitRequest) XXX_Marshal 

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

func (*CommitRequest) XXX_Merge 

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

func (*CommitRequest) XXX_Size 

func (m *CommitRequest) XXX_Size() int

func (*CommitRequest) XXX_Unmarshal 

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

type CommitResponse 

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

Empty if the commit is successful.

func (*CommitResponse) Descriptor 

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

func (*CommitResponse) GetError 

func (m *CommitResponse) GetError() *KeyError

func (*CommitResponse) GetRegionError 

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

func (*CommitResponse) Marshal 

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

func (*CommitResponse) MarshalTo 

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

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) Reset 

func (m *CommitResponse) Reset()

func (*CommitResponse) Size 

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

func (*CommitResponse) String 

func (m *CommitResponse) String() string

func (*CommitResponse) Unmarshal 

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

func (*CommitResponse) XXX_DiscardUnknown 

func (m *CommitResponse) XXX_DiscardUnknown()

func (*CommitResponse) XXX_Marshal 

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

func (*CommitResponse) XXX_Merge 

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

func (*CommitResponse) XXX_Size 

func (m *CommitResponse) XXX_Size() int

func (*CommitResponse) XXX_Unmarshal 

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

type Context 

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

Miscellaneous data present in each request.

func (*Context) Descriptor 

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

func (*Context) GetPeer 

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

func (*Context) GetRegionEpoch 

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

func (*Context) GetRegionId 

func (m *Context) GetRegionId() uint64

func (*Context) GetTerm 

func (m *Context) GetTerm() uint64

func (*Context) Marshal 

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

func (*Context) MarshalTo 

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

func (*Context) ProtoMessage 

func (*Context) ProtoMessage()

func (*Context) Reset 

func (m *Context) Reset()

func (*Context) Size 

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

func (*Context) String 

func (m *Context) String() string

func (*Context) Unmarshal 

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

func (*Context) XXX_DiscardUnknown 

func (m *Context) XXX_DiscardUnknown()

func (*Context) XXX_Marshal 

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

func (*Context) XXX_Merge 

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

func (*Context) XXX_Size 

func (m *Context) XXX_Size() int

func (*Context) XXX_Unmarshal 

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

type GetRequest 

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:"-"`
}

Read the value of a key at the given time.

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetContext 

func (m *GetRequest) GetContext() *Context

func (*GetRequest) GetKey 

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

func (*GetRequest) GetVersion 

func (m *GetRequest) GetVersion() uint64

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetResponse 

type GetResponse 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"`
	Value       []byte         `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// True if the requested key doesn't exist; another error will not be signalled.
	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 

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

func (*GetResponse) GetError 

func (m *GetResponse) GetError() *KeyError

func (*GetResponse) GetNotFound 

func (m *GetResponse) GetNotFound() bool

func (*GetResponse) GetRegionError 

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

func (*GetResponse) GetValue 

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

func (*GetResponse) Marshal 

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

func (*GetResponse) MarshalTo 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type KeyError 

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

Many responses can include a KeyError for some problem with one of the requested key. Only one field is set and it indicates what the client should do in response.

func (*KeyError) Descriptor 

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

func (*KeyError) GetAbort 

func (m *KeyError) GetAbort() string

func (*KeyError) GetConflict 

func (m *KeyError) GetConflict() *WriteConflict

func (*KeyError) GetLocked 

func (m *KeyError) GetLocked() *LockInfo

func (*KeyError) GetRetryable 

func (m *KeyError) GetRetryable() string

func (*KeyError) Marshal 

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

func (*KeyError) MarshalTo 

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

func (*KeyError) ProtoMessage 

func (*KeyError) ProtoMessage()

func (*KeyError) Reset 

func (m *KeyError) Reset()

func (*KeyError) Size 

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

func (*KeyError) String 

func (m *KeyError) String() string

func (*KeyError) Unmarshal 

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

func (*KeyError) XXX_DiscardUnknown 

func (m *KeyError) XXX_DiscardUnknown()

func (*KeyError) XXX_Marshal 

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

func (*KeyError) XXX_Merge 

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

func (*KeyError) XXX_Size 

func (m *KeyError) XXX_Size() int

func (*KeyError) XXX_Unmarshal 

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

type KvPair 

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:"-"`
}

Either a key/value pair or an error for a particular key.

func (*KvPair) Descriptor 

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

func (*KvPair) GetError 

func (m *KvPair) GetError() *KeyError

func (*KvPair) GetKey 

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

func (*KvPair) GetValue 

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

func (*KvPair) Marshal 

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

func (*KvPair) MarshalTo 

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

func (*KvPair) ProtoMessage 

func (*KvPair) ProtoMessage()

func (*KvPair) Reset 

func (m *KvPair) Reset()

func (*KvPair) Size 

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

func (*KvPair) String 

func (m *KvPair) String() string

func (*KvPair) Unmarshal 

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

func (*KvPair) XXX_DiscardUnknown 

func (m *KvPair) XXX_DiscardUnknown()

func (*KvPair) XXX_Marshal 

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

func (*KvPair) XXX_Merge 

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

func (*KvPair) XXX_Size 

func (m *KvPair) XXX_Size() int

func (*KvPair) XXX_Unmarshal 

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

type LockInfo 

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

func (*LockInfo) Descriptor 

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

func (*LockInfo) GetKey 

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

func (*LockInfo) GetLockTtl 

func (m *LockInfo) GetLockTtl() uint64

func (*LockInfo) GetLockVersion 

func (m *LockInfo) GetLockVersion() uint64

func (*LockInfo) GetPrimaryLock 

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

func (*LockInfo) Marshal 

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

func (*LockInfo) MarshalTo 

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

func (*LockInfo) ProtoMessage 

func (*LockInfo) ProtoMessage()

func (*LockInfo) Reset 

func (m *LockInfo) Reset()

func (*LockInfo) Size 

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

func (*LockInfo) String 

func (m *LockInfo) String() string

func (*LockInfo) Unmarshal 

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

func (*LockInfo) XXX_DiscardUnknown 

func (m *LockInfo) XXX_DiscardUnknown()

func (*LockInfo) XXX_Marshal 

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

func (*LockInfo) XXX_Merge 

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

func (*LockInfo) XXX_Size 

func (m *LockInfo) XXX_Size() int

func (*LockInfo) XXX_Unmarshal 

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

type Mutation 

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

func (*Mutation) Descriptor 

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

func (*Mutation) GetKey 

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

func (*Mutation) GetOp 

func (m *Mutation) GetOp() Op

func (*Mutation) GetValue 

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

func (*Mutation) Marshal 

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

func (*Mutation) MarshalTo 

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

func (*Mutation) ProtoMessage 

func (*Mutation) ProtoMessage()

func (*Mutation) Reset 

func (m *Mutation) Reset()

func (*Mutation) Size 

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

func (*Mutation) String 

func (m *Mutation) String() string

func (*Mutation) Unmarshal 

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

func (*Mutation) XXX_DiscardUnknown 

func (m *Mutation) XXX_DiscardUnknown()

func (*Mutation) XXX_Marshal 

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

func (*Mutation) XXX_Merge 

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

func (*Mutation) XXX_Size 

func (m *Mutation) XXX_Size() int

func (*Mutation) XXX_Unmarshal 

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

type Op 

type Op int32
const (
	Op_Put      Op = 0
	Op_Del      Op = 1
	Op_Rollback Op = 2
	// Used by TinySQL but not TinyKV.
	Op_Lock Op = 3
)

func (Op) EnumDescriptor 

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

func (Op) String 

func (x Op) String() string

type PrewriteRequest 

type PrewriteRequest struct {
	Context   *Context    `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Mutations []*Mutation `protobuf:"bytes,2,rep,name=mutations" json:"mutations,omitempty"`
	// Key of the primary lock.
	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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Prewrite is the first phase of two phase commit. A prewrite commit contains all the writes (mutations) which a client would like to make as part of a transaction. The request succeeds if none of the keys are locked. In that case all those keys will be locked. If the prewrite fails, no changes are made to the DB.

func (*PrewriteRequest) Descriptor 

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

func (*PrewriteRequest) GetContext 

func (m *PrewriteRequest) GetContext() *Context

func (*PrewriteRequest) GetLockTtl 

func (m *PrewriteRequest) GetLockTtl() uint64

func (*PrewriteRequest) GetMutations 

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

func (*PrewriteRequest) GetPrimaryLock 

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

func (*PrewriteRequest) GetStartVersion 

func (m *PrewriteRequest) GetStartVersion() uint64

func (*PrewriteRequest) Marshal 

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

func (*PrewriteRequest) MarshalTo 

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

func (*PrewriteRequest) ProtoMessage 

func (*PrewriteRequest) ProtoMessage()

func (*PrewriteRequest) Reset 

func (m *PrewriteRequest) Reset()

func (*PrewriteRequest) Size 

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

func (*PrewriteRequest) String 

func (m *PrewriteRequest) String() string

func (*PrewriteRequest) Unmarshal 

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

func (*PrewriteRequest) XXX_DiscardUnknown 

func (m *PrewriteRequest) XXX_DiscardUnknown()

func (*PrewriteRequest) XXX_Marshal 

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

func (*PrewriteRequest) XXX_Merge 

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

func (*PrewriteRequest) XXX_Size 

func (m *PrewriteRequest) XXX_Size() int

func (*PrewriteRequest) XXX_Unmarshal 

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

type PrewriteResponse 

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

Empty if the prewrite is successful.

func (*PrewriteResponse) Descriptor 

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

func (*PrewriteResponse) GetErrors 

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

func (*PrewriteResponse) GetRegionError 

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

func (*PrewriteResponse) Marshal 

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

func (*PrewriteResponse) MarshalTo 

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

func (*PrewriteResponse) ProtoMessage 

func (*PrewriteResponse) ProtoMessage()

func (*PrewriteResponse) Reset 

func (m *PrewriteResponse) Reset()

func (*PrewriteResponse) Size 

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

func (*PrewriteResponse) String 

func (m *PrewriteResponse) String() string

func (*PrewriteResponse) Unmarshal 

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

func (*PrewriteResponse) XXX_DiscardUnknown 

func (m *PrewriteResponse) XXX_DiscardUnknown()

func (*PrewriteResponse) XXX_Marshal 

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

func (*PrewriteResponse) XXX_Merge 

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

func (*PrewriteResponse) XXX_Size 

func (m *PrewriteResponse) XXX_Size() int

func (*PrewriteResponse) XXX_Unmarshal 

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

type RawDeleteRequest 

type RawDeleteRequest struct {
	Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,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 (*RawDeleteRequest) Descriptor 

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

func (*RawDeleteRequest) GetCf 

func (m *RawDeleteRequest) GetCf() string

func (*RawDeleteRequest) GetContext 

func (m *RawDeleteRequest) GetContext() *Context

func (*RawDeleteRequest) GetKey 

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

func (*RawDeleteRequest) Marshal 

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

func (*RawDeleteRequest) MarshalTo 

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

func (*RawDeleteRequest) ProtoMessage 

func (*RawDeleteRequest) ProtoMessage()

func (*RawDeleteRequest) Reset 

func (m *RawDeleteRequest) Reset()

func (*RawDeleteRequest) Size 

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

func (*RawDeleteRequest) String 

func (m *RawDeleteRequest) String() string

func (*RawDeleteRequest) Unmarshal 

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

func (*RawDeleteRequest) XXX_DiscardUnknown 

func (m *RawDeleteRequest) XXX_DiscardUnknown()

func (*RawDeleteRequest) XXX_Marshal 

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

func (*RawDeleteRequest) XXX_Merge 

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

func (*RawDeleteRequest) XXX_Size 

func (m *RawDeleteRequest) XXX_Size() int

func (*RawDeleteRequest) XXX_Unmarshal 

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

type RawDeleteResponse 

type RawDeleteResponse 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 (*RawDeleteResponse) Descriptor 

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

func (*RawDeleteResponse) GetError 

func (m *RawDeleteResponse) GetError() string

func (*RawDeleteResponse) GetRegionError 

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

func (*RawDeleteResponse) Marshal 

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

func (*RawDeleteResponse) MarshalTo 

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

func (*RawDeleteResponse) ProtoMessage 

func (*RawDeleteResponse) ProtoMessage()

func (*RawDeleteResponse) Reset 

func (m *RawDeleteResponse) Reset()

func (*RawDeleteResponse) Size 

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

func (*RawDeleteResponse) String 

func (m *RawDeleteResponse) String() string

func (*RawDeleteResponse) Unmarshal 

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

func (*RawDeleteResponse) XXX_DiscardUnknown 

func (m *RawDeleteResponse) XXX_DiscardUnknown()

func (*RawDeleteResponse) XXX_Marshal 

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

func (*RawDeleteResponse) XXX_Merge 

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

func (*RawDeleteResponse) XXX_Size 

func (m *RawDeleteResponse) XXX_Size() int

func (*RawDeleteResponse) XXX_Unmarshal 

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

type RawGetRequest 

type RawGetRequest struct {
	Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"`
	Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,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:"-"`
}

Raw commands.

func (*RawGetRequest) Descriptor 

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

func (*RawGetRequest) GetCf 

func (m *RawGetRequest) GetCf() string

func (*RawGetRequest) GetContext 

func (m *RawGetRequest) GetContext() *Context

func (*RawGetRequest) GetKey 

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

func (*RawGetRequest) Marshal 

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

func (*RawGetRequest) MarshalTo 

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

func (*RawGetRequest) ProtoMessage 

func (*RawGetRequest) ProtoMessage()

func (*RawGetRequest) Reset 

func (m *RawGetRequest) Reset()

func (*RawGetRequest) Size 

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

func (*RawGetRequest) String 

func (m *RawGetRequest) String() string

func (*RawGetRequest) Unmarshal 

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

func (*RawGetRequest) XXX_DiscardUnknown 

func (m *RawGetRequest) XXX_DiscardUnknown()

func (*RawGetRequest) XXX_Marshal 

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

func (*RawGetRequest) XXX_Merge 

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

func (*RawGetRequest) XXX_Size 

func (m *RawGetRequest) XXX_Size() int

func (*RawGetRequest) XXX_Unmarshal 

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

type RawGetResponse 

type RawGetResponse 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"`
	Value       []byte         `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// True if the requested key doesn't exist; another error will not be signalled.
	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 (*RawGetResponse) Descriptor 

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

func (*RawGetResponse) GetError 

func (m *RawGetResponse) GetError() string

func (*RawGetResponse) GetNotFound 

func (m *RawGetResponse) GetNotFound() bool

func (*RawGetResponse) GetRegionError 

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

func (*RawGetResponse) GetValue 

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

func (*RawGetResponse) Marshal 

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

func (*RawGetResponse) MarshalTo 

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

func (*RawGetResponse) ProtoMessage 

func (*RawGetResponse) ProtoMessage()

func (*RawGetResponse) Reset 

func (m *RawGetResponse) Reset()

func (*RawGetResponse) Size 

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

func (*RawGetResponse) String 

func (m *RawGetResponse) String() string

func (*RawGetResponse) Unmarshal 

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

func (*RawGetResponse) XXX_DiscardUnknown 

func (m *RawGetResponse) XXX_DiscardUnknown()

func (*RawGetResponse) XXX_Marshal 

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

func (*RawGetResponse) XXX_Merge 

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

func (*RawGetResponse) XXX_Size 

func (m *RawGetResponse) XXX_Size() int

func (*RawGetResponse) XXX_Unmarshal 

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

type RawPutRequest 

type RawPutRequest struct {
	Context              *Context `protobuf:"bytes,1,opt,name=context" json:"context,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"`
	Cf                   string   `protobuf:"bytes,4,opt,name=cf,proto3" json:"cf,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawPutRequest) Descriptor 

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

func (*RawPutRequest) GetCf 

func (m *RawPutRequest) GetCf() string

func (*RawPutRequest) GetContext 

func (m *RawPutRequest) GetContext() *Context

func (*RawPutRequest) GetKey 

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

func (*RawPutRequest) GetValue 

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

func (*RawPutRequest) Marshal 

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

func (*RawPutRequest) MarshalTo 

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

func (*RawPutRequest) ProtoMessage 

func (*RawPutRequest) ProtoMessage()

func (*RawPutRequest) Reset 

func (m *RawPutRequest) Reset()

func (*RawPutRequest) Size 

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

func (*RawPutRequest) String 

func (m *RawPutRequest) String() string

func (*RawPutRequest) Unmarshal 

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

func (*RawPutRequest) XXX_DiscardUnknown 

func (m *RawPutRequest) XXX_DiscardUnknown()

func (*RawPutRequest) XXX_Marshal 

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

func (*RawPutRequest) XXX_Merge 

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

func (*RawPutRequest) XXX_Size 

func (m *RawPutRequest) XXX_Size() int

func (*RawPutRequest) XXX_Unmarshal 

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

type RawPutResponse 

type RawPutResponse 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 (*RawPutResponse) Descriptor 

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

func (*RawPutResponse) GetError 

func (m *RawPutResponse) GetError() string

func (*RawPutResponse) GetRegionError 

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

func (*RawPutResponse) Marshal 

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

func (*RawPutResponse) MarshalTo 

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

func (*RawPutResponse) ProtoMessage 

func (*RawPutResponse) ProtoMessage()

func (*RawPutResponse) Reset 

func (m *RawPutResponse) Reset()

func (*RawPutResponse) Size 

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

func (*RawPutResponse) String 

func (m *RawPutResponse) String() string

func (*RawPutResponse) Unmarshal 

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

func (*RawPutResponse) XXX_DiscardUnknown 

func (m *RawPutResponse) XXX_DiscardUnknown()

func (*RawPutResponse) XXX_Marshal 

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

func (*RawPutResponse) XXX_Merge 

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

func (*RawPutResponse) XXX_Size 

func (m *RawPutResponse) XXX_Size() int

func (*RawPutResponse) XXX_Unmarshal 

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

type RawScanRequest 

type RawScanRequest 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"`
	// The maximum number of values read.
	Limit                uint32   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Cf                   string   `protobuf:"bytes,4,opt,name=cf,proto3" json:"cf,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawScanRequest) Descriptor 

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

func (*RawScanRequest) GetCf 

func (m *RawScanRequest) GetCf() string

func (*RawScanRequest) GetContext 

func (m *RawScanRequest) GetContext() *Context

func (*RawScanRequest) GetLimit 

func (m *RawScanRequest) GetLimit() uint32

func (*RawScanRequest) GetStartKey 

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

func (*RawScanRequest) Marshal 

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

func (*RawScanRequest) MarshalTo 

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

func (*RawScanRequest) ProtoMessage 

func (*RawScanRequest) ProtoMessage()

func (*RawScanRequest) Reset 

func (m *RawScanRequest) Reset()

func (*RawScanRequest) Size 

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

func (*RawScanRequest) String 

func (m *RawScanRequest) String() string

func (*RawScanRequest) Unmarshal 

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

func (*RawScanRequest) XXX_DiscardUnknown 

func (m *RawScanRequest) XXX_DiscardUnknown()

func (*RawScanRequest) XXX_Marshal 

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

func (*RawScanRequest) XXX_Merge 

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

func (*RawScanRequest) XXX_Size 

func (m *RawScanRequest) XXX_Size() int

func (*RawScanRequest) XXX_Unmarshal 

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

type RawScanResponse 

type RawScanResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	// An error which affects the whole scan. Per-key errors are included in kvs.
	Error                string    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Kvs                  []*KvPair `protobuf:"bytes,3,rep,name=kvs" json:"kvs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RawScanResponse) Descriptor 

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

func (*RawScanResponse) GetError 

func (m *RawScanResponse) GetError() string

func (*RawScanResponse) GetKvs 

func (m *RawScanResponse) GetKvs() []*KvPair

func (*RawScanResponse) GetRegionError 

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

func (*RawScanResponse) Marshal 

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

func (*RawScanResponse) MarshalTo 

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

func (*RawScanResponse) ProtoMessage 

func (*RawScanResponse) ProtoMessage()

func (*RawScanResponse) Reset 

func (m *RawScanResponse) Reset()

func (*RawScanResponse) Size 

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

func (*RawScanResponse) String 

func (m *RawScanResponse) String() string

func (*RawScanResponse) Unmarshal 

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

func (*RawScanResponse) XXX_DiscardUnknown 

func (m *RawScanResponse) XXX_DiscardUnknown()

func (*RawScanResponse) XXX_Marshal 

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

func (*RawScanResponse) XXX_Merge 

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

func (*RawScanResponse) XXX_Size 

func (m *RawScanResponse) XXX_Size() int

func (*RawScanResponse) XXX_Unmarshal 

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

type ResolveLockRequest 

type ResolveLockRequest 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"`
	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:"-"`
}

Resolve lock will find all locks belonging to the transaction with the given start timestamp. If commit_version is 0, TinyKV will rollback all locks. If commit_version is greater than 0 it will commit those locks with the given commit timestamp. The client will make a resolve lock request for all secondary keys once it has successfully committed or rolled back the primary key.

func (*ResolveLockRequest) Descriptor 

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

func (*ResolveLockRequest) GetCommitVersion 

func (m *ResolveLockRequest) GetCommitVersion() uint64

func (*ResolveLockRequest) GetContext 

func (m *ResolveLockRequest) GetContext() *Context

func (*ResolveLockRequest) GetStartVersion 

func (m *ResolveLockRequest) GetStartVersion() uint64

func (*ResolveLockRequest) Marshal 

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

func (*ResolveLockRequest) MarshalTo 

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

func (*ResolveLockRequest) ProtoMessage 

func (*ResolveLockRequest) ProtoMessage()

func (*ResolveLockRequest) Reset 

func (m *ResolveLockRequest) Reset()

func (*ResolveLockRequest) Size 

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

func (*ResolveLockRequest) String 

func (m *ResolveLockRequest) String() string

func (*ResolveLockRequest) Unmarshal 

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

func (*ResolveLockRequest) XXX_DiscardUnknown 

func (m *ResolveLockRequest) XXX_DiscardUnknown()

func (*ResolveLockRequest) XXX_Marshal 

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

func (*ResolveLockRequest) XXX_Merge 

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

func (*ResolveLockRequest) XXX_Size 

func (m *ResolveLockRequest) XXX_Size() int

func (*ResolveLockRequest) XXX_Unmarshal 

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

type ResolveLockResponse 

type ResolveLockResponse 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:"-"`
}

Empty if the lock is resolved successfully.

func (*ResolveLockResponse) Descriptor 

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

func (*ResolveLockResponse) GetError 

func (m *ResolveLockResponse) GetError() *KeyError

func (*ResolveLockResponse) GetRegionError 

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

func (*ResolveLockResponse) Marshal 

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

func (*ResolveLockResponse) MarshalTo 

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

func (*ResolveLockResponse) ProtoMessage 

func (*ResolveLockResponse) ProtoMessage()

func (*ResolveLockResponse) Reset 

func (m *ResolveLockResponse) Reset()

func (*ResolveLockResponse) Size 

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

func (*ResolveLockResponse) String 

func (m *ResolveLockResponse) String() string

func (*ResolveLockResponse) Unmarshal 

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

func (*ResolveLockResponse) XXX_DiscardUnknown 

func (m *ResolveLockResponse) XXX_DiscardUnknown()

func (*ResolveLockResponse) XXX_Marshal 

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

func (*ResolveLockResponse) XXX_Merge 

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

func (*ResolveLockResponse) XXX_Size 

func (m *ResolveLockResponse) XXX_Size() int

func (*ResolveLockResponse) XXX_Unmarshal 

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

type ScanRequest 

type ScanRequest 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"`
	// The maximum number of values read.
	Limit                uint32   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Version              uint64   `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Read multiple values from the DB.

func (*ScanRequest) Descriptor 

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

func (*ScanRequest) GetContext 

func (m *ScanRequest) GetContext() *Context

func (*ScanRequest) GetLimit 

func (m *ScanRequest) GetLimit() uint32

func (*ScanRequest) GetStartKey 

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

func (*ScanRequest) GetVersion 

func (m *ScanRequest) GetVersion() uint64

func (*ScanRequest) Marshal 

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

func (*ScanRequest) MarshalTo 

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

func (*ScanRequest) ProtoMessage 

func (*ScanRequest) ProtoMessage()

func (*ScanRequest) Reset 

func (m *ScanRequest) Reset()

func (*ScanRequest) Size 

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

func (*ScanRequest) String 

func (m *ScanRequest) String() string

func (*ScanRequest) Unmarshal 

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

func (*ScanRequest) XXX_DiscardUnknown 

func (m *ScanRequest) XXX_DiscardUnknown()

func (*ScanRequest) XXX_Marshal 

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

func (*ScanRequest) XXX_Merge 

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

func (*ScanRequest) XXX_Size 

func (m *ScanRequest) XXX_Size() int

func (*ScanRequest) XXX_Unmarshal 

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

type ScanResponse 

type ScanResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError" json:"region_error,omitempty"`
	// Other errors are recorded for each key in pairs.
	Pairs                []*KvPair `protobuf:"bytes,2,rep,name=pairs" json:"pairs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ScanResponse) Descriptor 

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

func (*ScanResponse) GetPairs 

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

func (*ScanResponse) GetRegionError 

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

func (*ScanResponse) Marshal 

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

func (*ScanResponse) MarshalTo 

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

func (*ScanResponse) ProtoMessage 

func (*ScanResponse) ProtoMessage()

func (*ScanResponse) Reset 

func (m *ScanResponse) Reset()

func (*ScanResponse) Size 

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

func (*ScanResponse) String 

func (m *ScanResponse) String() string

func (*ScanResponse) Unmarshal 

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

func (*ScanResponse) XXX_DiscardUnknown 

func (m *ScanResponse) XXX_DiscardUnknown()

func (*ScanResponse) XXX_Marshal 

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

func (*ScanResponse) XXX_Merge 

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

func (*ScanResponse) XXX_Size 

func (m *ScanResponse) XXX_Size() int

func (*ScanResponse) XXX_Unmarshal 

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

type WriteConflict 

type WriteConflict struct {
	StartTs              uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	ConflictTs           uint64   `protobuf:"varint,2,opt,name=conflict_ts,json=conflictTs,proto3" json:"conflict_ts,omitempty"`
	Key                  []byte   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Primary              []byte   `protobuf:"bytes,4,opt,name=primary,proto3" json:"primary,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteConflict) Descriptor 

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

func (*WriteConflict) GetConflictTs 

func (m *WriteConflict) GetConflictTs() uint64

func (*WriteConflict) GetKey 

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

func (*WriteConflict) GetPrimary 

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

func (*WriteConflict) GetStartTs 

func (m *WriteConflict) GetStartTs() uint64

func (*WriteConflict) Marshal 

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

func (*WriteConflict) MarshalTo 

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

func (*WriteConflict) ProtoMessage 

func (*WriteConflict) ProtoMessage()

func (*WriteConflict) Reset 

func (m *WriteConflict) Reset()

func (*WriteConflict) Size 

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

func (*WriteConflict) String 

func (m *WriteConflict) String() string

func (*WriteConflict) Unmarshal 

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

func (*WriteConflict) XXX_DiscardUnknown 

func (m *WriteConflict) XXX_DiscardUnknown()

func (*WriteConflict) XXX_Marshal 

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

func (*WriteConflict) XXX_Merge 

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

func (*WriteConflict) XXX_Size 

func (m *WriteConflict) XXX_Size() int

func (*WriteConflict) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.