548 lines
16 KiB
Go
548 lines
16 KiB
Go
|
// Code generated by protoc-gen-go.
|
||
|
|
// source: Themis.proto
|
||
|
|
// DO NOT EDIT!
|
||
|
|
|
||
|
|
/*
|
||
|
|
Package Themis is a generated protocol buffer package.
|
||
|
|
|
||
|
|
It is generated from these files:
|
||
|
|
Themis.proto
|
||
|
|
|
||
|
|
It has these top-level messages:
|
||
|
|
ThemisGetRequest
|
||
|
|
ThemisBatchGetRequest
|
||
|
|
ThemisBatchGetResponse
|
||
|
|
ThemisPrewrite
|
||
|
|
ThemisPrewriteRequest
|
||
|
|
ThemisPrewriteResponse
|
||
|
|
ThemisBatchPrewriteSecondaryRequest
|
||
|
|
ThemisBatchPrewriteSecondaryResponse
|
||
|
|
ThemisPrewriteResult
|
||
|
|
ThemisCommitRequest
|
||
|
|
ThemisCommitResponse
|
||
|
|
ThemisBatchCommitSecondaryRequest
|
||
|
|
ThemisBatchCommitSecondaryResponse
|
||
|
|
ThemisBatchCommitSecondaryResult
|
||
|
|
ThemisCommit
|
||
|
|
EraseLockRequest
|
||
|
|
EraseLockResponse
|
||
|
|
LockExpiredRequest
|
||
|
|
LockExpiredResponse
|
||
|
|
*/
|
||
|
|
package themis
|
||
|
|
|
||
|
|
import proto "github.com/golang/protobuf/proto"
|
||
|
|
import fmt "fmt"
|
||
|
|
import math "math"
|
||
|
|
import Client "github.com/pingcap/go-hbase/proto"
|
||
|
|
import Cell "github.com/pingcap/go-hbase/proto"
|
||
|
|
|
||
|
|
// Reference imports to suppress errors if they are not otherwise used.
|
||
|
|
var _ = proto.Marshal
|
||
|
|
var _ = fmt.Errorf
|
||
|
|
var _ = math.Inf
|
||
|
|
|
||
|
|
type ThemisGetRequest struct {
|
||
|
|
Get *Client.Get `protobuf:"bytes,1,req,name=get" json:"get,omitempty"`
|
||
|
|
StartTs *uint64 `protobuf:"varint,2,req,name=startTs" json:"startTs,omitempty"`
|
||
|
|
IgnoreLock *bool `protobuf:"varint,3,req,name=ignoreLock" json:"ignoreLock,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisGetRequest) Reset() { *m = ThemisGetRequest{} }
|
||
|
|
func (m *ThemisGetRequest) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisGetRequest) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisGetRequest) GetGet() *Client.Get {
|
||
|
|
if m != nil {
|
||
|
|
return m.Get
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisGetRequest) GetStartTs() uint64 {
|
||
|
|
if m != nil && m.StartTs != nil {
|
||
|
|
return *m.StartTs
|
||
|
|
}
|
||
|
|
return 0
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisGetRequest) GetIgnoreLock() bool {
|
||
|
|
if m != nil && m.IgnoreLock != nil {
|
||
|
|
return *m.IgnoreLock
|
||
|
|
}
|
||
|
|
return false
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisBatchGetRequest struct {
|
||
|
|
Gets []*Client.Get `protobuf:"bytes,1,rep,name=gets" json:"gets,omitempty"`
|
||
|
|
StartTs *uint64 `protobuf:"varint,2,req,name=startTs" json:"startTs,omitempty"`
|
||
|
|
IgnoreLock *bool `protobuf:"varint,3,req,name=ignoreLock" json:"ignoreLock,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchGetRequest) Reset() { *m = ThemisBatchGetRequest{} }
|
||
|
|
func (m *ThemisBatchGetRequest) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisBatchGetRequest) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisBatchGetRequest) GetGets() []*Client.Get {
|
||
|
|
if m != nil {
|
||
|
|
return m.Gets
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchGetRequest) GetStartTs() uint64 {
|
||
|
|
if m != nil && m.StartTs != nil {
|
||
|
|
return *m.StartTs
|
||
|
|
}
|
||
|
|
return 0
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchGetRequest) GetIgnoreLock() bool {
|
||
|
|
if m != nil && m.IgnoreLock != nil {
|
||
|
|
return *m.IgnoreLock
|
||
|
|
}
|
||
|
|
return false
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisBatchGetResponse struct {
|
||
|
|
Rs []*Client.Result `protobuf:"bytes,1,rep,name=rs" json:"rs,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchGetResponse) Reset() { *m = ThemisBatchGetResponse{} }
|
||
|
|
func (m *ThemisBatchGetResponse) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisBatchGetResponse) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisBatchGetResponse) GetRs() []*Client.Result {
|
||
|
|
if m != nil {
|
||
|
|
return m.Rs
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisPrewrite struct {
|
||
|
|
Row []byte `protobuf:"bytes,1,req,name=row" json:"row,omitempty"`
|
||
|
|
Mutations []*Cell.Cell `protobuf:"bytes,2,rep,name=mutations" json:"mutations,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewrite) Reset() { *m = ThemisPrewrite{} }
|
||
|
|
func (m *ThemisPrewrite) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisPrewrite) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisPrewrite) GetRow() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.Row
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewrite) GetMutations() []*Cell.Cell {
|
||
|
|
if m != nil {
|
||
|
|
return m.Mutations
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisPrewriteRequest struct {
|
||
|
|
ThemisPrewrite *ThemisPrewrite `protobuf:"bytes,1,req,name=themisPrewrite" json:"themisPrewrite,omitempty"`
|
||
|
|
PrewriteTs *uint64 `protobuf:"varint,2,req,name=prewriteTs" json:"prewriteTs,omitempty"`
|
||
|
|
SecondaryLock []byte `protobuf:"bytes,3,req,name=secondaryLock" json:"secondaryLock,omitempty"`
|
||
|
|
PrimaryLock []byte `protobuf:"bytes,4,req,name=primaryLock" json:"primaryLock,omitempty"`
|
||
|
|
PrimaryIndex *int32 `protobuf:"varint,5,req,name=primaryIndex" json:"primaryIndex,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteRequest) Reset() { *m = ThemisPrewriteRequest{} }
|
||
|
|
func (m *ThemisPrewriteRequest) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisPrewriteRequest) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteRequest) GetThemisPrewrite() *ThemisPrewrite {
|
||
|
|
if m != nil {
|
||
|
|
return m.ThemisPrewrite
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteRequest) GetPrewriteTs() uint64 {
|
||
|
|
if m != nil && m.PrewriteTs != nil {
|
||
|
|
return *m.PrewriteTs
|
||
|
|
}
|
||
|
|
return 0
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteRequest) GetSecondaryLock() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.SecondaryLock
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteRequest) GetPrimaryLock() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.PrimaryLock
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteRequest) GetPrimaryIndex() int32 {
|
||
|
|
if m != nil && m.PrimaryIndex != nil {
|
||
|
|
return *m.PrimaryIndex
|
||
|
|
}
|
||
|
|
return 0
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisPrewriteResponse struct {
|
||
|
|
ThemisPrewriteResult *ThemisPrewriteResult `protobuf:"bytes,1,opt,name=themisPrewriteResult" json:"themisPrewriteResult,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteResponse) Reset() { *m = ThemisPrewriteResponse{} }
|
||
|
|
func (m *ThemisPrewriteResponse) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisPrewriteResponse) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteResponse) GetThemisPrewriteResult() *ThemisPrewriteResult {
|
||
|
|
if m != nil {
|
||
|
|
return m.ThemisPrewriteResult
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisBatchPrewriteSecondaryRequest struct {
|
||
|
|
ThemisPrewrite []*ThemisPrewrite `protobuf:"bytes,1,rep,name=themisPrewrite" json:"themisPrewrite,omitempty"`
|
||
|
|
PrewriteTs *uint64 `protobuf:"varint,2,req,name=prewriteTs" json:"prewriteTs,omitempty"`
|
||
|
|
SecondaryLock []byte `protobuf:"bytes,3,req,name=secondaryLock" json:"secondaryLock,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchPrewriteSecondaryRequest) Reset() { *m = ThemisBatchPrewriteSecondaryRequest{} }
|
||
|
|
func (m *ThemisBatchPrewriteSecondaryRequest) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisBatchPrewriteSecondaryRequest) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisBatchPrewriteSecondaryRequest) GetThemisPrewrite() []*ThemisPrewrite {
|
||
|
|
if m != nil {
|
||
|
|
return m.ThemisPrewrite
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchPrewriteSecondaryRequest) GetPrewriteTs() uint64 {
|
||
|
|
if m != nil && m.PrewriteTs != nil {
|
||
|
|
return *m.PrewriteTs
|
||
|
|
}
|
||
|
|
return 0
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchPrewriteSecondaryRequest) GetSecondaryLock() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.SecondaryLock
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisBatchPrewriteSecondaryResponse struct {
|
||
|
|
ThemisPrewriteResult []*ThemisPrewriteResult `protobuf:"bytes,1,rep,name=themisPrewriteResult" json:"themisPrewriteResult,omitempty"`
|
||
|
|
RowsNotInRegion [][]byte `protobuf:"bytes,2,rep,name=rowsNotInRegion" json:"rowsNotInRegion,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchPrewriteSecondaryResponse) Reset() { *m = ThemisBatchPrewriteSecondaryResponse{} }
|
||
|
|
func (m *ThemisBatchPrewriteSecondaryResponse) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisBatchPrewriteSecondaryResponse) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisBatchPrewriteSecondaryResponse) GetThemisPrewriteResult() []*ThemisPrewriteResult {
|
||
|
|
if m != nil {
|
||
|
|
return m.ThemisPrewriteResult
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchPrewriteSecondaryResponse) GetRowsNotInRegion() [][]byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.RowsNotInRegion
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisPrewriteResult struct {
|
||
|
|
NewerWriteTs *int64 `protobuf:"varint,1,req,name=newerWriteTs" json:"newerWriteTs,omitempty"`
|
||
|
|
ExistLock []byte `protobuf:"bytes,2,req,name=existLock" json:"existLock,omitempty"`
|
||
|
|
Family []byte `protobuf:"bytes,3,req,name=family" json:"family,omitempty"`
|
||
|
|
Qualifier []byte `protobuf:"bytes,4,req,name=qualifier" json:"qualifier,omitempty"`
|
||
|
|
LockExpired *bool `protobuf:"varint,5,req,name=lockExpired" json:"lockExpired,omitempty"`
|
||
|
|
Row []byte `protobuf:"bytes,6,req,name=row" json:"row,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteResult) Reset() { *m = ThemisPrewriteResult{} }
|
||
|
|
func (m *ThemisPrewriteResult) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisPrewriteResult) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteResult) GetNewerWriteTs() int64 {
|
||
|
|
if m != nil && m.NewerWriteTs != nil {
|
||
|
|
return *m.NewerWriteTs
|
||
|
|
}
|
||
|
|
return 0
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteResult) GetExistLock() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.ExistLock
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteResult) GetFamily() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.Family
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteResult) GetQualifier() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.Qualifier
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteResult) GetLockExpired() bool {
|
||
|
|
if m != nil && m.LockExpired != nil {
|
||
|
|
return *m.LockExpired
|
||
|
|
}
|
||
|
|
return false
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisPrewriteResult) GetRow() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.Row
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisCommitRequest struct {
|
||
|
|
ThemisCommit *ThemisCommit `protobuf:"bytes,1,req,name=themisCommit" json:"themisCommit,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisCommitRequest) Reset() { *m = ThemisCommitRequest{} }
|
||
|
|
func (m *ThemisCommitRequest) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisCommitRequest) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisCommitRequest) GetThemisCommit() *ThemisCommit {
|
||
|
|
if m != nil {
|
||
|
|
return m.ThemisCommit
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisCommitResponse struct {
|
||
|
|
Result *bool `protobuf:"varint,1,req,name=result" json:"result,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisCommitResponse) Reset() { *m = ThemisCommitResponse{} }
|
||
|
|
func (m *ThemisCommitResponse) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisCommitResponse) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisCommitResponse) GetResult() bool {
|
||
|
|
if m != nil && m.Result != nil {
|
||
|
|
return *m.Result
|
||
|
|
}
|
||
|
|
return false
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisBatchCommitSecondaryRequest struct {
|
||
|
|
ThemisCommit []*ThemisCommit `protobuf:"bytes,1,rep,name=themisCommit" json:"themisCommit,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchCommitSecondaryRequest) Reset() { *m = ThemisBatchCommitSecondaryRequest{} }
|
||
|
|
func (m *ThemisBatchCommitSecondaryRequest) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisBatchCommitSecondaryRequest) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisBatchCommitSecondaryRequest) GetThemisCommit() []*ThemisCommit {
|
||
|
|
if m != nil {
|
||
|
|
return m.ThemisCommit
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisBatchCommitSecondaryResponse struct {
|
||
|
|
BatchCommitSecondaryResult []*ThemisBatchCommitSecondaryResult `protobuf:"bytes,1,rep,name=batchCommitSecondaryResult" json:"batchCommitSecondaryResult,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchCommitSecondaryResponse) Reset() { *m = ThemisBatchCommitSecondaryResponse{} }
|
||
|
|
func (m *ThemisBatchCommitSecondaryResponse) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisBatchCommitSecondaryResponse) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisBatchCommitSecondaryResponse) GetBatchCommitSecondaryResult() []*ThemisBatchCommitSecondaryResult {
|
||
|
|
if m != nil {
|
||
|
|
return m.BatchCommitSecondaryResult
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisBatchCommitSecondaryResult struct {
|
||
|
|
Row []byte `protobuf:"bytes,1,req,name=row" json:"row,omitempty"`
|
||
|
|
Success *bool `protobuf:"varint,2,req,name=success" json:"success,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchCommitSecondaryResult) Reset() { *m = ThemisBatchCommitSecondaryResult{} }
|
||
|
|
func (m *ThemisBatchCommitSecondaryResult) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisBatchCommitSecondaryResult) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisBatchCommitSecondaryResult) GetRow() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.Row
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisBatchCommitSecondaryResult) GetSuccess() bool {
|
||
|
|
if m != nil && m.Success != nil {
|
||
|
|
return *m.Success
|
||
|
|
}
|
||
|
|
return false
|
||
|
|
}
|
||
|
|
|
||
|
|
type ThemisCommit struct {
|
||
|
|
Row []byte `protobuf:"bytes,1,req,name=row" json:"row,omitempty"`
|
||
|
|
Mutations []*Cell.Cell `protobuf:"bytes,2,rep,name=mutations" json:"mutations,omitempty"`
|
||
|
|
PrewriteTs *uint64 `protobuf:"varint,3,req,name=prewriteTs" json:"prewriteTs,omitempty"`
|
||
|
|
CommitTs *uint64 `protobuf:"varint,4,req,name=commitTs" json:"commitTs,omitempty"`
|
||
|
|
PrimaryIndex *int32 `protobuf:"varint,5,req,name=primaryIndex" json:"primaryIndex,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisCommit) Reset() { *m = ThemisCommit{} }
|
||
|
|
func (m *ThemisCommit) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*ThemisCommit) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *ThemisCommit) GetRow() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.Row
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisCommit) GetMutations() []*Cell.Cell {
|
||
|
|
if m != nil {
|
||
|
|
return m.Mutations
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisCommit) GetPrewriteTs() uint64 {
|
||
|
|
if m != nil && m.PrewriteTs != nil {
|
||
|
|
return *m.PrewriteTs
|
||
|
|
}
|
||
|
|
return 0
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisCommit) GetCommitTs() uint64 {
|
||
|
|
if m != nil && m.CommitTs != nil {
|
||
|
|
return *m.CommitTs
|
||
|
|
}
|
||
|
|
return 0
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *ThemisCommit) GetPrimaryIndex() int32 {
|
||
|
|
if m != nil && m.PrimaryIndex != nil {
|
||
|
|
return *m.PrimaryIndex
|
||
|
|
}
|
||
|
|
return 0
|
||
|
|
}
|
||
|
|
|
||
|
|
type EraseLockRequest struct {
|
||
|
|
Row []byte `protobuf:"bytes,1,req,name=row" json:"row,omitempty"`
|
||
|
|
Family []byte `protobuf:"bytes,2,req,name=family" json:"family,omitempty"`
|
||
|
|
Qualifier []byte `protobuf:"bytes,3,req,name=qualifier" json:"qualifier,omitempty"`
|
||
|
|
PrewriteTs *uint64 `protobuf:"varint,4,req,name=prewriteTs" json:"prewriteTs,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *EraseLockRequest) Reset() { *m = EraseLockRequest{} }
|
||
|
|
func (m *EraseLockRequest) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*EraseLockRequest) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *EraseLockRequest) GetRow() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.Row
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *EraseLockRequest) GetFamily() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.Family
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *EraseLockRequest) GetQualifier() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.Qualifier
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *EraseLockRequest) GetPrewriteTs() uint64 {
|
||
|
|
if m != nil && m.PrewriteTs != nil {
|
||
|
|
return *m.PrewriteTs
|
||
|
|
}
|
||
|
|
return 0
|
||
|
|
}
|
||
|
|
|
||
|
|
type EraseLockResponse struct {
|
||
|
|
Lock []byte `protobuf:"bytes,1,opt,name=lock" json:"lock,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *EraseLockResponse) Reset() { *m = EraseLockResponse{} }
|
||
|
|
func (m *EraseLockResponse) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*EraseLockResponse) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *EraseLockResponse) GetLock() []byte {
|
||
|
|
if m != nil {
|
||
|
|
return m.Lock
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
type LockExpiredRequest struct {
|
||
|
|
Timestamp *uint64 `protobuf:"varint,1,req,name=timestamp" json:"timestamp,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *LockExpiredRequest) Reset() { *m = LockExpiredRequest{} }
|
||
|
|
func (m *LockExpiredRequest) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*LockExpiredRequest) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *LockExpiredRequest) GetTimestamp() uint64 {
|
||
|
|
if m != nil && m.Timestamp != nil {
|
||
|
|
return *m.Timestamp
|
||
|
|
}
|
||
|
|
return 0
|
||
|
|
}
|
||
|
|
|
||
|
|
type LockExpiredResponse struct {
|
||
|
|
Expired *bool `protobuf:"varint,1,req,name=expired" json:"expired,omitempty"`
|
||
|
|
XXX_unrecognized []byte `json:"-"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *LockExpiredResponse) Reset() { *m = LockExpiredResponse{} }
|
||
|
|
func (m *LockExpiredResponse) String() string { return proto.CompactTextString(m) }
|
||
|
|
func (*LockExpiredResponse) ProtoMessage() {}
|
||
|
|
|
||
|
|
func (m *LockExpiredResponse) GetExpired() bool {
|
||
|
|
if m != nil && m.Expired != nil {
|
||
|
|
return *m.Expired
|
||
|
|
}
|
||
|
|
return false
|
||
|
|
}
|