lock

package
v1.2.3 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2024 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",
	9:  "ValidateService",
	10: "CannotCommit",
	11: "GetActiveTxn",
	12: "SetRestartService",
	13: "RemainTxnInService",
	14: "CanRestartService",
	15: "CheckOrphan",
}
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,
	"ValidateService":    9,
	"CannotCommit":       10,
	"GetActiveTxn":       11,
	"SetRestartService":  12,
	"RemainTxnInService": 13,
	"CanRestartService":  14,
	"CheckOrphan":        15,
}
View Source 
var Sharding_name = map[int32]string{
	0: "None",
	1: "ByRow",
}
View Source 
var Sharding_value = map[string]int32{
	"None":  0,
	"ByRow": 1,
}
View Source 
var Status_name = map[int32]string{
	0: "ServiceLockEnable",
	1: "ServiceLockWaiting",
	2: "ServiceUnLockSucc",
	3: "ServiceCanRestart",
}
View Source 
var Status_value = map[string]int32{
	"ServiceLockEnable":  0,
	"ServiceLockWaiting": 1,
	"ServiceUnLockSucc":  2,
	"ServiceCanRestart":  3,
}
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 CanRestartServiceRequest added in v1.2.0 

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

CanRestartServiceRequest can restart lock service request from allocator request. operator -> TN

func (*CanRestartServiceRequest) Descriptor added in v1.2.0 

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

func (*CanRestartServiceRequest) GetServiceID added in v1.2.0 

func (m *CanRestartServiceRequest) GetServiceID() string

func (*CanRestartServiceRequest) Marshal added in v1.2.0 

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

func (*CanRestartServiceRequest) MarshalTo added in v1.2.0 

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

func (*CanRestartServiceRequest) MarshalToSizedBuffer added in v1.2.0 

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

func (*CanRestartServiceRequest) ProtoMessage added in v1.2.0 

func (*CanRestartServiceRequest) ProtoMessage()

func (*CanRestartServiceRequest) Reset added in v1.2.0 

func (m *CanRestartServiceRequest) Reset()

func (*CanRestartServiceRequest) Size added in v1.2.0 

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

func (*CanRestartServiceRequest) String added in v1.2.0 

func (m *CanRestartServiceRequest) String() string

func (*CanRestartServiceRequest) Unmarshal added in v1.2.0 

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

func (*CanRestartServiceRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *CanRestartServiceRequest) XXX_DiscardUnknown()

func (*CanRestartServiceRequest) XXX_Marshal added in v1.2.0 

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

func (*CanRestartServiceRequest) XXX_Merge added in v1.2.0 

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

func (*CanRestartServiceRequest) XXX_Size added in v1.2.0 

func (m *CanRestartServiceRequest) XXX_Size() int

func (*CanRestartServiceRequest) XXX_Unmarshal added in v1.2.0 

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

type CanRestartServiceResponse added in v1.2.0 

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

CanRestartServiceResponse can restart lock service request from allocator response. TN -> operator

func (*CanRestartServiceResponse) Descriptor added in v1.2.0 

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

func (*CanRestartServiceResponse) GetOK added in v1.2.0 

func (m *CanRestartServiceResponse) GetOK() bool

func (*CanRestartServiceResponse) Marshal added in v1.2.0 

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

func (*CanRestartServiceResponse) MarshalTo added in v1.2.0 

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

func (*CanRestartServiceResponse) MarshalToSizedBuffer added in v1.2.0 

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

func (*CanRestartServiceResponse) ProtoMessage added in v1.2.0 

func (*CanRestartServiceResponse) ProtoMessage()

func (*CanRestartServiceResponse) Reset added in v1.2.0 

func (m *CanRestartServiceResponse) Reset()

func (*CanRestartServiceResponse) Size added in v1.2.0 

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

func (*CanRestartServiceResponse) String added in v1.2.0 

func (m *CanRestartServiceResponse) String() string

func (*CanRestartServiceResponse) Unmarshal added in v1.2.0 

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

func (*CanRestartServiceResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *CanRestartServiceResponse) XXX_DiscardUnknown()

func (*CanRestartServiceResponse) XXX_Marshal added in v1.2.0 

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

func (*CanRestartServiceResponse) XXX_Merge added in v1.2.0 

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

func (*CanRestartServiceResponse) XXX_Size added in v1.2.0 

func (m *CanRestartServiceResponse) XXX_Size() int

func (*CanRestartServiceResponse) XXX_Unmarshal added in v1.2.0 

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

type CannotCommitRequest added in v1.1.3 

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

CannotCommitRequest cannot commit request. CN -> TN

func (*CannotCommitRequest) Descriptor added in v1.1.3 

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

func (*CannotCommitRequest) GetOrphanTxnList added in v1.1.3 

func (m *CannotCommitRequest) GetOrphanTxnList() []OrphanTxn

func (*CannotCommitRequest) Marshal added in v1.1.3 

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

func (*CannotCommitRequest) MarshalTo added in v1.1.3 

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

func (*CannotCommitRequest) MarshalToSizedBuffer added in v1.1.3 

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

