txn

package

Go to main page

Versions in this module

v1

v1.2.4

Sep 20, 2024

v1.2.3

Sep 10, 2024

Changes in this version

type TxnOptions

+ InIncrStmt bool

+ InRollbackStmt bool

+ func (m *TxnOptions) GetInIncrStmt() bool

+ func (m *TxnOptions) GetInRollbackStmt() bool

v1.2.3-hotfix-20241101

Oct 31, 2024

v1.2.3-hotfix-20241016

Oct 16, 2024

v1.2.3-hotfix-20241010

Oct 11, 2024

v1.2.3-hotfix-20240916

Sep 14, 2024

v1.2.2

Jul 11, 2024

v1.2.2-20240715

Jul 15, 2024

v1.2.1

Jun 28, 2024

Changes in this version

type TxnOptions

+ Autocommit bool

+ ByBegin bool

+ func (m *TxnOptions) GetAutocommit() bool

+ func (m *TxnOptions) GetByBegin() bool

v1.2.1-20240709

Jul 9, 2024

v1.2.0

May 17, 2024

Changes in this version

type CNTxnSnapshot

+ Options TxnOptions

+ func (m *CNTxnSnapshot) GetOptions() TxnOptions

type TxnOptions

+ AccountID uint32

+ CN string

+ ConnectionID uint32

+ Features uint32

+ SessionID string

+ SkipLockTableModes []lock.LockMode

+ SkipLockTables []uint64

+ UserName string

+ func (m *TxnOptions) GetAccountID() uint32

+ func (m *TxnOptions) GetCN() string

+ func (m *TxnOptions) GetConnectionID() uint32

+ func (m *TxnOptions) GetFeatures() uint32

+ func (m *TxnOptions) GetSessionID() string

+ func (m *TxnOptions) GetSkipLockTableModes() []lock.LockMode

+ func (m *TxnOptions) GetSkipLockTables() []uint64

+ func (m *TxnOptions) GetUserName() string

+ func (m TxnOptions) CacheWriteEnabled() bool

+ func (m TxnOptions) CheckDupEnabled() bool

+ func (m TxnOptions) Is1PCDisabled() bool

+ func (m TxnOptions) ReadOnly() bool

+ func (m TxnOptions) TraceDisabled() bool

+ func (m TxnOptions) UserTxn() bool

+ func (m TxnOptions) WithDisable1PC() TxnOptions

+ func (m TxnOptions) WithDisableTrace() TxnOptions

+ func (m TxnOptions) WithEnableCacheWrite() TxnOptions

+ func (m TxnOptions) WithEnableCheckDup() TxnOptions

+ func (m TxnOptions) WithReadOnly() TxnOptions

+ func (m TxnOptions) WithUserTxn() TxnOptions

v1.1.3

Apr 15, 2024

v1.1.2

Apr 2, 2024

Changes in this version

+ type TxnOptions struct

+ Counter string

+ InCommit bool

+ InRollback bool

+ InRunSql bool

+ SessionInfo string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnOptions) Descriptor() ([]byte, []int)

+ func (*TxnOptions) ProtoMessage()

+ func (m *TxnOptions) GetCounter() string

+ func (m *TxnOptions) GetInCommit() bool

+ func (m *TxnOptions) GetInRollback() bool

+ func (m *TxnOptions) GetInRunSql() bool

+ func (m *TxnOptions) GetSessionInfo() string

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

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

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

+ func (m *TxnOptions) Reset()

+ func (m *TxnOptions) Size() (n int)

+ func (m *TxnOptions) String() string

+ func (m *TxnOptions) Unmarshal(dAtA []byte) error

+ func (m *TxnOptions) XXX_DiscardUnknown()

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

+ func (m *TxnOptions) XXX_Merge(src proto.Message)

+ func (m *TxnOptions) XXX_Size() int

+ func (m *TxnOptions) XXX_Unmarshal(b []byte) error

v1.1.1

Feb 2, 2024

v1.1.0

Dec 29, 2023

v1.0.2

Dec 21, 2023

v1.0.1

Dec 15, 2023

v1.0.0

Nov 13, 2023

Changes in this version

type TxnCommitRequest

+ Payload []*TxnRequest

+ func (m *TxnCommitRequest) GetPayload() []*TxnRequest

type TxnCommitResponse

+ InvalidLockTables []uint64

+ func (m *TxnCommitResponse) GetInvalidLockTables() []uint64

+ type TxnCommitTNShardRequest struct

+ TNShard metadata.TNShard

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnCommitTNShardRequest) Descriptor() ([]byte, []int)

+ func (*TxnCommitTNShardRequest) ProtoMessage()

+ func (m *TxnCommitTNShardRequest) GetTNShard() metadata.TNShard

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

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

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

