lock

package
v1.0.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2023 License: Apache-2.0 Imports: 11 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLock        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLock          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLock = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Granularity_name = map[int32]string{
	0: "Row",
	1: "Range",
}
View Source 
var Granularity_value = map[string]int32{
	"Row":   0,
	"Range": 1,
}
View Source 
var LockMode_name = map[int32]string{
	0: "Exclusive",
	1: "Shared",
}
View Source 
var LockMode_value = map[string]int32{
	"Exclusive": 0,
	"Shared":    1,
}
View Source 
var Method_name = map[int32]string{
	0: "Lock",
	1: "Unlock",
	2: "GetTxnLock",
	3: "GetWaitingList",
	4: "KeepRemoteLock",
	5: "GetBind",
	6: "KeepLockTableBind",
	7: "ForwardLock",
	8: "ForwardUnlock",
}
View Source 
var Method_value = map[string]int32{
	"Lock":              0,
	"Unlock":            1,
	"GetTxnLock":        2,
	"GetWaitingList":    3,
	"KeepRemoteLock":    4,
	"GetBind":           5,
	"KeepLockTableBind": 6,
	"ForwardLock":       7,
	"ForwardUnlock":     8,
}
View Source 
var WaitPolicy_name = map[int32]string{
	0: "Wait",
	1: "FastFail",
}
View Source 
var WaitPolicy_value = map[string]int32{
	"Wait":     0,
	"FastFail": 1,
}

Functions

This section is empty.

Types

type GetBindRequest 