func (*CannotCommitRequest) ProtoMessage added in v1.1.3 

func (*CannotCommitRequest) ProtoMessage()

func (*CannotCommitRequest) Reset added in v1.1.3 

func (m *CannotCommitRequest) Reset()

func (*CannotCommitRequest) Size added in v1.1.3 

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

func (*CannotCommitRequest) String added in v1.1.3 

func (m *CannotCommitRequest) String() string

func (*CannotCommitRequest) Unmarshal added in v1.1.3 

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

func (*CannotCommitRequest) XXX_DiscardUnknown added in v1.1.3 

func (m *CannotCommitRequest) XXX_DiscardUnknown()

func (*CannotCommitRequest) XXX_Marshal added in v1.1.3 

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

func (*CannotCommitRequest) XXX_Merge added in v1.1.3 

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

func (*CannotCommitRequest) XXX_Size added in v1.1.3 

func (m *CannotCommitRequest) XXX_Size() int

func (*CannotCommitRequest) XXX_Unmarshal added in v1.1.3 

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

type CannotCommitResponse added in v1.1.3 

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

CannotCommitResponse cannot commit response. TN -> CN

func (*CannotCommitResponse) Descriptor added in v1.1.3 

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

func (*CannotCommitResponse) GetCommittingTxn added in v1.2.0 

func (m *CannotCommitResponse) GetCommittingTxn() [][]byte

func (*CannotCommitResponse) Marshal added in v1.1.3 

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

func (*CannotCommitResponse) MarshalTo added in v1.1.3 

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

func (*CannotCommitResponse) MarshalToSizedBuffer added in v1.1.3 

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

func (*CannotCommitResponse) ProtoMessage added in v1.1.3 

func (*CannotCommitResponse) ProtoMessage()

func (*CannotCommitResponse) Reset added in v1.1.3 

func (m *CannotCommitResponse) Reset()

func (*CannotCommitResponse) Size added in v1.1.3 

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

func (*CannotCommitResponse) String added in v1.1.3 

func (m *CannotCommitResponse) String() string

func (*CannotCommitResponse) Unmarshal added in v1.1.3 

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

func (*CannotCommitResponse) XXX_DiscardUnknown added in v1.1.3 

func (m *CannotCommitResponse) XXX_DiscardUnknown()

func (*CannotCommitResponse) XXX_Marshal added in v1.1.3 

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

func (*CannotCommitResponse) XXX_Merge added in v1.1.3 

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

func (*CannotCommitResponse) XXX_Size added in v1.1.3 

func (m *CannotCommitResponse) XXX_Size() int

func (*CannotCommitResponse) XXX_Unmarshal added in v1.1.3 

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

type CheckOrphanRequest added in v1.2.1 

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

func (*CheckOrphanRequest) Descriptor added in v1.2.1 

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

func (*CheckOrphanRequest) GetServiceID added in v1.2.1 

func (m *CheckOrphanRequest) GetServiceID() string

func (*CheckOrphanRequest) GetTxn added in v1.2.1 

func (m *CheckOrphanRequest) GetTxn() []byte

func (*CheckOrphanRequest) Marshal added in v1.2.1 

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

func (*CheckOrphanRequest) MarshalTo added in v1.2.1 

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

func (*CheckOrphanRequest) MarshalToSizedBuffer added in v1.2.1 

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

func (*CheckOrphanRequest) ProtoMessage added in v1.2.1 

func (*CheckOrphanRequest) ProtoMessage()

func (*CheckOrphanRequest) Reset added in v1.2.1 

func (m *CheckOrphanRequest) Reset()

func (*CheckOrphanRequest) Size added in v1.2.1 

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

func (*CheckOrphanRequest) String added in v1.2.1 

func (m *CheckOrphanRequest) String() string

func (*CheckOrphanRequest) Unmarshal added in v1.2.1 

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

func (*CheckOrphanRequest) XXX_DiscardUnknown added in v1.2.1 

func (m *CheckOrphanRequest) XXX_DiscardUnknown()

func (*CheckOrphanRequest) XXX_Marshal added in v1.2.1 

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

func (*CheckOrphanRequest) XXX_Merge added in v1.2.1 

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

func (*CheckOrphanRequest) XXX_Size added in v1.2.1 

func (m *CheckOrphanRequest) XXX_Size() int

func (*CheckOrphanRequest) XXX_Unmarshal added in v1.2.1 

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

type CheckOrphanResponse added in v1.2.1 

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

func (*CheckOrphanResponse) Descriptor added in v1.2.1 

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

func (*CheckOrphanResponse) GetOrphan added in v1.2.1 

func (m *CheckOrphanResponse) GetOrphan() bool

func (*CheckOrphanResponse) Marshal added in v1.2.1 

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

func (*CheckOrphanResponse) MarshalTo added in v1.2.1 

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

func (*CheckOrphanResponse) MarshalToSizedBuffer added in v1.2.1 

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

func (*CheckOrphanResponse) ProtoMessage added in v1.2.1 

func (*CheckOrphanResponse) ProtoMessage()

func (*CheckOrphanResponse) Reset added in v1.2.1 