+ func (m *TxnCommitTNShardRequest) Reset()

+ func (m *TxnCommitTNShardRequest) Size() (n int)

+ func (m *TxnCommitTNShardRequest) String() string

+ func (m *TxnCommitTNShardRequest) Unmarshal(dAtA []byte) error

+ func (m *TxnCommitTNShardRequest) XXX_DiscardUnknown()

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

+ func (m *TxnCommitTNShardRequest) XXX_Merge(src proto.Message)

+ func (m *TxnCommitTNShardRequest) XXX_Size() int

+ func (m *TxnCommitTNShardRequest) XXX_Unmarshal(b []byte) error

+ type TxnCommitTNShardResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnCommitTNShardResponse) Descriptor() ([]byte, []int)

+ func (*TxnCommitTNShardResponse) ProtoMessage()

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

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

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

+ func (m *TxnCommitTNShardResponse) Reset()

+ func (m *TxnCommitTNShardResponse) Size() (n int)

+ func (m *TxnCommitTNShardResponse) String() string

+ func (m *TxnCommitTNShardResponse) Unmarshal(dAtA []byte) error

+ func (m *TxnCommitTNShardResponse) XXX_DiscardUnknown()

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

+ func (m *TxnCommitTNShardResponse) XXX_Merge(src proto.Message)

+ func (m *TxnCommitTNShardResponse) XXX_Size() int

+ func (m *TxnCommitTNShardResponse) XXX_Unmarshal(b []byte) error

type TxnGetStatusRequest

+ TNShard metadata.TNShard

+ func (m *TxnGetStatusRequest) GetTNShard() metadata.TNShard

type TxnMeta

+ TNShards []metadata.TNShard

+ func (m *TxnMeta) GetTNShards() []metadata.TNShard

type TxnMethod

+ const TxnMethod_CommitTNShard

+ const TxnMethod_RollbackTNShard

type TxnPrepareRequest

+ TNShard metadata.TNShard

+ func (m *TxnPrepareRequest) GetTNShard() metadata.TNShard

type TxnRemoveMetadataRequest

+ TNShard metadata.TNShard

+ func (m *TxnRemoveMetadataRequest) GetTNShard() metadata.TNShard

type TxnRequest

+ CommitTNShardRequest *TxnCommitTNShardRequest

+ RollbackTNShardRequest *TxnRollbackTNShardRequest

+ func (m *TxnRequest) GetCommitTNShardRequest() *TxnCommitTNShardRequest

+ func (m *TxnRequest) GetRollbackTNShardRequest() *TxnRollbackTNShardRequest

+ func (m TxnRequest) GetTargetTN() metadata.TNShard

type TxnResponse

+ CommitTNShardResponse *TxnCommitTNShardResponse

+ RollbackTNShardResponse *TxnRollbackTNShardResponse

+ func (m *TxnResponse) GetCommitTNShardResponse() *TxnCommitTNShardResponse

+ func (m *TxnResponse) GetRollbackTNShardResponse() *TxnRollbackTNShardResponse

+ type TxnRollbackTNShardRequest struct

+ TNShard metadata.TNShard

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnRollbackTNShardRequest) Descriptor() ([]byte, []int)

+ func (*TxnRollbackTNShardRequest) ProtoMessage()

+ func (m *TxnRollbackTNShardRequest) GetTNShard() metadata.TNShard

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

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

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

+ func (m *TxnRollbackTNShardRequest) Reset()

+ func (m *TxnRollbackTNShardRequest) Size() (n int)

+ func (m *TxnRollbackTNShardRequest) String() string

+ func (m *TxnRollbackTNShardRequest) Unmarshal(dAtA []byte) error

+ func (m *TxnRollbackTNShardRequest) XXX_DiscardUnknown()

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

+ func (m *TxnRollbackTNShardRequest) XXX_Merge(src proto.Message)

+ func (m *TxnRollbackTNShardRequest) XXX_Size() int

+ func (m *TxnRollbackTNShardRequest) XXX_Unmarshal(b []byte) error

+ type TxnRollbackTNShardResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnRollbackTNShardResponse) Descriptor() ([]byte, []int)

+ func (*TxnRollbackTNShardResponse) ProtoMessage()

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

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

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

+ func (m *TxnRollbackTNShardResponse) Reset()

+ func (m *TxnRollbackTNShardResponse) Size() (n int)

+ func (m *TxnRollbackTNShardResponse) String() string

+ func (m *TxnRollbackTNShardResponse) Unmarshal(dAtA []byte) error

+ func (m *TxnRollbackTNShardResponse) XXX_DiscardUnknown()

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

