Платформа ЦРНП "Мирокод" для разработки проектов
https://git.mirocod.ru
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
547 lines
16 KiB
547 lines
16 KiB
// 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 |
|
}
|
|
|