func (m *CheckOrphanResponse) Reset()

func (*CheckOrphanResponse) Size added in v1.2.1 

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

func (*CheckOrphanResponse) String added in v1.2.1 

func (m *CheckOrphanResponse) String() string

func (*CheckOrphanResponse) Unmarshal added in v1.2.1 

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

func (*CheckOrphanResponse) XXX_DiscardUnknown added in v1.2.1 

func (m *CheckOrphanResponse) XXX_DiscardUnknown()

func (*CheckOrphanResponse) XXX_Marshal added in v1.2.1 

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

func (*CheckOrphanResponse) XXX_Merge added in v1.2.1 

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

func (*CheckOrphanResponse) XXX_Size added in v1.2.1 

func (m *CheckOrphanResponse) XXX_Size() int

func (*CheckOrphanResponse) XXX_Unmarshal added in v1.2.1 

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

type ExtraMutation added in v1.1.0 

type ExtraMutation struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Skip                 bool     `protobuf:"varint,2,opt,name=skip,proto3" json:"skip,omitempty"`
	ReplaceTo            []byte   `protobuf:"bytes,3,opt,name=replaceTo,proto3" json:"replaceTo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExtraMutation) Descriptor added in v1.1.0 

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

func (*ExtraMutation) GetKey added in v1.1.0 

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

func (*ExtraMutation) GetReplaceTo added in v1.1.0 

func (m *ExtraMutation) GetReplaceTo() []byte

func (*ExtraMutation) GetSkip added in v1.1.0 

func (m *ExtraMutation) GetSkip() bool

func (*ExtraMutation) Marshal added in v1.1.0 

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

func (*ExtraMutation) MarshalTo added in v1.1.0 

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

func (*ExtraMutation) MarshalToSizedBuffer added in v1.1.0 

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

func (*ExtraMutation) ProtoMessage added in v1.1.0 

func (*ExtraMutation) ProtoMessage()

func (*ExtraMutation) Reset added in v1.1.0 

func (m *ExtraMutation) Reset()

func (*ExtraMutation) Size added in v1.1.0 

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

func (*ExtraMutation) String added in v1.1.0 

func (m *ExtraMutation) String() string

func (*ExtraMutation) Unmarshal added in v1.1.0 

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

func (*ExtraMutation) XXX_DiscardUnknown added in v1.1.0 

func (m *ExtraMutation) XXX_DiscardUnknown()

func (*ExtraMutation) XXX_Marshal added in v1.1.0 

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

func (*ExtraMutation) XXX_Merge added in v1.1.0 

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

func (*ExtraMutation) XXX_Size added in v1.1.0 

func (m *ExtraMutation) XXX_Size() int

func (*ExtraMutation) XXX_Unmarshal added in v1.1.0 

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

type GetActiveTxnRequest added in v1.1.3 

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

func (*GetActiveTxnRequest) Descriptor added in v1.1.3 

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

func (*GetActiveTxnRequest) GetServiceID added in v1.1.3 

func (m *GetActiveTxnRequest) GetServiceID() string

func (*GetActiveTxnRequest) Marshal added in v1.1.3 

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

func (*GetActiveTxnRequest) MarshalTo added in v1.1.3 

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

func (*GetActiveTxnRequest) MarshalToSizedBuffer added in v1.1.3 

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

func (*GetActiveTxnRequest) ProtoMessage added in v1.1.3 

func (*GetActiveTxnRequest) ProtoMessage()

func (*GetActiveTxnRequest) Reset added in v1.1.3 

func (m *GetActiveTxnRequest) Reset()

func (*GetActiveTxnRequest) Size added in v1.1.3 

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

func (*GetActiveTxnRequest) String added in v1.1.3 

func (m *GetActiveTxnRequest) String() string

func (*GetActiveTxnRequest) Unmarshal added in v1.1.3 

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

func (*GetActiveTxnRequest) XXX_DiscardUnknown added in v1.1.3 

func (m *GetActiveTxnRequest) XXX_DiscardUnknown()

func (*GetActiveTxnRequest) XXX_Marshal added in v1.1.3 

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

func (*GetActiveTxnRequest) XXX_Merge added in v1.1.3 

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

func (*GetActiveTxnRequest) XXX_Size added in v1.1.3 

func (m *GetActiveTxnRequest) XXX_Size() int

func (*GetActiveTxnRequest) XXX_Unmarshal added in v1.1.3 

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

type GetActiveTxnResponse added in v1.1.3 

type GetActiveTxnResponse struct {
	Valid                bool     `protobuf:"varint,1,opt,name=Valid,proto3" json:"Valid,omitempty"`
	Txn                  [][]byte `protobuf:"bytes,2,rep,name=Txn,proto3" json:"Txn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetActiveTxnResponse) Descriptor added in v1.1.3 

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

func (*GetActiveTxnResponse) GetTxn added in v1.1.3 

func (m *GetActiveTxnResponse) GetTxn() [][]byte

func (*GetActiveTxnResponse) GetValid added in v1.1.3 

func (m *GetActiveTxnResponse) GetValid() bool

