themis

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

type EraseLockResponse struct {
	Lock             []byte `protobuf:"bytes,1,opt,name=lock" json:"lock,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

type Lock interface {
	// SetCoordinate sets lock's coordinate
	SetCoordinate(c *hbase.ColumnCoordinate)
	// Coordinate returns the lock's coordinate
	Coordinate() *hbase.ColumnCoordinate
	// Timestamp returns startTs of the transction which owned this lock
	Timestamp() uint64
	// SetExpired sets the lock's expired status.
	SetExpired(b bool)
	// IsExpired returns if lock is expired.
	IsExpired() bool
	// Type returns the lock's type, Put or Delete
	Type() hbase.Type
	// Role returns LockRole, primary or secondary
	Role() LockRole
	// not used now
	Context() interface{}
	// valid only  Role == Primary
	Secondaries() []Lock
	// Primary returns the primary lock of this lock
	Primary() Lock
	// Encode encodes the lock to byte slice
	Encode() []byte
}

type LockExpiredRequest struct {
	Timestamp        *uint64 `protobuf:"varint,1,req,name=timestamp" json:"timestamp,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

type LockExpiredResponse struct {
	Expired          *bool  `protobuf:"varint,1,req,name=expired" json:"expired,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

type LockManager interface {
	// CleanLock if clean lock success, first return value is transction's commit
	// timestamp, otherwise, the second return value is transction's primary
	// lock.
	CleanLock(c *hbase.ColumnCoordinate, prewriteTs uint64) (uint64, Lock, error)
	// EraseLockAndData removes lock and data.
	EraseLockAndData(c *hbase.ColumnCoordinate, prewriteTs uint64) error
	// GetCommitTimestamp returns a committed transction's commit timestamp.
	GetCommitTimestamp(c *hbase.ColumnCoordinate, prewriteTs uint64) (uint64, error)
	// [startTs, endTs]
	IsLockExists(c *hbase.ColumnCoordinate, startTs, endTs uint64) (bool, error)
}

type LockRole int

type ThemisBatchCommitSecondaryRequest struct {
	ThemisCommit     []*ThemisCommit `protobuf:"bytes,1,rep,name=themisCommit" json:"themisCommit,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

type ThemisBatchCommitSecondaryResponse struct {
	BatchCommitSecondaryResult []*ThemisBatchCommitSecondaryResult `protobuf:"bytes,1,rep,name=batchCommitSecondaryResult" json:"batchCommitSecondaryResult,omitempty"`
	XXX_unrecognized           []byte                              `json:"-"`
}

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

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

type ThemisBatchGetResponse struct {
	Rs               []*Client.Result `protobuf:"bytes,1,rep,name=rs" json:"rs,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

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

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

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

type ThemisCommitRequest struct {
	ThemisCommit     *ThemisCommit `protobuf:"bytes,1,req,name=themisCommit" json:"themisCommit,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

type ThemisCommitResponse struct {
	Result           *bool  `protobuf:"varint,1,req,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

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

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

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

type ThemisPrewriteResponse struct {
	ThemisPrewriteResult *ThemisPrewriteResult `protobuf:"bytes,1,opt,name=themisPrewriteResult" json:"themisPrewriteResult,omitempty"`
	XXX_unrecognized     []byte                `json:"-"`
}

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

type ThemisScanner struct {
	// contains filtered or unexported fields
}

type Txn interface {
	Get(t string, get *hbase.Get) (*hbase.ResultRow, error)
	Gets(t string, gets []*hbase.Get) ([]*hbase.ResultRow, error)
	LockRow(t string, row []byte) error
	Put(t string, put *hbase.Put)
	Delete(t string, del *hbase.Delete) error
	GetScanner(tbl []byte, startKey, endKey []byte, batchSize int) *ThemisScanner
	Release()
	Commit() error
	GetStartTS() uint64
	GetCommitTS() uint64
}

type TxnConfig struct {
	ConcurrentPrewriteAndCommit bool
	WaitSecondaryCommit         bool
	TTLInMs                     uint64
	MaxRowsInOneTxn             int
	// contains filtered or unexported fields
}