+ func (m *TxnRollbackTNShardResponse) XXX_Merge(src proto.Message)

+ func (m *TxnRollbackTNShardResponse) XXX_Size() int

+ func (m *TxnRollbackTNShardResponse) XXX_Unmarshal(b []byte) error

v1.0.0-rc2

Oct 24, 2023

v1.0.0-rc1

Aug 24, 2023

v0

v0.8.1

Oct 9, 2023

v0.8.0

Jun 30, 2023

Changes in this version

+ var TxnIsolation_name = map[int32]string

+ var TxnIsolation_value = map[string]int32

+ var TxnMode_name = map[int32]string

+ var TxnMode_value = map[string]int32

+ func ValidTxnIsolation(value string) bool

+ func ValidTxnMode(value string) bool

type CNTxnSnapshot

+ LockTables []lock.LockTable

+ func (m *CNTxnSnapshot) GetLockTables() []lock.LockTable

+ type TxnIsolation int32

+ const TxnIsolation_RC

+ const TxnIsolation_SI

+ func GetTxnIsolation(value string) TxnIsolation

+ func (TxnIsolation) EnumDescriptor() ([]byte, []int)

+ func (x TxnIsolation) String() string

type TxnMeta

+ Isolation TxnIsolation

+ LockService string

+ LockTables []lock.LockTable

+ Mirror bool

+ Mode TxnMode

+ func (m *TxnMeta) GetIsolation() TxnIsolation

+ func (m *TxnMeta) GetLockService() string

+ func (m *TxnMeta) GetLockTables() []lock.LockTable

+ func (m *TxnMeta) GetMirror() bool

+ func (m *TxnMeta) GetMode() TxnMode

+ func (m TxnMeta) IsPessimistic() bool

+ func (m TxnMeta) IsRCIsolation() bool

+ type TxnMode int32

+ const TxnMode_Optimistic

+ const TxnMode_Pessimistic

+ func GetTxnMode(value string) TxnMode

+ func (TxnMode) EnumDescriptor() ([]byte, []int)

+ func (x TxnMode) String() string

v0.7.0

Feb 18, 2023

Changes in this version

type TxnRequest

+ func (m TxnRequest) DebugStringWithPayload(withPayload bool) string

v0.6.0

Nov 29, 2022

Changes in this version

+ func RequestsDebugString(requests []TxnRequest) string

+ func ResponsesDebugString(responses []TxnResponse) string

type TxnError

+ Error []byte

+ TxnErrCode uint32

+ func WrapError(err error, internalCode uint16) *TxnError

+ func (m *TxnError) GetError() []byte

+ func (m *TxnError) GetTxnErrCode() uint32

+ func (m TxnError) UnwrapError() error

type TxnMethod

+ const TxnMethod_DEBUG

type TxnRequest

+ Options *TxnRequestOptions

+ func (m *TxnRequest) GetOptions() *TxnRequestOptions

+ type TxnRequestOptions struct

+ RetryCodes []int32

+ RetryInterval int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnRequestOptions) Descriptor() ([]byte, []int)

+ func (*TxnRequestOptions) ProtoMessage()

+ func (m *TxnRequestOptions) GetRetryCodes() []int32

+ func (m *TxnRequestOptions) GetRetryInterval() int64

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

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

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

+ func (m *TxnRequestOptions) Reset()

+ func (m *TxnRequestOptions) Size() (n int)

+ func (m *TxnRequestOptions) String() string

+ func (m *TxnRequestOptions) Unmarshal(dAtA []byte) error

+ func (m *TxnRequestOptions) XXX_DiscardUnknown()

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

+ func (m *TxnRequestOptions) XXX_Merge(src proto.Message)

+ func (m *TxnRequestOptions) XXX_Size() int

+ func (m *TxnRequestOptions) XXX_Unmarshal(b []byte) error

v0.5.1

Aug 17, 2022

v0.5.0

Jul 14, 2022

Changes in this version

+ const SkipResponseFlag

+ var ErrIntOverflowTxn = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthTxn = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupTxn = fmt.Errorf("proto: unexpected end of group")

+ var ErrorCode_name = map[int32]string

+ var ErrorCode_value = map[string]int32

+ var TxnMethod_name = map[int32]string

+ var TxnMethod_value = map[string]int32

+ var TxnStatus_name = map[int32]string

+ var TxnStatus_value = map[string]int32

+ type CNOpRequest struct

+ OpCode uint32

+ Payload []byte

+ Target metadata.DNShard

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CNOpRequest) Descriptor() ([]byte, []int)

+ func (*CNOpRequest) ProtoMessage()

+ func (m *CNOpRequest) GetOpCode() uint32

+ func (m *CNOpRequest) GetPayload() []byte