func (*GetActiveTxnResponse) Marshal added in v1.1.3 

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

func (*GetActiveTxnResponse) MarshalTo added in v1.1.3 

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

func (*GetActiveTxnResponse) MarshalToSizedBuffer added in v1.1.3 

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

func (*GetActiveTxnResponse) ProtoMessage added in v1.1.3 

func (*GetActiveTxnResponse) ProtoMessage()

func (*GetActiveTxnResponse) Reset added in v1.1.3 

func (m *GetActiveTxnResponse) Reset()

func (*GetActiveTxnResponse) Size added in v1.1.3 

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

func (*GetActiveTxnResponse) String added in v1.1.3 

func (m *GetActiveTxnResponse) String() string

func (*GetActiveTxnResponse) Unmarshal added in v1.1.3 

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

func (*GetActiveTxnResponse) XXX_DiscardUnknown added in v1.1.3 

func (m *GetActiveTxnResponse) XXX_DiscardUnknown()

func (*GetActiveTxnResponse) XXX_Marshal added in v1.1.3 

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

func (*GetActiveTxnResponse) XXX_Merge added in v1.1.3 

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

func (*GetActiveTxnResponse) XXX_Size added in v1.1.3 

func (m *GetActiveTxnResponse) XXX_Size() int

func (*GetActiveTxnResponse) XXX_Unmarshal added in v1.1.3 

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

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"`
	Group                uint32   `protobuf:"varint,3,opt,name=Group,proto3" json:"Group,omitempty"`
	Sharding             Sharding `protobuf:"varint,4,opt,name=Sharding,proto3,enum=lock.Sharding" json:"Sharding,omitempty"`
	OriginTable          uint64   `protobuf:"varint,5,opt,name=OriginTable,proto3" json:"OriginTable,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) GetGroup added in v1.1.0 

func (m *GetBindRequest) GetGroup() uint32

func (*GetBindRequest) GetOriginTable added in v1.1.0 

func (m *GetBindRequest) GetOriginTable() uint64

func (*GetBindRequest) GetServiceID 

func (m *GetBindRequest) GetServiceID() string

func (*GetBindRequest) GetSharding added in v1.1.0 

func (m *GetBindRequest) GetSharding() Sharding

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"`
	Status               Status      `protobuf:"varint,2,opt,name=Status,proto3,enum=lock.Status" json:"Status,omitempty"`
	TxnIDs               [][]byte    `protobuf:"bytes,3,rep,name=TxnIDs,proto3" json:"TxnIDs,omitempty"`
	LockTables           []LockTable `protobuf:"bytes,4,rep,name=LockTables,proto3" json:"LockTables"`
	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) GetLockTables added in v1.2.0 

func (m *KeepLockTableBindRequest) GetLockTables() []LockTable

func (*KeepLockTableBindRequest) GetServiceID 

func (m *KeepLockTableBindRequest) GetServiceID() string

func (*KeepLockTableBindRequest) GetStatus added in v1.2.0 

func (m *KeepLockTableBindRequest) GetStatus() Status

func (*KeepLockTableBindRequest) GetTxnIDs added in v1.2.0 

func (m *KeepLockTableBindRequest) GetTxnIDs() [][]byte

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"`
	Status               Status   `protobuf:"varint,2,opt,name=Status,proto3,enum=lock.Status" json:"Status,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) GetStatus added in v1.2.0 

func (m *KeepLockTableBindResponse) GetStatus() Status

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"`
	RetryWait            int64               `protobuf:"varint,6,opt,name=RetryWait,proto3" json:"RetryWait,omitempty"`
	Group                uint32              `protobuf:"varint,7,opt,name=Group,proto3" json:"Group,omitempty"`
	Sharding             Sharding            `protobuf:"varint,8,opt,name=Sharding,proto3,enum=lock.Sharding" json:"Sharding,omitempty"`
	SnapShotTs           timestamp.Timestamp `protobuf:"bytes,9,opt,name=SnapShotTs,proto3" json:"SnapShotTs"`
	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) GetGroup added in v1.1.0 

func (m *LockOptions) GetGroup() uint32

func (*LockOptions) GetMode 

func (m *LockOptions) GetMode() LockMode

func (*LockOptions) GetPolicy 

func (m *LockOptions) GetPolicy() WaitPolicy

func (*LockOptions) GetRetryWait added in v1.2.0 

func (m *LockOptions) GetRetryWait() int64

func (*LockOptions) GetSharding added in v1.1.0 

func (m *LockOptions) GetSharding() Sharding

func (*LockOptions) GetSnapShotTs added in v1.2.0 

func (m *LockOptions) GetSnapShotTs() timestamp.Timestamp

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) Validate added in v1.1.0 