type GetBindRequest struct {
	ServiceID            string   `protobuf:"bytes,1,opt,name=ServiceID,proto3" json:"ServiceID,omitempty"`
	Table                uint64   `protobuf:"varint,2,opt,name=Table,proto3" json:"Table,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetBindRequest get bind request from allocator request. CN -> TN

func (*GetBindRequest) DebugString 

func (m *GetBindRequest) DebugString() string

func (*GetBindRequest) Descriptor 

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

func (*GetBindRequest) GetServiceID 

func (m *GetBindRequest) GetServiceID() string

func (*GetBindRequest) GetTable 

func (m *GetBindRequest) GetTable() uint64

func (*GetBindRequest) Marshal 

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

func (*GetBindRequest) MarshalTo 

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

func (*GetBindRequest) MarshalToSizedBuffer 

func (m *GetBindRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetBindRequest) ProtoMessage 

func (*GetBindRequest) ProtoMessage()

func (*GetBindRequest) Reset 

func (m *GetBindRequest) Reset()

func (*GetBindRequest) Size 

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

func (*GetBindRequest) String 

func (m *GetBindRequest) String() string

func (*GetBindRequest) Unmarshal 

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

func (*GetBindRequest) XXX_DiscardUnknown 

func (m *GetBindRequest) XXX_DiscardUnknown()

func (*GetBindRequest) XXX_Marshal 

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

func (*GetBindRequest) XXX_Merge 

func (m *GetBindRequest) XXX_Merge(src proto.Message)

func (*GetBindRequest) XXX_Size 

func (m *GetBindRequest) XXX_Size() int

func (*GetBindRequest) XXX_Unmarshal 

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

type GetBindResponse 

type GetBindResponse struct {
	LockTable            LockTable `protobuf:"bytes,2,opt,name=LockTable,proto3" json:"LockTable"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

GetBindResponse get bind request from allocator response. TN -> CN

func (*GetBindResponse) DebugString 

func (m *GetBindResponse) DebugString() string

func (*GetBindResponse) Descriptor 

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

func (*GetBindResponse) GetLockTable 

func (m *GetBindResponse) GetLockTable() LockTable

func (*GetBindResponse) Marshal 

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

func (*GetBindResponse) MarshalTo 

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

func (*GetBindResponse) MarshalToSizedBuffer 

func (m *GetBindResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetBindResponse) ProtoMessage 

func (*GetBindResponse) ProtoMessage()

func (*GetBindResponse) Reset 

func (m *GetBindResponse) Reset()

func (*GetBindResponse) Size 

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

func (*GetBindResponse) String 

func (m *GetBindResponse) String() string

func (*GetBindResponse) Unmarshal 

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

func (*GetBindResponse) XXX_DiscardUnknown 

func (m *GetBindResponse) XXX_DiscardUnknown()

func (*GetBindResponse) XXX_Marshal 

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

func (*GetBindResponse) XXX_Merge 

func (m *GetBindResponse) XXX_Merge(src proto.Message)

func (*GetBindResponse) XXX_Size 

func (m *GetBindResponse) XXX_Size() int

func (*GetBindResponse) XXX_Unmarshal 

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

type GetTxnLockRequest 

type GetTxnLockRequest struct {
	TxnID                []byte   `protobuf:"bytes,1,opt,name=TxnID,proto3" json:"TxnID,omitempty"`
	Row                  []byte   `protobuf:"bytes,2,opt,name=Row,proto3" json:"Row,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetTxnLockRequest get a waiting txn list on a special lock request, used to dead lock detect

func (*GetTxnLockRequest) DebugString 

func (m *GetTxnLockRequest) DebugString() string

func (*GetTxnLockRequest) Descriptor 

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

func (*GetTxnLockRequest) GetRow 

func (m *GetTxnLockRequest) GetRow() []byte

func (*GetTxnLockRequest) GetTxnID 

func (m *GetTxnLockRequest) GetTxnID() []byte

func (*GetTxnLockRequest) Marshal 

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

func (*GetTxnLockRequest) MarshalTo 

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

func (*GetTxnLockRequest) MarshalToSizedBuffer 

func (m *GetTxnLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetTxnLockRequest) ProtoMessage 

func (*GetTxnLockRequest) ProtoMessage()

func (*GetTxnLockRequest) Reset 

func (m *GetTxnLockRequest) Reset()

func (*GetTxnLockRequest) Size 

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

func (*GetTxnLockRequest) String 

func (m *GetTxnLockRequest) String() string

func (*GetTxnLockRequest) Unmarshal 

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

func (*GetTxnLockRequest) XXX_DiscardUnknown 

func (m *GetTxnLockRequest) XXX_DiscardUnknown()

func (*GetTxnLockRequest) XXX_Marshal 

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

func (*GetTxnLockRequest) XXX_Merge 

func (m *GetTxnLockRequest) XXX_Merge(src proto.Message)

func (*GetTxnLockRequest) XXX_Size 

func (m *GetTxnLockRequest) XXX_Size() int

func (*GetTxnLockRequest) XXX_Unmarshal 

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

type GetTxnLockResponse 

type GetTxnLockResponse struct {
	Value                int32     `protobuf:"varint,1,opt,name=Value,proto3" json:"Value,omitempty"`
	WaitingList          []WaitTxn `protobuf:"bytes,2,rep,name=WaitingList,proto3" json:"WaitingList"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

GetTxnLockResponse get txn Lock response

func (*GetTxnLockResponse) DebugString 

func (m *GetTxnLockResponse) DebugString() string

func (*GetTxnLockResponse) Descriptor 

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

func (*GetTxnLockResponse) GetValue 

func (m *GetTxnLockResponse) GetValue() int32

func (*GetTxnLockResponse) GetWaitingList 

func (m *GetTxnLockResponse) GetWaitingList() []WaitTxn

func (*GetTxnLockResponse) Marshal 

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

func (*GetTxnLockResponse) MarshalTo 

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

func (*GetTxnLockResponse) MarshalToSizedBuffer 

func (m *GetTxnLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetTxnLockResponse) ProtoMessage 

func (*GetTxnLockResponse) ProtoMessage()

func (*GetTxnLockResponse) Reset 

func (m *GetTxnLockResponse) Reset()

func (*GetTxnLockResponse) Size 

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

func (*GetTxnLockResponse) String 

func (m *GetTxnLockResponse) String() string

func (*GetTxnLockResponse) Unmarshal 

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

func (*GetTxnLockResponse) XXX_DiscardUnknown 

func (m *GetTxnLockResponse) XXX_DiscardUnknown()

func (*GetTxnLockResponse) XXX_Marshal 

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

func (*GetTxnLockResponse) XXX_Merge 

func (m *GetTxnLockResponse) XXX_Merge(src proto.Message)

func (*GetTxnLockResponse) XXX_Size 

func (m *GetTxnLockResponse) XXX_Size() int

func (*GetTxnLockResponse) XXX_Unmarshal 

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

type GetWaitingListRequest 

type GetWaitingListRequest struct {
	Txn                  WaitTxn  `protobuf:"bytes,1,opt,name=Txn,proto3" json:"Txn"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetWaitingListRequest get a waiting txn list on a specical txn request. CN -> CN

func (*GetWaitingListRequest) DebugString 

func (m *GetWaitingListRequest) DebugString() string

func (*GetWaitingListRequest) Descriptor 

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

func (*GetWaitingListRequest) GetTxn 

func (m *GetWaitingListRequest) GetTxn() WaitTxn

func (*GetWaitingListRequest) Marshal 

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

func (*GetWaitingListRequest) MarshalTo 

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

func (*GetWaitingListRequest) MarshalToSizedBuffer 

func (m *GetWaitingListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWaitingListRequest) ProtoMessage 

func (*GetWaitingListRequest) ProtoMessage()

func (*GetWaitingListRequest) Reset 

func (m *GetWaitingListRequest) Reset()

func (*GetWaitingListRequest) Size 

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

func (*GetWaitingListRequest) String 

func (m *GetWaitingListRequest) String() string

func (*GetWaitingListRequest) Unmarshal 

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

func (*GetWaitingListRequest) XXX_DiscardUnknown 

func (m *GetWaitingListRequest) XXX_DiscardUnknown()

func (*GetWaitingListRequest) XXX_Marshal 

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

func (*GetWaitingListRequest) XXX_Merge 

func (m *GetWaitingListRequest) XXX_Merge(src proto.Message)

func (*GetWaitingListRequest) XXX_Size 

func (m *GetWaitingListRequest) XXX_Size() int

func (*GetWaitingListRequest) XXX_Unmarshal 

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

type GetWaitingListResponse 

type GetWaitingListResponse struct {
	WaitingList          []WaitTxn `protobuf:"bytes,1,rep,name=WaitingList,proto3" json:"WaitingList"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

GetWaitingListResponse get a waiting txn list on a specical txn response. CN -> CN

func (*GetWaitingListResponse) DebugString 

func (m *GetWaitingListResponse) DebugString() string

func (*GetWaitingListResponse) Descriptor 

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

func (*GetWaitingListResponse) GetWaitingList 

func (m *GetWaitingListResponse) GetWaitingList() []WaitTxn

func (*GetWaitingListResponse) Marshal 

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

func (*GetWaitingListResponse) MarshalTo 

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

func (*GetWaitingListResponse) MarshalToSizedBuffer 

func (m *GetWaitingListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWaitingListResponse) ProtoMessage 

func (*GetWaitingListResponse) ProtoMessage()

func (*GetWaitingListResponse) Reset 

func (m *GetWaitingListResponse) Reset()

func (*GetWaitingListResponse) Size 

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

func (*GetWaitingListResponse) String 

func (m *GetWaitingListResponse) String() string

func (*GetWaitingListResponse) Unmarshal 

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

func (*GetWaitingListResponse) XXX_DiscardUnknown 

func (m *GetWaitingListResponse) XXX_DiscardUnknown()

func (*GetWaitingListResponse) XXX_Marshal 

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

func (*GetWaitingListResponse) XXX_Merge 

func (m *GetWaitingListResponse) XXX_Merge(src proto.Message)

func (*GetWaitingListResponse) XXX_Size 

func (m *GetWaitingListResponse) XXX_Size() int

func (*GetWaitingListResponse) XXX_Unmarshal 

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

type Granularity 

type Granularity int32

Granularity row granularity, single row or row range 

const (
	Granularity_Row   Granularity = 0
	Granularity_Range Granularity = 1
)

func (Granularity) EnumDescriptor 

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

func (Granularity) String 

func (x Granularity) String() string

type KeepLockTableBindRequest 

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

KeepLockTableBindRequest keep lock table bind request. CN -> TN

func (*KeepLockTableBindRequest) DebugString 

func (m *KeepLockTableBindRequest) DebugString() string

func (*KeepLockTableBindRequest) Descriptor 

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

func (*KeepLockTableBindRequest) GetServiceID 

func (m *KeepLockTableBindRequest) GetServiceID() string

func (*KeepLockTableBindRequest) Marshal 

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

func (*KeepLockTableBindRequest) MarshalTo 

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

func (*KeepLockTableBindRequest) MarshalToSizedBuffer 

func (m *KeepLockTableBindRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeepLockTableBindRequest) ProtoMessage 

func (*KeepLockTableBindRequest) ProtoMessage()

func (*KeepLockTableBindRequest) Reset 

func (m *KeepLockTableBindRequest) Reset()

func (*KeepLockTableBindRequest) Size 

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

func (*KeepLockTableBindRequest) String 

func (m *KeepLockTableBindRequest) String() string

func (*KeepLockTableBindRequest) Unmarshal 

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

func (*KeepLockTableBindRequest) XXX_DiscardUnknown 

func (m *KeepLockTableBindRequest) XXX_DiscardUnknown()

func (*KeepLockTableBindRequest) XXX_Marshal 

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

func (*KeepLockTableBindRequest) XXX_Merge 

func (m *KeepLockTableBindRequest) XXX_Merge(src proto.Message)

func (*KeepLockTableBindRequest) XXX_Size 

func (m *KeepLockTableBindRequest) XXX_Size() int

func (*KeepLockTableBindRequest) XXX_Unmarshal 

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

type KeepLockTableBindResponse 

type KeepLockTableBindResponse struct {
	OK                   bool     `protobuf:"varint,1,opt,name=OK,proto3" json:"OK,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

KeepLockTableBindResponse keep lock table bind response. TN -> CN

func (*KeepLockTableBindResponse) DebugString 

func (m *KeepLockTableBindResponse) DebugString() string

func (*KeepLockTableBindResponse) Descriptor 

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

func (*KeepLockTableBindResponse) GetOK 

func (m *KeepLockTableBindResponse) GetOK() bool

func (*KeepLockTableBindResponse) Marshal 

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

func (*KeepLockTableBindResponse) MarshalTo 

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

func (*KeepLockTableBindResponse) MarshalToSizedBuffer 

func (m *KeepLockTableBindResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeepLockTableBindResponse) ProtoMessage 

func (*KeepLockTableBindResponse) ProtoMessage()

func (*KeepLockTableBindResponse) Reset 

func (m *KeepLockTableBindResponse) Reset()

func (*KeepLockTableBindResponse) Size 

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

func (*KeepLockTableBindResponse) String 

func (m *KeepLockTableBindResponse) String() string

func (*KeepLockTableBindResponse) Unmarshal 

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

func (*KeepLockTableBindResponse) XXX_DiscardUnknown 

func (m *KeepLockTableBindResponse) XXX_DiscardUnknown()

func (*KeepLockTableBindResponse) XXX_Marshal 

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

func (*KeepLockTableBindResponse) XXX_Merge 

func (m *KeepLockTableBindResponse) XXX_Merge(src proto.Message)

func (*KeepLockTableBindResponse) XXX_Size 

func (m *KeepLockTableBindResponse) XXX_Size() int

func (*KeepLockTableBindResponse) XXX_Unmarshal 

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

type KeepRemoteLockRequest 

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

KeepRemoteLockRequest keep lock on remote lockservice request. CN -> CN

func (*KeepRemoteLockRequest) DebugString 

func (m *KeepRemoteLockRequest) DebugString() string

func (*KeepRemoteLockRequest) Descriptor 

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

func (*KeepRemoteLockRequest) GetServiceID 

func (m *KeepRemoteLockRequest) GetServiceID() string

func (*KeepRemoteLockRequest) Marshal 

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

func (*KeepRemoteLockRequest) MarshalTo 

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

func (*KeepRemoteLockRequest) MarshalToSizedBuffer 

func (m *KeepRemoteLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeepRemoteLockRequest) ProtoMessage 

func (*KeepRemoteLockRequest) ProtoMessage()

func (*KeepRemoteLockRequest) Reset 

func (m *KeepRemoteLockRequest) Reset()

func (*KeepRemoteLockRequest) Size 

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

func (*KeepRemoteLockRequest) String 

func (m *KeepRemoteLockRequest) String() string

func (*KeepRemoteLockRequest) Unmarshal 

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

func (*KeepRemoteLockRequest) XXX_DiscardUnknown 

func (m *KeepRemoteLockRequest) XXX_DiscardUnknown()

func (*KeepRemoteLockRequest) XXX_Marshal 

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

func (*KeepRemoteLockRequest) XXX_Merge 

func (m *KeepRemoteLockRequest) XXX_Merge(src proto.Message)

func (*KeepRemoteLockRequest) XXX_Size 

func (m *KeepRemoteLockRequest) XXX_Size() int

func (*KeepRemoteLockRequest) XXX_Unmarshal 

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

type KeepRemoteLockResponse 

type KeepRemoteLockResponse struct {
	OK                   bool     `protobuf:"varint,1,opt,name=OK,proto3" json:"OK,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

KeepRemoteLockResponse keep lock on remote lockservice response. TN -> CN

func (*KeepRemoteLockResponse) DebugString 

func (m *KeepRemoteLockResponse) DebugString() string

func (*KeepRemoteLockResponse) Descriptor 

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

func (*KeepRemoteLockResponse) GetOK 

func (m *KeepRemoteLockResponse) GetOK() bool

func (*KeepRemoteLockResponse) Marshal 

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

func (*KeepRemoteLockResponse) MarshalTo 

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

func (*KeepRemoteLockResponse) MarshalToSizedBuffer 

func (m *KeepRemoteLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeepRemoteLockResponse) ProtoMessage 

func (*KeepRemoteLockResponse) ProtoMessage()

func (*KeepRemoteLockResponse) Reset 

func (m *KeepRemoteLockResponse) Reset()

func (*KeepRemoteLockResponse) Size 

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

func (*KeepRemoteLockResponse) String 

func (m *KeepRemoteLockResponse) String() string

func (*KeepRemoteLockResponse) Unmarshal 

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

func (*KeepRemoteLockResponse) XXX_DiscardUnknown 

func (m *KeepRemoteLockResponse) XXX_DiscardUnknown()

func (*KeepRemoteLockResponse) XXX_Marshal 

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

func (*KeepRemoteLockResponse) XXX_Merge 

func (m *KeepRemoteLockResponse) XXX_Merge(src proto.Message)

func (*KeepRemoteLockResponse) XXX_Size 

func (m *KeepRemoteLockResponse) XXX_Size() int

func (*KeepRemoteLockResponse) XXX_Unmarshal 

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

type LockMode 

type LockMode int32

LockMode lock mode 

const (
	LockMode_Exclusive LockMode = 0
	LockMode_Shared    LockMode = 1
)

func (LockMode) EnumDescriptor 

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

func (LockMode) String 

func (x LockMode) String() string

type LockOptions 

type LockOptions struct {
	Granularity          Granularity `protobuf:"varint,1,opt,name=Granularity,proto3,enum=lock.Granularity" json:"Granularity,omitempty"`
	Mode                 LockMode    `protobuf:"varint,2,opt,name=Mode,proto3,enum=lock.LockMode" json:"Mode,omitempty"`
	Policy               WaitPolicy  `protobuf:"varint,3,opt,name=Policy,proto3,enum=lock.WaitPolicy" json:"Policy,omitempty"`
	ForwardTo            string      `protobuf:"bytes,4,opt,name=ForwardTo,proto3" json:"ForwardTo,omitempty"`
	TableDefChanged      bool        `protobuf:"varint,5,opt,name=TableDefChanged,proto3" json:"TableDefChanged,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

LockOptions lock options

func (LockOptions) DebugString 

func (m LockOptions) DebugString() string

DebugString debug string

func (*LockOptions) Descriptor 

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

func (*LockOptions) GetForwardTo 

func (m *LockOptions) GetForwardTo() string

func (*LockOptions) GetGranularity 

func (m *LockOptions) GetGranularity() Granularity

func (*LockOptions) GetMode 

func (m *LockOptions) GetMode() LockMode

func (*LockOptions) GetPolicy 

func (m *LockOptions) GetPolicy() WaitPolicy

func (*LockOptions) GetTableDefChanged added in v1.0.0 

func (m *LockOptions) GetTableDefChanged() bool

func (*LockOptions) Marshal 

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

func (*LockOptions) MarshalTo 

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

func (*LockOptions) MarshalToSizedBuffer 

func (m *LockOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LockOptions) ProtoMessage 

func (*LockOptions) ProtoMessage()

func (*LockOptions) Reset 

func (m *LockOptions) Reset()

func (*LockOptions) Size 

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

func (*LockOptions) String 

func (m *LockOptions) String() string

func (*LockOptions) Unmarshal 

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

func (LockOptions) WithGranularity 

func (m LockOptions) WithGranularity(granularity Granularity) LockOptions

WithGranularity set rows granularity, the default granularity is Row.

func (LockOptions) WithMode 

func (m LockOptions) WithMode(mode LockMode) LockOptions

WithMode set lock mode, the default mode is Exclusive.

func (LockOptions) WithWaitPolicy 

func (m LockOptions) WithWaitPolicy(policy WaitPolicy) LockOptions

WithWaitPolicy set wait policy, the default policy is Wait.

func (*LockOptions) XXX_DiscardUnknown 

func (m *LockOptions) XXX_DiscardUnknown()

func (*LockOptions) XXX_Marshal 

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

func (*LockOptions) XXX_Merge 

func (m *LockOptions) XXX_Merge(src proto.Message)

func (*LockOptions) XXX_Size 

func (m *LockOptions) XXX_Size() int

func (*LockOptions) XXX_Unmarshal 

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

type LockRequest 

type LockRequest struct {
	TxnID     []byte   `protobuf:"bytes,1,opt,name=TxnID,proto3" json:"TxnID,omitempty"`
	ServiceID string   `protobuf:"bytes,2,opt,name=ServiceID,proto3" json:"ServiceID,omitempty"`
	Rows      [][]byte `protobuf:"bytes,3,rep,name=Rows,proto3" json:"Rows,omitempty"`
	// LockOptions lock options
	Options              LockOptions `protobuf:"bytes,4,opt,name=Options,proto3" json:"Options"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

LockRequest lock request

func (*LockRequest) DebugString 

func (m *LockRequest) DebugString() string

func (*LockRequest) Descriptor 

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

func (*LockRequest) GetOptions 

func (m *LockRequest) GetOptions() LockOptions

func (*LockRequest) GetRows 

func (m *LockRequest) GetRows() [][]byte

func (*LockRequest) GetServiceID 

func (m *LockRequest) GetServiceID() string

func (*LockRequest) GetTxnID 

func (m *LockRequest) GetTxnID() []byte

func (*LockRequest) Marshal 

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

func (*LockRequest) MarshalTo 

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

func (*LockRequest) MarshalToSizedBuffer 

func (m *LockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LockRequest) ProtoMessage 

func (*LockRequest) ProtoMessage()

func (*LockRequest) Reset 

func (m *LockRequest) Reset()

func (*LockRequest) Size 

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

func (*LockRequest) String 

func (m *LockRequest) String() string

func (*LockRequest) Unmarshal 

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

func (*LockRequest) XXX_DiscardUnknown 

func (m *LockRequest) XXX_DiscardUnknown()

func (*LockRequest) XXX_Marshal 

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

func (*LockRequest) XXX_Merge 

func (m *LockRequest) XXX_Merge(src proto.Message)

func (*LockRequest) XXX_Size 

func (m *LockRequest) XXX_Size() int

func (*LockRequest) XXX_Unmarshal 

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

type LockResponse 

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

LockResponse lock response

func (*LockResponse) DebugString 

func (m *LockResponse) DebugString() string

func (*LockResponse) Descriptor 

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

func (*LockResponse) GetResult 

func (m *LockResponse) GetResult() Result

func (*LockResponse) Marshal 

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

func (*LockResponse) MarshalTo 

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

func (*LockResponse) MarshalToSizedBuffer 

func (m *LockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LockResponse) ProtoMessage 

func (*LockResponse) ProtoMessage()

func (*LockResponse) Reset 

func (m *LockResponse) Reset()

func (*LockResponse) Size 

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

func (*LockResponse) String 

func (m *LockResponse) String() string

func (*LockResponse) Unmarshal 

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

func (*LockResponse) XXX_DiscardUnknown 

func (m *LockResponse) XXX_DiscardUnknown()

func (*LockResponse) XXX_Marshal 

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

func (*LockResponse) XXX_Merge 

func (m *LockResponse) XXX_Merge(src proto.Message)

func (*LockResponse) XXX_Size 

func (m *LockResponse) XXX_Size() int

func (*LockResponse) XXX_Unmarshal 

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

type LockTable 

type LockTable struct {
	// Table table id
	Table uint64 `protobuf:"varint,1,opt,name=Table,proto3" json:"Table,omitempty"`
	// ServiceID lock service id, a cn node will only run one instance of LockService
	ServiceID string `protobuf:"bytes,2,opt,name=ServiceID,proto3" json:"ServiceID,omitempty"`
	// Version will incr if CN-Table bind changed.
	Version uint64 `protobuf:"varint,3,opt,name=Version,proto3" json:"Version,omitempty"`
	// Valid false if the service is disabled, and no new service bind this table
	Valid                bool     `protobuf:"varint,4,opt,name=Valid,proto3" json:"Valid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LockTable describes which CN manages a Table's Locks.

func (LockTable) Changed 

func (m LockTable) Changed(v LockTable) bool

Changed returns true if LockTable bind changed

func (LockTable) DebugString 

func (m LockTable) DebugString() string

DebugString returns the debug string

func (*LockTable) Descriptor 

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

func (*LockTable) GetServiceID 

func (m *LockTable) GetServiceID() string

func (*LockTable) GetTable 

func (m *LockTable) GetTable() uint64

func (*LockTable) GetValid 

func (m *LockTable) GetValid() bool

func (*LockTable) GetVersion 

func (m *LockTable) GetVersion() uint64

func (*LockTable) Marshal 

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

func (*LockTable) MarshalTo 

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

func (*LockTable) MarshalToSizedBuffer 

func (m *LockTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LockTable) ProtoMessage 

func (*LockTable) ProtoMessage()

func (*LockTable) Reset 

func (m *LockTable) Reset()

func (*LockTable) Size 

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

func (*LockTable) String 

func (m *LockTable) String() string

func (*LockTable) Unmarshal 

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

func (*LockTable) XXX_DiscardUnknown 

func (m *LockTable) XXX_DiscardUnknown()

func (*LockTable) XXX_Marshal 

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

func (*LockTable) XXX_Merge 

func (m *LockTable) XXX_Merge(src proto.Message)

func (*LockTable) XXX_Size 

func (m *LockTable) XXX_Size() int

func (*LockTable) XXX_Unmarshal 

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

type Method 

type Method int32

Method lock table operations 

const (
	// Lock lock rows on remote lock table
	Method_Lock Method = 0
	// Write unlock rows from remote lock table
	Method_Unlock Method = 1
	// GetTxnLock get lock data on a special lock
	Method_GetTxnLock Method = 2
	// GetWaitingList get waiting txns on a special lock
	Method_GetWaitingList Method = 3
	// KeepRemoteLock keep remote lock on remote lock service
	Method_KeepRemoteLock Method = 4
	// GetBind get or create lock table bind from lock table allocator
	Method_GetBind Method = 5
	// KeepLockTableBind keep the lock table bind on lock table allocator
	Method_KeepLockTableBind Method = 6
	// ForwardLock forward lock request to another service
	Method_ForwardLock Method = 7
	// ForwardUnlock forward unlock request to another service
	Method_ForwardUnlock Method = 8
)

func (Method) EnumDescriptor 

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

func (Method) String 

func (x Method) String() string

type Request 

type Request struct {
	// RequestID request id
	RequestID uint64 `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	// LockTable lock target table
	LockTable            LockTable                `protobuf:"bytes,2,opt,name=LockTable,proto3" json:"LockTable"`
	Method               Method                   `protobuf:"varint,3,opt,name=Method,proto3,enum=lock.Method" json:"Method,omitempty"`
	Lock                 LockRequest              `protobuf:"bytes,4,opt,name=Lock,proto3" json:"Lock"`
	Unlock               UnlockRequest            `protobuf:"bytes,5,opt,name=Unlock,proto3" json:"Unlock"`
	GetTxnLock           GetTxnLockRequest        `protobuf:"bytes,6,opt,name=GetTxnLock,proto3" json:"GetTxnLock"`
	GetWaitingList       GetWaitingListRequest    `protobuf:"bytes,7,opt,name=GetWaitingList,proto3" json:"GetWaitingList"`
	GetBind              GetBindRequest           `protobuf:"bytes,8,opt,name=GetBind,proto3" json:"GetBind"`
	KeepLockTableBind    KeepLockTableBindRequest `protobuf:"bytes,9,opt,name=KeepLockTableBind,proto3" json:"KeepLockTableBind"`
	KeepRemoteLock       KeepRemoteLockRequest    `protobuf:"bytes,10,opt,name=KeepRemoteLock,proto3" json:"KeepRemoteLock"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

Request is used to send a request for a LockTable related operation to another service.

func (*Request) DebugString 

func (m *Request) DebugString() string

DebugString returns the debug string

func (*Request) Descriptor 

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

func (*Request) GetGetBind 

func (m *Request) GetGetBind() GetBindRequest

func (*Request) GetGetTxnLock 

func (m *Request) GetGetTxnLock() GetTxnLockRequest

func (*Request) GetGetWaitingList 

func (m *Request) GetGetWaitingList() GetWaitingListRequest

func (*Request) GetID 

func (m *Request) GetID() uint64

GetID implement morpc Messgae

func (*Request) GetKeepLockTableBind 

func (m *Request) GetKeepLockTableBind() KeepLockTableBindRequest

func (*Request) GetKeepRemoteLock 

func (m *Request) GetKeepRemoteLock() KeepRemoteLockRequest

func (*Request) GetLock 

func (m *Request) GetLock() LockRequest

func (*Request) GetLockTable 

func (m *Request) GetLockTable() LockTable

func (*Request) GetMethod 

func (m *Request) GetMethod() Method

func (*Request) GetRequestID 

func (m *Request) GetRequestID() uint64

func (*Request) GetUnlock 

func (m *Request) GetUnlock() UnlockRequest

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) MarshalToSizedBuffer 

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) SetID 

func (m *Request) SetID(id uint64)

SetID implement morpc Messgae

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type Response 

type Response struct {
	// RequestID corresponding request id
	RequestID uint64 `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	Method    Method `protobuf:"varint,2,opt,name=Method,proto3,enum=lock.Method" json:"Method,omitempty"`
	// Error we use this field to send moerr from service to another cn. Set with
	// moerr.MarshalBinary, and use moerr.UnmarshalBinary to restore moerr.
	Error                []byte                    `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	NewBind              *LockTable                `protobuf:"bytes,4,opt,name=NewBind,proto3" json:"NewBind,omitempty"`
	Lock                 LockResponse              `protobuf:"bytes,5,opt,name=Lock,proto3" json:"Lock"`
	Unlock               UnlockResponse            `protobuf:"bytes,6,opt,name=Unlock,proto3" json:"Unlock"`
	GetTxnLock           GetTxnLockResponse        `protobuf:"bytes,7,opt,name=GetTxnLock,proto3" json:"GetTxnLock"`
	GetWaitingList       GetWaitingListResponse    `protobuf:"bytes,8,opt,name=GetWaitingList,proto3" json:"GetWaitingList"`
	GetBind              GetBindResponse           `protobuf:"bytes,9,opt,name=GetBind,proto3" json:"GetBind"`
	KeepLockTableBind    KeepLockTableBindResponse `protobuf:"bytes,10,opt,name=KeepLockTableBind,proto3" json:"KeepLockTableBind"`
	KeepRemoteLock       KeepRemoteLockResponse    `protobuf:"bytes,11,opt,name=KeepRemoteLock,proto3" json:"KeepRemoteLock"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

Response response

func (*Response) DebugString 

func (m *Response) DebugString() string

DebugString returns the debug string

func (*Response) Descriptor 

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

func (*Response) GetError 

func (m *Response) GetError() []byte

func (*Response) GetGetBind 

func (m *Response) GetGetBind() GetBindResponse

func (*Response) GetGetTxnLock 

func (m *Response) GetGetTxnLock() GetTxnLockResponse

func (*Response) GetGetWaitingList 

func (m *Response) GetGetWaitingList() GetWaitingListResponse

func (*Response) GetID 

func (m *Response) GetID() uint64

GetID implement morpc Messgae

func (*Response) GetKeepLockTableBind 

func (m *Response) GetKeepLockTableBind() KeepLockTableBindResponse

func (*Response) GetKeepRemoteLock 

func (m *Response) GetKeepRemoteLock() KeepRemoteLockResponse

func (*Response) GetLock 

func (m *Response) GetLock() LockResponse

func (*Response) GetMethod 

func (m *Response) GetMethod() Method

func (*Response) GetNewBind 

func (m *Response) GetNewBind() *LockTable

func (*Response) GetRequestID 

func (m *Response) GetRequestID() uint64

func (*Response) GetUnlock 

func (m *Response) GetUnlock() UnlockResponse

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) MarshalToSizedBuffer 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) SetID 

func (m *Response) SetID(id uint64)

SetID implement morpc Messgae

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

func (Response) UnwrapError 

func (m Response) UnwrapError() error

UnwrapError unwrap the moerr from the error bytes

func (*Response) WrapError 

func (m *Response) WrapError(err error)

WrapError wrapper error to TxnError

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type Result 

type Result struct {
	// LockedOn lock is locked on which locktable
	LockedOn LockTable `protobuf:"bytes,1,opt,name=LockedOn,proto3" json:"LockedOn"`
	// HasConflict if true means encounter lock conflict
	HasConflict bool `protobuf:"varint,2,opt,name=HasConflict,proto3" json:"HasConflict,omitempty"`
	// HasPrevCommit if HasPrevCommit && HasConflict, Timestamp is the latest commit
	// timestamp.
	HasPrevCommit bool `protobuf:"varint,3,opt,name=HasPrevCommit,proto3" json:"HasPrevCommit,omitempty"`
	// Timestamp is used to help determine which version of RC should be queried
	// under the RC isolation level, this timestamp ensures that the latest data
	// is always read.
	Timestamp timestamp.Timestamp `protobuf:"bytes,4,opt,name=Timestamp,proto3" json:"Timestamp"`
	// TableDefChanged conflict with ddl lock, need rebuild plan to get new table def
	TableDefChanged      bool     `protobuf:"varint,5,opt,name=TableDefChanged,proto3" json:"TableDefChanged,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Result result is used to tell the caller the result of the lock operation.

func (*Result) Descriptor 

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

func (*Result) GetHasConflict 

func (m *Result) GetHasConflict() bool

func (*Result) GetHasPrevCommit 

func (m *Result) GetHasPrevCommit() bool

func (*Result) GetLockedOn 

func (m *Result) GetLockedOn() LockTable

func (*Result) GetTableDefChanged added in v1.0.0 

func (m *Result) GetTableDefChanged() bool

func (*Result) GetTimestamp 

func (m *Result) GetTimestamp() timestamp.Timestamp

func (*Result) Marshal 

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

func (*Result) MarshalTo 

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

func (*Result) MarshalToSizedBuffer 

func (m *Result) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) Size 

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

func (*Result) String 

func (m *Result) String() string

func (*Result) Unmarshal 

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

func (*Result) XXX_DiscardUnknown 

func (m *Result) XXX_DiscardUnknown()

func (*Result) XXX_Marshal 

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

func (*Result) XXX_Merge 

func (m *Result) XXX_Merge(src proto.Message)

func (*Result) XXX_Size 

func (m *Result) XXX_Size() int

func (*Result) XXX_Unmarshal 

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

type UnlockRequest 

type UnlockRequest struct {
	TxnID []byte `protobuf:"bytes,1,opt,name=TxnID,proto3" json:"TxnID,omitempty"`
	// CommitTS is the commit timestamp of the current txn. Empty if txn is
	// roll backed
	CommitTS             timestamp.Timestamp `protobuf:"bytes,2,opt,name=CommitTS,proto3" json:"CommitTS"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

UnlockRequest unlock lock on remote lock service request. CN -> CN

func (*UnlockRequest) DebugString 

func (m *UnlockRequest) DebugString() string

func (*UnlockRequest) Descriptor 

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

func (*UnlockRequest) GetCommitTS 

func (m *UnlockRequest) GetCommitTS() timestamp.Timestamp

func (*UnlockRequest) GetTxnID 

func (m *UnlockRequest) GetTxnID() []byte

func (*UnlockRequest) Marshal 

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

func (*UnlockRequest) MarshalTo 

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

func (*UnlockRequest) MarshalToSizedBuffer 

func (m *UnlockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnlockRequest) ProtoMessage 

func (*UnlockRequest) ProtoMessage()

func (*UnlockRequest) Reset 

func (m *UnlockRequest) Reset()

func (*UnlockRequest) Size 

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

func (*UnlockRequest) String 

func (m *UnlockRequest) String() string

func (*UnlockRequest) Unmarshal 

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

func (*UnlockRequest) XXX_DiscardUnknown 

func (m *UnlockRequest) XXX_DiscardUnknown()

func (*UnlockRequest) XXX_Marshal 

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

func (*UnlockRequest) XXX_Merge 

func (m *UnlockRequest) XXX_Merge(src proto.Message)

func (*UnlockRequest) XXX_Size 

func (m *UnlockRequest) XXX_Size() int

func (*UnlockRequest) XXX_Unmarshal 

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

type UnlockResponse 

type UnlockResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

UnlockResponse unlock lock on remote lock service response. CN -> CN

func (*UnlockResponse) DebugString 

func (m *UnlockResponse) DebugString() string

func (*UnlockResponse) Descriptor 

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

func (*UnlockResponse) Marshal 

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

func (*UnlockResponse) MarshalTo 

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

func (*UnlockResponse) MarshalToSizedBuffer 

func (m *UnlockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnlockResponse) ProtoMessage 

func (*UnlockResponse) ProtoMessage()

func (*UnlockResponse) Reset 

func (m *UnlockResponse) Reset()

func (*UnlockResponse) Size 

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

func (*UnlockResponse) String 

func (m *UnlockResponse) String() string

func (*UnlockResponse) Unmarshal 

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

func (*UnlockResponse) XXX_DiscardUnknown 

func (m *UnlockResponse) XXX_DiscardUnknown()

func (*UnlockResponse) XXX_Marshal 

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

func (*UnlockResponse) XXX_Merge 

func (m *UnlockResponse) XXX_Merge(src proto.Message)

func (*UnlockResponse) XXX_Size 

func (m *UnlockResponse) XXX_Size() int

func (*UnlockResponse) XXX_Unmarshal 

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

type WaitPolicy 

type WaitPolicy int32

WaitPolicy wait policy 

const (
	WaitPolicy_Wait     WaitPolicy = 0
	WaitPolicy_FastFail WaitPolicy = 1
)

func (WaitPolicy) EnumDescriptor 

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

func (WaitPolicy) String 

func (x WaitPolicy) String() string

type WaitTxn 

type WaitTxn struct {
	TxnID                []byte   `protobuf:"bytes,1,opt,name=TxnID,proto3" json:"TxnID,omitempty"`
	CreatedOn            string   `protobuf:"bytes,2,opt,name=CreatedOn,proto3" json:"CreatedOn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

WaitTxn wait txn include txn created on

func (*WaitTxn) DebugString 

func (m *WaitTxn) DebugString() string

func (*WaitTxn) Descriptor 

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

func (*WaitTxn) GetCreatedOn 

func (m *WaitTxn) GetCreatedOn() string

func (*WaitTxn) GetTxnID 

func (m *WaitTxn) GetTxnID() []byte

func (*WaitTxn) Marshal 

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

func (*WaitTxn) MarshalTo 

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

func (*WaitTxn) MarshalToSizedBuffer 

func (m *WaitTxn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WaitTxn) ProtoMessage 

func (*WaitTxn) ProtoMessage()

func (*WaitTxn) Reset 

func (m *WaitTxn) Reset()

func (*WaitTxn) Size 

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

func (*WaitTxn) String 

func (m *WaitTxn) String() string

func (*WaitTxn) Unmarshal 

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

func (*WaitTxn) XXX_DiscardUnknown 

func (m *WaitTxn) XXX_DiscardUnknown()

func (*WaitTxn) XXX_Marshal 

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

func (*WaitTxn) XXX_Merge 

func (m *WaitTxn) XXX_Merge(src proto.Message)

func (*WaitTxn) XXX_Size 

func (m *WaitTxn) XXX_Size() int

func (*WaitTxn) XXX_Unmarshal 

func (m *WaitTxn) 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.