+ func (m *CNOpRequest) GetTarget() metadata.DNShard

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

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

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

+ func (m *CNOpRequest) Reset()

+ func (m *CNOpRequest) Size() (n int)

+ func (m *CNOpRequest) String() string

+ func (m *CNOpRequest) Unmarshal(dAtA []byte) error

+ func (m *CNOpRequest) XXX_DiscardUnknown()

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

+ func (m *CNOpRequest) XXX_Merge(src proto.Message)

+ func (m *CNOpRequest) XXX_Size() int

+ func (m *CNOpRequest) XXX_Unmarshal(b []byte) error

+ func (m CNOpRequest) DebugString() string

+ type CNOpResponse struct

+ Payload []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func GetCNOpResponse(response TxnResponse) CNOpResponse

+ func (*CNOpResponse) Descriptor() ([]byte, []int)

+ func (*CNOpResponse) ProtoMessage()

+ func (m *CNOpResponse) GetPayload() []byte

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

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

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

+ func (m *CNOpResponse) Reset()

+ func (m *CNOpResponse) Size() (n int)

+ func (m *CNOpResponse) String() string

+ func (m *CNOpResponse) Unmarshal(dAtA []byte) error

+ func (m *CNOpResponse) XXX_DiscardUnknown()

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

+ func (m *CNOpResponse) XXX_Merge(src proto.Message)

+ func (m *CNOpResponse) XXX_Size() int

+ func (m *CNOpResponse) XXX_Unmarshal(b []byte) error

+ func (m CNOpResponse) DebugString() string

+ type CNTxnSnapshot struct

+ Disable1PCOpt bool

+ EnableCacheWrite bool

+ ReadyOnly bool

+ Txn TxnMeta

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CNTxnSnapshot) Descriptor() ([]byte, []int)

+ func (*CNTxnSnapshot) ProtoMessage()

+ func (m *CNTxnSnapshot) GetDisable1PCOpt() bool

+ func (m *CNTxnSnapshot) GetEnableCacheWrite() bool

+ func (m *CNTxnSnapshot) GetReadyOnly() bool

+ func (m *CNTxnSnapshot) GetTxn() TxnMeta

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

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

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

+ func (m *CNTxnSnapshot) Reset()

+ func (m *CNTxnSnapshot) Size() (n int)

+ func (m *CNTxnSnapshot) String() string

+ func (m *CNTxnSnapshot) Unmarshal(dAtA []byte) error

+ func (m *CNTxnSnapshot) XXX_DiscardUnknown()

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

+ func (m *CNTxnSnapshot) XXX_Merge(src proto.Message)

+ func (m *CNTxnSnapshot) XXX_Size() int

+ func (m *CNTxnSnapshot) XXX_Unmarshal(b []byte) error

+ type ErrorCode int32

+ const ErrorCode_RPCError

+ const ErrorCode_TAECommit

+ const ErrorCode_TAEPrepare

+ const ErrorCode_TAERead

+ const ErrorCode_TAERollback

+ const ErrorCode_TAEWrite

+ const ErrorCode_TxnNotActive

+ const ErrorCode_TxnNotFound

+ const ErrorCode_WaitTxn

+ func (ErrorCode) EnumDescriptor() ([]byte, []int)

+ func (x ErrorCode) String() string

+ type TxnCommitDNShardRequest struct

+ DNShard metadata.DNShard

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnCommitDNShardRequest) Descriptor() ([]byte, []int)

+ func (*TxnCommitDNShardRequest) ProtoMessage()

+ func (m *TxnCommitDNShardRequest) GetDNShard() metadata.DNShard

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

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

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

+ func (m *TxnCommitDNShardRequest) Reset()

+ func (m *TxnCommitDNShardRequest) Size() (n int)

+ func (m *TxnCommitDNShardRequest) String() string

+ func (m *TxnCommitDNShardRequest) Unmarshal(dAtA []byte) error

+ func (m *TxnCommitDNShardRequest) XXX_DiscardUnknown()

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

+ func (m *TxnCommitDNShardRequest) XXX_Merge(src proto.Message)

+ func (m *TxnCommitDNShardRequest) XXX_Size() int

+ func (m *TxnCommitDNShardRequest) XXX_Unmarshal(b []byte) error

+ type TxnCommitDNShardResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnCommitDNShardResponse) Descriptor() ([]byte, []int)

+ func (*TxnCommitDNShardResponse) ProtoMessage()

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

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

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

+ func (m *TxnCommitDNShardResponse) Reset()

+ func (m *TxnCommitDNShardResponse) Size() (n int)

+ func (m *TxnCommitDNShardResponse) String() string

+ func (m *TxnCommitDNShardResponse) Unmarshal(dAtA []byte) error