func (m LockOptions) Validate(rows [][]byte)

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"`
	Group                uint32   `protobuf:"varint,5,opt,name=Group,proto3" json:"Group,omitempty"`
	Sharding             Sharding `protobuf:"varint,6,opt,name=Sharding,proto3,enum=lock.Sharding" json:"Sharding,omitempty"`
	OriginTable          uint64   `protobuf:"varint,7,opt,name=OriginTable,proto3" json:"OriginTable,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) Equal added in v1.1.1 

func (m LockTable) Equal(v LockTable) bool

Equal return true means same bind

func (*LockTable) GetGroup added in v1.1.0 

func (m *LockTable) GetGroup() uint32

func (*LockTable) GetOriginTable added in v1.1.0 

func (m *LockTable) GetOriginTable() uint64

func (*LockTable) GetServiceID 

func (m *LockTable) GetServiceID() string

func (*LockTable) GetSharding added in v1.1.0 

func (m *LockTable) GetSharding() Sharding

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
	// ValidateService validate if lock service alive
	Method_ValidateService Method = 9
	// CannotCommit for orphaned transactions that are found, the lock is released
	// immediately, and you need to mark these transactions as not being able to be
	// committed in the TN
	Method_CannotCommit Method = 10
	// GetActiveTxn used to get the active txn on the lock service
	Method_GetActiveTxn Method = 11
	// SetRestartService set restart lock service
	Method_SetRestartService Method = 12
	// RemainTxnInService get remain txn in lock service
	Method_RemainTxnInService Method = 13
	// canRestartService judge if can restart lock service
	Method_CanRestartService Method = 14
	// CheckOrphan check txn is orphan
	Method_CheckOrphan Method = 15
)

func (Method) EnumDescriptor 

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

func (Method) String 

func (x Method) String() string

type OrphanTxn added in v1.1.3 

type OrphanTxn struct {
	Service              string   `protobuf:"bytes,1,opt,name=Service,proto3" json:"Service,omitempty"`
	Txn                  [][]byte `protobuf:"bytes,2,rep,name=Txn,proto3" json:"Txn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OrphanTxn) Descriptor added in v1.1.3 

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

func (*OrphanTxn) GetService added in v1.1.3 

func (m *OrphanTxn) GetService() string

func (*OrphanTxn) GetTxn added in v1.1.3 

func (m *OrphanTxn) GetTxn() [][]byte

func (*OrphanTxn) Marshal added in v1.1.3 

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

func (*OrphanTxn) MarshalTo added in v1.1.3 

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

func (*OrphanTxn) MarshalToSizedBuffer added in v1.1.3 

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

func (*OrphanTxn) ProtoMessage added in v1.1.3 

func (*OrphanTxn) ProtoMessage()

func (*OrphanTxn) Reset added in v1.1.3 

func (m *OrphanTxn) Reset()

func (*OrphanTxn) Size added in v1.1.3 

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

func (*OrphanTxn) String added in v1.1.3 

func (m *OrphanTxn) String() string

func (*OrphanTxn) Unmarshal added in v1.1.3 

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

func (*OrphanTxn) XXX_DiscardUnknown added in v1.1.3 

func (m *OrphanTxn) XXX_DiscardUnknown()

func (*OrphanTxn) XXX_Marshal added in v1.1.3 

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

func (*OrphanTxn) XXX_Merge added in v1.1.3 

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

func (*OrphanTxn) XXX_Size added in v1.1.3 

func (m *OrphanTxn) XXX_Size() int

func (*OrphanTxn) XXX_Unmarshal added in v1.1.3 

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

type RemainTxnInServiceRequest added in v1.2.0 

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

RemainTxnInServiceRequest get remain txn in service request from allocator request. operator -> TN

func (*RemainTxnInServiceRequest) Descriptor added in v1.2.0 

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

func (*RemainTxnInServiceRequest) GetServiceID added in v1.2.0 

func (m *RemainTxnInServiceRequest) GetServiceID() string

func (*RemainTxnInServiceRequest) Marshal added in v1.2.0 

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

func (*RemainTxnInServiceRequest) MarshalTo added in v1.2.0 

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

func (*RemainTxnInServiceRequest) MarshalToSizedBuffer added in v1.2.0 

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

func (*RemainTxnInServiceRequest) ProtoMessage added in v1.2.0 

func (*RemainTxnInServiceRequest) ProtoMessage()

func (*RemainTxnInServiceRequest) Reset added in v1.2.0 

func (m *RemainTxnInServiceRequest) Reset()

func (*RemainTxnInServiceRequest) Size added in v1.2.0 

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

func (*RemainTxnInServiceRequest) String added in v1.2.0 

func (m *RemainTxnInServiceRequest) String() string

func (*RemainTxnInServiceRequest) Unmarshal added in v1.2.0 

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

func (*RemainTxnInServiceRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *RemainTxnInServiceRequest) XXX_DiscardUnknown()

func (*RemainTxnInServiceRequest) XXX_Marshal added in v1.2.0 

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

func (*RemainTxnInServiceRequest) XXX_Merge added in v1.2.0 

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

func (*RemainTxnInServiceRequest) XXX_Size added in v1.2.0 

func (m *RemainTxnInServiceRequest) XXX_Size() int

func (*RemainTxnInServiceRequest) XXX_Unmarshal added in v1.2.0 

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

type RemainTxnInServiceResponse added in v1.2.0 

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

RemainTxnInServiceResponse get remain txn in service request from allocator response. TN -> operator