+ func (m *TxnCommitDNShardResponse) XXX_DiscardUnknown()

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

+ func (m *TxnCommitDNShardResponse) XXX_Merge(src proto.Message)

+ func (m *TxnCommitDNShardResponse) XXX_Size() int

+ func (m *TxnCommitDNShardResponse) XXX_Unmarshal(b []byte) error

+ type TxnCommitRequest struct

+ Disable1PCOpt bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnCommitRequest) Descriptor() ([]byte, []int)

+ func (*TxnCommitRequest) ProtoMessage()

+ func (m *TxnCommitRequest) GetDisable1PCOpt() bool

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

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

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

+ func (m *TxnCommitRequest) Reset()

+ func (m *TxnCommitRequest) Size() (n int)

+ func (m *TxnCommitRequest) String() string

+ func (m *TxnCommitRequest) Unmarshal(dAtA []byte) error

+ func (m *TxnCommitRequest) XXX_DiscardUnknown()

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

+ func (m *TxnCommitRequest) XXX_Merge(src proto.Message)

+ func (m *TxnCommitRequest) XXX_Size() int

+ func (m *TxnCommitRequest) XXX_Unmarshal(b []byte) error

+ type TxnCommitResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnCommitResponse) Descriptor() ([]byte, []int)

+ func (*TxnCommitResponse) ProtoMessage()

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

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

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

+ func (m *TxnCommitResponse) Reset()

+ func (m *TxnCommitResponse) Size() (n int)

+ func (m *TxnCommitResponse) String() string

+ func (m *TxnCommitResponse) Unmarshal(dAtA []byte) error

+ func (m *TxnCommitResponse) XXX_DiscardUnknown()

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

+ func (m *TxnCommitResponse) XXX_Merge(src proto.Message)

+ func (m *TxnCommitResponse) XXX_Size() int

+ func (m *TxnCommitResponse) XXX_Unmarshal(b []byte) error

+ type TxnError struct

+ Code ErrorCode

+ Message string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnError) Descriptor() ([]byte, []int)

+ func (*TxnError) ProtoMessage()

+ func (m *TxnError) GetCode() ErrorCode

+ func (m *TxnError) GetMessage() string

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

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

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

+ func (m *TxnError) Reset()

+ func (m *TxnError) Size() (n int)

+ func (m *TxnError) String() string

+ func (m *TxnError) Unmarshal(dAtA []byte) error

+ func (m *TxnError) XXX_DiscardUnknown()

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

+ func (m *TxnError) XXX_Merge(src proto.Message)

+ func (m *TxnError) XXX_Size() int

+ func (m *TxnError) XXX_Unmarshal(b []byte) error

+ func (m TxnError) DebugString() string

+ type TxnGetStatusRequest struct

+ DNShard metadata.DNShard

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnGetStatusRequest) Descriptor() ([]byte, []int)

+ func (*TxnGetStatusRequest) ProtoMessage()

+ func (m *TxnGetStatusRequest) GetDNShard() metadata.DNShard

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

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

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

+ func (m *TxnGetStatusRequest) Reset()

+ func (m *TxnGetStatusRequest) Size() (n int)

+ func (m *TxnGetStatusRequest) String() string

+ func (m *TxnGetStatusRequest) Unmarshal(dAtA []byte) error

+ func (m *TxnGetStatusRequest) XXX_DiscardUnknown()

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

+ func (m *TxnGetStatusRequest) XXX_Merge(src proto.Message)

+ func (m *TxnGetStatusRequest) XXX_Size() int

+ func (m *TxnGetStatusRequest) XXX_Unmarshal(b []byte) error

+ type TxnGetStatusResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnGetStatusResponse) Descriptor() ([]byte, []int)

+ func (*TxnGetStatusResponse) ProtoMessage()

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

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

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

+ func (m *TxnGetStatusResponse) Reset()

+ func (m *TxnGetStatusResponse) Size() (n int)

+ func (m *TxnGetStatusResponse) String() string

+ func (m *TxnGetStatusResponse) Unmarshal(dAtA []byte) error

+ func (m *TxnGetStatusResponse) XXX_DiscardUnknown()

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

+ func (m *TxnGetStatusResponse) XXX_Merge(src proto.Message)

+ func (m *TxnGetStatusResponse) XXX_Size() int

+ func (m *TxnGetStatusResponse) XXX_Unmarshal(b []byte) error

+ type TxnMeta struct

+ CommitTS timestamp.Timestamp

+ DNShards []metadata.DNShard

+ ID []byte

+ PreparedTS timestamp.Timestamp

+ SnapshotTS timestamp.Timestamp

+ Status TxnStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnMeta) Descriptor() ([]byte, []int)

+ func (*TxnMeta) ProtoMessage()

+ func (m *TxnMeta) GetCommitTS() timestamp.Timestamp

+ func (m *TxnMeta) GetDNShards() []metadata.DNShard

+ func (m *TxnMeta) GetID() []byte

+ func (m *TxnMeta) GetPreparedTS() timestamp.Timestamp

+ func (m *TxnMeta) GetSnapshotTS() timestamp.Timestamp

+ func (m *TxnMeta) GetStatus() TxnStatus

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

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

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

+ func (m *TxnMeta) Reset()

+ func (m *TxnMeta) Size() (n int)

+ func (m *TxnMeta) String() string

+ func (m *TxnMeta) Unmarshal(dAtA []byte) error

+ func (m *TxnMeta) XXX_DiscardUnknown()

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

+ func (m *TxnMeta) XXX_Merge(src proto.Message)

+ func (m *TxnMeta) XXX_Size() int

+ func (m *TxnMeta) XXX_Unmarshal(b []byte) error

+ func (m TxnMeta) DebugString() string

+ type TxnMethod int32

+ const TxnMethod_Commit

+ const TxnMethod_CommitDNShard

+ const TxnMethod_GetStatus

+ const TxnMethod_Prepare

+ const TxnMethod_Read

+ const TxnMethod_RemoveMedata

+ const TxnMethod_Rollback

+ const TxnMethod_RollbackDNShard

+ const TxnMethod_Write

+ func (TxnMethod) EnumDescriptor() ([]byte, []int)

+ func (x TxnMethod) String() string

+ type TxnPrepareRequest struct

+ DNShard metadata.DNShard

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnPrepareRequest) Descriptor() ([]byte, []int)

+ func (*TxnPrepareRequest) ProtoMessage()

+ func (m *TxnPrepareRequest) GetDNShard() metadata.DNShard

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

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

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

+ func (m *TxnPrepareRequest) Reset()

+ func (m *TxnPrepareRequest) Size() (n int)

+ func (m *TxnPrepareRequest) String() string

+ func (m *TxnPrepareRequest) Unmarshal(dAtA []byte) error

+ func (m *TxnPrepareRequest) XXX_DiscardUnknown()

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

+ func (m *TxnPrepareRequest) XXX_Merge(src proto.Message)

+ func (m *TxnPrepareRequest) XXX_Size() int

+ func (m *TxnPrepareRequest) XXX_Unmarshal(b []byte) error

+ type TxnPrepareResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnPrepareResponse) Descriptor() ([]byte, []int)

+ func (*TxnPrepareResponse) ProtoMessage()

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

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

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

+ func (m *TxnPrepareResponse) Reset()

+ func (m *TxnPrepareResponse) Size() (n int)

+ func (m *TxnPrepareResponse) String() string

+ func (m *TxnPrepareResponse) Unmarshal(dAtA []byte) error

+ func (m *TxnPrepareResponse) XXX_DiscardUnknown()

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

+ func (m *TxnPrepareResponse) XXX_Merge(src proto.Message)

+ func (m *TxnPrepareResponse) XXX_Size() int

+ func (m *TxnPrepareResponse) XXX_Unmarshal(b []byte) error

+ type TxnRemoveMetadataRequest struct

+ DNShard metadata.DNShard

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnRemoveMetadataRequest) Descriptor() ([]byte, []int)

+ func (*TxnRemoveMetadataRequest) ProtoMessage()

+ func (m *TxnRemoveMetadataRequest) GetDNShard() metadata.DNShard

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

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

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

+ func (m *TxnRemoveMetadataRequest) Reset()

+ func (m *TxnRemoveMetadataRequest) Size() (n int)

+ func (m *TxnRemoveMetadataRequest) String() string

+ func (m *TxnRemoveMetadataRequest) Unmarshal(dAtA []byte) error

+ func (m *TxnRemoveMetadataRequest) XXX_DiscardUnknown()

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

+ func (m *TxnRemoveMetadataRequest) XXX_Merge(src proto.Message)

+ func (m *TxnRemoveMetadataRequest) XXX_Size() int

+ func (m *TxnRemoveMetadataRequest) XXX_Unmarshal(b []byte) error

+ type TxnRemoveMetadataResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnRemoveMetadataResponse) Descriptor() ([]byte, []int)

+ func (*TxnRemoveMetadataResponse) ProtoMessage()

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

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

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

+ func (m *TxnRemoveMetadataResponse) Reset()

+ func (m *TxnRemoveMetadataResponse) Size() (n int)

+ func (m *TxnRemoveMetadataResponse) String() string

+ func (m *TxnRemoveMetadataResponse) Unmarshal(dAtA []byte) error