func (*RemainTxnInServiceResponse) Descriptor added in v1.2.0 

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

func (*RemainTxnInServiceResponse) GetRemainTxn added in v1.2.0 

func (m *RemainTxnInServiceResponse) GetRemainTxn() int32

func (*RemainTxnInServiceResponse) Marshal added in v1.2.0 

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

func (*RemainTxnInServiceResponse) MarshalTo added in v1.2.0 

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

func (*RemainTxnInServiceResponse) MarshalToSizedBuffer added in v1.2.0 

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

func (*RemainTxnInServiceResponse) ProtoMessage added in v1.2.0 

func (*RemainTxnInServiceResponse) ProtoMessage()

func (*RemainTxnInServiceResponse) Reset added in v1.2.0 

func (m *RemainTxnInServiceResponse) Reset()

func (*RemainTxnInServiceResponse) Size added in v1.2.0 

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

func (*RemainTxnInServiceResponse) String added in v1.2.0 

func (m *RemainTxnInServiceResponse) String() string

func (*RemainTxnInServiceResponse) Unmarshal added in v1.2.0 

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

func (*RemainTxnInServiceResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *RemainTxnInServiceResponse) XXX_DiscardUnknown()

func (*RemainTxnInServiceResponse) XXX_Marshal added in v1.2.0 

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

func (*RemainTxnInServiceResponse) XXX_Merge added in v1.2.0 

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

func (*RemainTxnInServiceResponse) XXX_Size added in v1.2.0 

func (m *RemainTxnInServiceResponse) XXX_Size() int

func (*RemainTxnInServiceResponse) XXX_Unmarshal added in v1.2.0 

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

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"`
	ValidateService      ValidateServiceRequest    `protobuf:"bytes,11,opt,name=ValidateService,proto3" json:"ValidateService"`
	CannotCommit         CannotCommitRequest       `protobuf:"bytes,12,opt,name=CannotCommit,proto3" json:"CannotCommit"`
	GetActiveTxn         GetActiveTxnRequest       `protobuf:"bytes,13,opt,name=GetActiveTxn,proto3" json:"GetActiveTxn"`
	SetRestartService    SetRestartServiceRequest  `protobuf:"bytes,14,opt,name=SetRestartService,proto3" json:"SetRestartService"`
	CanRestartService    CanRestartServiceRequest  `protobuf:"bytes,15,opt,name=CanRestartService,proto3" json:"CanRestartService"`
	RemainTxnInService   RemainTxnInServiceRequest `protobuf:"bytes,16,opt,name=RemainTxnInService,proto3" json:"RemainTxnInService"`
	CheckOrphan          CheckOrphanRequest        `protobuf:"bytes,17,opt,name=CheckOrphan,proto3" json:"CheckOrphan"`
	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) GetCanRestartService added in v1.2.0 

func (m *Request) GetCanRestartService() CanRestartServiceRequest

func (*Request) GetCannotCommit added in v1.1.3 

func (m *Request) GetCannotCommit() CannotCommitRequest

func (*Request) GetCheckOrphan added in v1.2.1 

func (m *Request) GetCheckOrphan() CheckOrphanRequest

func (*Request) GetGetActiveTxn added in v1.1.3 

func (m *Request) GetGetActiveTxn() GetActiveTxnRequest

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) GetRemainTxnInService added in v1.2.0 

func (m *Request) GetRemainTxnInService() RemainTxnInServiceRequest

func (*Request) GetRequestID 

func (m *Request) GetRequestID() uint64

func (*Request) GetSetRestartService added in v1.2.0 

func (m *Request) GetSetRestartService() SetRestartServiceRequest

func (*Request) GetUnlock 

func (m *Request) GetUnlock() UnlockRequest

func (*Request) GetValidateService added in v1.1.3 

func (m *Request) GetValidateService() ValidateServiceRequest

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) TypeName added in v1.2.0 

func (m Request) TypeName() 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"`
	ValidateService      ValidateServiceResponse    `protobuf:"bytes,12,opt,name=ValidateService,proto3" json:"ValidateService"`
	CannotCommit         CannotCommitResponse       `protobuf:"bytes,13,opt,name=CannotCommit,proto3" json:"CannotCommit"`
	GetActiveTxn         GetActiveTxnResponse       `protobuf:"bytes,14,opt,name=GetActiveTxn,proto3" json:"GetActiveTxn"`
	SetRestartService    SetRestartServiceResponse  `protobuf:"bytes,15,opt,name=SetRestartService,proto3" json:"SetRestartService"`
	CanRestartService    CanRestartServiceResponse  `protobuf:"bytes,16,opt,name=CanRestartService,proto3" json:"CanRestartService"`
	RemainTxnInService   RemainTxnInServiceResponse `protobuf:"bytes,17,opt,name=RemainTxnInService,proto3" json:"RemainTxnInService"`
	CheckOrphan          CheckOrphanResponse        `protobuf:"bytes,18,opt,name=CheckOrphan,proto3" json:"CheckOrphan"`
	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) GetCanRestartService added in v1.2.0 

func (m *Response) GetCanRestartService() CanRestartServiceResponse

func (*Response) GetCannotCommit added in v1.1.3 

func (m *Response) GetCannotCommit() CannotCommitResponse

func (*Response) GetCheckOrphan added in v1.2.1 

func (m *Response) GetCheckOrphan() CheckOrphanResponse

func (*Response) GetError 

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

func (*Response) GetGetActiveTxn added in v1.1.3 

func (m *Response) GetGetActiveTxn() GetActiveTxnResponse

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) GetRemainTxnInService added in v1.2.0 

func (m *Response) GetRemainTxnInService() RemainTxnInServiceResponse

func (*Response) GetRequestID 

func (m *Response) GetRequestID() uint64

func (*Response) GetSetRestartService added in v1.2.0 

func (m *Response) GetSetRestartService() SetRestartServiceResponse

func (*Response) GetUnlock 

func (m *Response) GetUnlock() UnlockResponse

func (*Response) GetValidateService added in v1.1.3 

func (m *Response) GetValidateService() ValidateServiceResponse

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) TypeName added in v1.2.0 

func (m Response) TypeName() 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"`
	ConflictKey     []byte `protobuf:"bytes,6,opt,name=ConflictKey,proto3" json:"ConflictKey,omitempty"`
	ConflictTxn     []byte `protobuf:"bytes,7,opt,name=ConflictTxn,proto3" json:"ConflictTxn,omitempty"`
	PrevWaiter      []byte `protobuf:"bytes,8,opt,name=PrevWaiter,proto3" json:"PrevWaiter,omitempty"`
	Waiters         uint32 `protobuf:"varint,9,opt,name=Waiters,proto3" json:"Waiters,omitempty"`
	// NewLockAdd if true means new lock added, false means lock is added before by current
	// txn
	NewLockAdd           bool     `protobuf:"varint,10,opt,name=NewLockAdd,proto3" json:"NewLockAdd,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) GetConflictKey added in v1.2.0 

func (m *Result) GetConflictKey() []byte

func (*Result) GetConflictTxn added in v1.2.0 

func (m *Result) GetConflictTxn() []byte

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) GetNewLockAdd added in v1.2.3 

func (m *Result) GetNewLockAdd() bool

func (*Result) GetPrevWaiter added in v1.2.0 

func (m *Result) GetPrevWaiter() []byte

func (*Result) GetTableDefChanged added in v1.0.0 

func (m *Result) GetTableDefChanged() bool

func (*Result) GetTimestamp 

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

func (*Result) GetWaiters added in v1.2.0 

func (m *Result) GetWaiters() uint32

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 SetRestartServiceRequest added in v1.2.0 

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

SetRestartServiceRequest set restart lock service request from allocator request. operator -> TN

func (*SetRestartServiceRequest) Descriptor added in v1.2.0 

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

func (*SetRestartServiceRequest) GetServiceID added in v1.2.0 

func (m *SetRestartServiceRequest) GetServiceID() string

func (*SetRestartServiceRequest) Marshal added in v1.2.0 

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

func (*SetRestartServiceRequest) MarshalTo added in v1.2.0 

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

func (*SetRestartServiceRequest) MarshalToSizedBuffer added in v1.2.0 

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

func (*SetRestartServiceRequest) ProtoMessage added in v1.2.0 

func (*SetRestartServiceRequest) ProtoMessage()

func (*SetRestartServiceRequest) Reset added in v1.2.0 

func (m *SetRestartServiceRequest) Reset()

func (*SetRestartServiceRequest) Size added in v1.2.0 

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

func (*SetRestartServiceRequest) String added in v1.2.0 

func (m *SetRestartServiceRequest) String() string

func (*SetRestartServiceRequest) Unmarshal added in v1.2.0 

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

func (*SetRestartServiceRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *SetRestartServiceRequest) XXX_DiscardUnknown()

func (*SetRestartServiceRequest) XXX_Marshal added in v1.2.0 

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

func (*SetRestartServiceRequest) XXX_Merge added in v1.2.0 

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

func (*SetRestartServiceRequest) XXX_Size added in v1.2.0 

func (m *SetRestartServiceRequest) XXX_Size() int

func (*SetRestartServiceRequest) XXX_Unmarshal added in v1.2.0 

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

type SetRestartServiceResponse added in v1.2.0 

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

SetRestartServiceResponse set restart lock service request from allocator response. TN -> operator

func (*SetRestartServiceResponse) Descriptor added in v1.2.0 

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

func (*SetRestartServiceResponse) GetOK added in v1.2.0 

func (m *SetRestartServiceResponse) GetOK() bool

func (*SetRestartServiceResponse) Marshal added in v1.2.0 

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

func (*SetRestartServiceResponse) MarshalTo added in v1.2.0 

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

func (*SetRestartServiceResponse) MarshalToSizedBuffer added in v1.2.0 

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

func (*SetRestartServiceResponse) ProtoMessage added in v1.2.0 

func (*SetRestartServiceResponse) ProtoMessage()

func (*SetRestartServiceResponse) Reset added in v1.2.0 

func (m *SetRestartServiceResponse) Reset()

func (*SetRestartServiceResponse) Size added in v1.2.0 

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

func (*SetRestartServiceResponse) String added in v1.2.0 

func (m *SetRestartServiceResponse) String() string

func (*SetRestartServiceResponse) Unmarshal added in v1.2.0 

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

func (*SetRestartServiceResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *SetRestartServiceResponse) XXX_DiscardUnknown()

func (*SetRestartServiceResponse) XXX_Marshal added in v1.2.0 

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

func (*SetRestartServiceResponse) XXX_Merge added in v1.2.0 

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

func (*SetRestartServiceResponse) XXX_Size added in v1.2.0 

func (m *SetRestartServiceResponse) XXX_Size() int

func (*SetRestartServiceResponse) XXX_Unmarshal added in v1.2.0 

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

type Sharding added in v1.1.0 

type Sharding int32
const (
	Sharding_None  Sharding = 0
	Sharding_ByRow Sharding = 1
)

func (Sharding) EnumDescriptor added in v1.1.0 

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

func (Sharding) String added in v1.1.0 

func (x Sharding) String() string

type Status added in v1.2.0 

type Status int32
const (
	Status_ServiceLockEnable  Status = 0
	Status_ServiceLockWaiting Status = 1
	Status_ServiceUnLockSucc  Status = 2
	Status_ServiceCanRestart  Status = 3
)

func (Status) EnumDescriptor added in v1.2.0 

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

func (Status) String added in v1.2.0 

func (x Status) String() string

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"`
	Mutations            []ExtraMutation     `protobuf:"bytes,3,rep,name=Mutations,proto3" json:"Mutations"`
	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) GetMutations added in v1.1.0 

func (m *UnlockRequest) GetMutations() []ExtraMutation

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 ValidateServiceRequest added in v1.1.3 

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

ValidateServiceRequest validate if lock service alive request. TN -> CN

func (*ValidateServiceRequest) Descriptor added in v1.1.3 

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

func (*ValidateServiceRequest) GetServiceID added in v1.1.3 

func (m *ValidateServiceRequest) GetServiceID() string

func (*ValidateServiceRequest) Marshal added in v1.1.3 

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

func (*ValidateServiceRequest) MarshalTo added in v1.1.3 

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

func (*ValidateServiceRequest) MarshalToSizedBuffer added in v1.1.3 

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

func (*ValidateServiceRequest) ProtoMessage added in v1.1.3 

func (*ValidateServiceRequest) ProtoMessage()

func (*ValidateServiceRequest) Reset added in v1.1.3 

func (m *ValidateServiceRequest) Reset()

func (*ValidateServiceRequest) Size added in v1.1.3 

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

func (*ValidateServiceRequest) String added in v1.1.3 

func (m *ValidateServiceRequest) String() string

func (*ValidateServiceRequest) Unmarshal added in v1.1.3 

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

func (*ValidateServiceRequest) XXX_DiscardUnknown added in v1.1.3 

func (m *ValidateServiceRequest) XXX_DiscardUnknown()

func (*ValidateServiceRequest) XXX_Marshal added in v1.1.3 

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

func (*ValidateServiceRequest) XXX_Merge added in v1.1.3 

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

func (*ValidateServiceRequest) XXX_Size added in v1.1.3 

func (m *ValidateServiceRequest) XXX_Size() int

func (*ValidateServiceRequest) XXX_Unmarshal added in v1.1.3 

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

type ValidateServiceResponse added in v1.1.3 

type ValidateServiceResponse 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. CN -> DN

func (*ValidateServiceResponse) Descriptor added in v1.1.3 

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

func (*ValidateServiceResponse) GetOK added in v1.1.3 

func (m *ValidateServiceResponse) GetOK() bool

func (*ValidateServiceResponse) Marshal added in v1.1.3 

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

func (*ValidateServiceResponse) MarshalTo added in v1.1.3 

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

func (*ValidateServiceResponse) MarshalToSizedBuffer added in v1.1.3 

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

func (*ValidateServiceResponse) ProtoMessage added in v1.1.3 

func (*ValidateServiceResponse) ProtoMessage()

func (*ValidateServiceResponse) Reset added in v1.1.3 

func (m *ValidateServiceResponse) Reset()

func (*ValidateServiceResponse) Size added in v1.1.3 

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

func (*ValidateServiceResponse) String added in v1.1.3 

func (m *ValidateServiceResponse) String() string

func (*ValidateServiceResponse) Unmarshal added in v1.1.3 

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

func (*ValidateServiceResponse) XXX_DiscardUnknown added in v1.1.3 

func (m *ValidateServiceResponse) XXX_DiscardUnknown()

func (*ValidateServiceResponse) XXX_Marshal added in v1.1.3 

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

func (*ValidateServiceResponse) XXX_Merge added in v1.1.3 

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

func (*ValidateServiceResponse) XXX_Size added in v1.1.3 

func (m *ValidateServiceResponse) XXX_Size() int

func (*ValidateServiceResponse) XXX_Unmarshal added in v1.1.3 

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