+ func (m *TxnRemoveMetadataResponse) XXX_DiscardUnknown()

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

+ func (m *TxnRemoveMetadataResponse) XXX_Merge(src proto.Message)

+ func (m *TxnRemoveMetadataResponse) XXX_Size() int

+ func (m *TxnRemoveMetadataResponse) XXX_Unmarshal(b []byte) error

+ type TxnRequest struct

+ CNRequest *CNOpRequest

+ CommitDNShardRequest *TxnCommitDNShardRequest

+ CommitRequest *TxnCommitRequest

+ Flag uint32

+ GetStatusRequest *TxnGetStatusRequest

+ Method TxnMethod

+ PrepareRequest *TxnPrepareRequest

+ RemoveMetadata *TxnRemoveMetadataRequest

+ RequestID uint64

+ RollbackDNShardRequest *TxnRollbackDNShardRequest

+ RollbackRequest *TxnRollbackRequest

+ TimeoutAt int64

+ Txn TxnMeta

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewTxnRequest(request *CNOpRequest) TxnRequest

+ func (*TxnRequest) Descriptor() ([]byte, []int)

+ func (*TxnRequest) ProtoMessage()

+ func (m *TxnRequest) GetCNRequest() *CNOpRequest

+ func (m *TxnRequest) GetCommitDNShardRequest() *TxnCommitDNShardRequest

+ func (m *TxnRequest) GetCommitRequest() *TxnCommitRequest

+ func (m *TxnRequest) GetFlag() uint32

+ func (m *TxnRequest) GetGetStatusRequest() *TxnGetStatusRequest

+ func (m *TxnRequest) GetID() uint64

+ func (m *TxnRequest) GetMethod() TxnMethod

+ func (m *TxnRequest) GetPrepareRequest() *TxnPrepareRequest

+ func (m *TxnRequest) GetRemoveMetadata() *TxnRemoveMetadataRequest

+ func (m *TxnRequest) GetRequestID() uint64

+ func (m *TxnRequest) GetRollbackDNShardRequest() *TxnRollbackDNShardRequest

+ func (m *TxnRequest) GetRollbackRequest() *TxnRollbackRequest

+ func (m *TxnRequest) GetTimeoutAt() int64

+ func (m *TxnRequest) GetTxn() TxnMeta

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

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

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

+ func (m *TxnRequest) Reset()

+ func (m *TxnRequest) SetID(id uint64)

+ func (m *TxnRequest) SetPayloadField(data []byte)

+ func (m *TxnRequest) Size() (n int)

+ func (m *TxnRequest) String() string

+ func (m *TxnRequest) Unmarshal(dAtA []byte) error

+ func (m *TxnRequest) XXX_DiscardUnknown()

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

+ func (m *TxnRequest) XXX_Merge(src proto.Message)

+ func (m *TxnRequest) XXX_Size() int

+ func (m *TxnRequest) XXX_Unmarshal(b []byte) error

+ func (m TxnRequest) DebugString() string

+ func (m TxnRequest) GetPayloadField() []byte

+ func (m TxnRequest) GetTargetDN() metadata.DNShard

+ type TxnResponse struct

+ CNOpResponse *CNOpResponse

+ CommitDNShardResponse *TxnCommitDNShardResponse

+ CommitResponse *TxnCommitResponse

+ Flag uint32

+ GetStatusResponse *TxnGetStatusResponse

+ Method TxnMethod

+ PrepareResponse *TxnPrepareResponse

+ RemoveMetadata *TxnRemoveMetadataResponse

+ RequestID uint64

+ RollbackDNShardResponse *TxnRollbackDNShardResponse

+ RollbackResponse *TxnRollbackResponse

+ Txn *TxnMeta

+ TxnError *TxnError

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnResponse) Descriptor() ([]byte, []int)

+ func (*TxnResponse) ProtoMessage()

+ func (m *TxnResponse) GetCNOpResponse() *CNOpResponse

+ func (m *TxnResponse) GetCommitDNShardResponse() *TxnCommitDNShardResponse

+ func (m *TxnResponse) GetCommitResponse() *TxnCommitResponse

+ func (m *TxnResponse) GetFlag() uint32

+ func (m *TxnResponse) GetGetStatusResponse() *TxnGetStatusResponse

+ func (m *TxnResponse) GetID() uint64

+ func (m *TxnResponse) GetMethod() TxnMethod

+ func (m *TxnResponse) GetPrepareResponse() *TxnPrepareResponse

+ func (m *TxnResponse) GetRemoveMetadata() *TxnRemoveMetadataResponse

+ func (m *TxnResponse) GetRequestID() uint64

+ func (m *TxnResponse) GetRollbackDNShardResponse() *TxnRollbackDNShardResponse

+ func (m *TxnResponse) GetRollbackResponse() *TxnRollbackResponse

+ func (m *TxnResponse) GetTxn() *TxnMeta

+ func (m *TxnResponse) GetTxnError() *TxnError

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

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

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

+ func (m *TxnResponse) Reset()

+ func (m *TxnResponse) SetID(id uint64)

+ func (m *TxnResponse) Size() (n int)

+ func (m *TxnResponse) String() string

+ func (m *TxnResponse) Unmarshal(dAtA []byte) error

+ func (m *TxnResponse) XXX_DiscardUnknown()

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

+ func (m *TxnResponse) XXX_Merge(src proto.Message)

+ func (m *TxnResponse) XXX_Size() int

+ func (m *TxnResponse) XXX_Unmarshal(b []byte) error

+ func (m TxnResponse) DebugString() string

+ func (m TxnResponse) HasFlag(flag uint32) bool

+ type TxnRollbackDNShardRequest struct

+ DNShard metadata.DNShard

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnRollbackDNShardRequest) Descriptor() ([]byte, []int)

+ func (*TxnRollbackDNShardRequest) ProtoMessage()

+ func (m *TxnRollbackDNShardRequest) GetDNShard() metadata.DNShard

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

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

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

+ func (m *TxnRollbackDNShardRequest) Reset()

+ func (m *TxnRollbackDNShardRequest) Size() (n int)

+ func (m *TxnRollbackDNShardRequest) String() string

+ func (m *TxnRollbackDNShardRequest) Unmarshal(dAtA []byte) error

+ func (m *TxnRollbackDNShardRequest) XXX_DiscardUnknown()

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

+ func (m *TxnRollbackDNShardRequest) XXX_Merge(src proto.Message)

+ func (m *TxnRollbackDNShardRequest) XXX_Size() int

+ func (m *TxnRollbackDNShardRequest) XXX_Unmarshal(b []byte) error

+ type TxnRollbackDNShardResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnRollbackDNShardResponse) Descriptor() ([]byte, []int)

+ func (*TxnRollbackDNShardResponse) ProtoMessage()

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

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

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

+ func (m *TxnRollbackDNShardResponse) Reset()

+ func (m *TxnRollbackDNShardResponse) Size() (n int)

+ func (m *TxnRollbackDNShardResponse) String() string

+ func (m *TxnRollbackDNShardResponse) Unmarshal(dAtA []byte) error

+ func (m *TxnRollbackDNShardResponse) XXX_DiscardUnknown()

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

+ func (m *TxnRollbackDNShardResponse) XXX_Merge(src proto.Message)

+ func (m *TxnRollbackDNShardResponse) XXX_Size() int

+ func (m *TxnRollbackDNShardResponse) XXX_Unmarshal(b []byte) error

+ type TxnRollbackRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnRollbackRequest) Descriptor() ([]byte, []int)

+ func (*TxnRollbackRequest) ProtoMessage()

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

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

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

+ func (m *TxnRollbackRequest) Reset()

+ func (m *TxnRollbackRequest) Size() (n int)

+ func (m *TxnRollbackRequest) String() string

+ func (m *TxnRollbackRequest) Unmarshal(dAtA []byte) error

+ func (m *TxnRollbackRequest) XXX_DiscardUnknown()

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

+ func (m *TxnRollbackRequest) XXX_Merge(src proto.Message)

+ func (m *TxnRollbackRequest) XXX_Size() int

+ func (m *TxnRollbackRequest) XXX_Unmarshal(b []byte) error

+ type TxnRollbackResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TxnRollbackResponse) Descriptor() ([]byte, []int)

+ func (*TxnRollbackResponse) ProtoMessage()

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

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

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

+ func (m *TxnRollbackResponse) Reset()

+ func (m *TxnRollbackResponse) Size() (n int)

+ func (m *TxnRollbackResponse) String() string

+ func (m *TxnRollbackResponse) Unmarshal(dAtA []byte) error

+ func (m *TxnRollbackResponse) XXX_DiscardUnknown()

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

+ func (m *TxnRollbackResponse) XXX_Merge(src proto.Message)

+ func (m *TxnRollbackResponse) XXX_Size() int

+ func (m *TxnRollbackResponse) XXX_Unmarshal(b []byte) error

+ type TxnStatus int32

+ const TxnStatus_Aborted

+ const TxnStatus_Aborting

+ const TxnStatus_Active

+ const TxnStatus_Committed

+ const TxnStatus_Committing

+ const TxnStatus_Prepared

+ func (TxnStatus) EnumDescriptor() ([]byte, []int)

+ func (x TxnStatus) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL