Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ChangeDataRequest_KvAPI_name = map[int32]string + var ChangeDataRequest_KvAPI_value = map[string]int32 + var ErrIntOverflowCdcpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthCdcpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupCdcpb = fmt.Errorf("proto: unexpected end of group") + var Event_LogType_name = map[int32]string + var Event_LogType_value = map[string]int32 + var Event_Row_OpType_name = map[int32]string + var Event_Row_OpType_value = map[string]int32 + func RegisterChangeDataServer(s *grpc.Server, srv ChangeDataServer) + type ChangeDataClient interface + EventFeed func(ctx context.Context, opts ...grpc.CallOption) (ChangeData_EventFeedClient, error) + func NewChangeDataClient(cc *grpc.ClientConn) ChangeDataClient + type ChangeDataEvent struct + Events []*Event + ResolvedTs *ResolvedTs + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangeDataEvent) Descriptor() ([]byte, []int) + func (*ChangeDataEvent) ProtoMessage() + func (m *ChangeDataEvent) GetEvents() []*Event + func (m *ChangeDataEvent) GetResolvedTs() *ResolvedTs + func (m *ChangeDataEvent) Marshal() (dAtA []byte, err error) + func (m *ChangeDataEvent) MarshalTo(dAtA []byte) (int, error) + func (m *ChangeDataEvent) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangeDataEvent) Reset() + func (m *ChangeDataEvent) Size() (n int) + func (m *ChangeDataEvent) String() string + func (m *ChangeDataEvent) Unmarshal(dAtA []byte) error + func (m *ChangeDataEvent) XXX_DiscardUnknown() + func (m *ChangeDataEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangeDataEvent) XXX_Merge(src proto.Message) + func (m *ChangeDataEvent) XXX_Size() int + func (m *ChangeDataEvent) XXX_Unmarshal(b []byte) error + type ChangeDataRequest struct + CheckpointTs uint64 + EndKey []byte + ExtraOp kvrpcpb.ExtraOp + FilterLoop bool + Header *Header + KvApi ChangeDataRequest_KvAPI + RegionEpoch *metapb.RegionEpoch + RegionId uint64 + Request isChangeDataRequest_Request + RequestId uint64 + StartKey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangeDataRequest) Descriptor() ([]byte, []int) + func (*ChangeDataRequest) ProtoMessage() + func (*ChangeDataRequest) XXX_OneofWrappers() []interface{} + func (m *ChangeDataRequest) GetCheckpointTs() uint64 + func (m *ChangeDataRequest) GetEndKey() []byte + func (m *ChangeDataRequest) GetExtraOp() kvrpcpb.ExtraOp + func (m *ChangeDataRequest) GetFilterLoop() bool + func (m *ChangeDataRequest) GetHeader() *Header + func (m *ChangeDataRequest) GetKvApi() ChangeDataRequest_KvAPI + func (m *ChangeDataRequest) GetNotifyTxnStatus() *ChangeDataRequest_NotifyTxnStatus + func (m *ChangeDataRequest) GetRegionEpoch() *metapb.RegionEpoch + func (m *ChangeDataRequest) GetRegionId() uint64 + func (m *ChangeDataRequest) GetRegister() *ChangeDataRequest_Register + func (m *ChangeDataRequest) GetRequest() isChangeDataRequest_Request + func (m *ChangeDataRequest) GetRequestId() uint64 + func (m *ChangeDataRequest) GetStartKey() []byte + func (m *ChangeDataRequest) Marshal() (dAtA []byte, err error) + func (m *ChangeDataRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ChangeDataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangeDataRequest) Reset() + func (m *ChangeDataRequest) Size() (n int) + func (m *ChangeDataRequest) String() string + func (m *ChangeDataRequest) Unmarshal(dAtA []byte) error + func (m *ChangeDataRequest) XXX_DiscardUnknown() + func (m *ChangeDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangeDataRequest) XXX_Merge(src proto.Message) + func (m *ChangeDataRequest) XXX_Size() int + func (m *ChangeDataRequest) XXX_Unmarshal(b []byte) error + type ChangeDataRequest_KvAPI int32 + const ChangeDataRequest_RawKV + const ChangeDataRequest_TiDB + const ChangeDataRequest_TxnKV + func (ChangeDataRequest_KvAPI) EnumDescriptor() ([]byte, []int) + func (x ChangeDataRequest_KvAPI) String() string + type ChangeDataRequest_NotifyTxnStatus struct + TxnStatus []*TxnStatus + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangeDataRequest_NotifyTxnStatus) Descriptor() ([]byte, []int) + func (*ChangeDataRequest_NotifyTxnStatus) ProtoMessage() + func (m *ChangeDataRequest_NotifyTxnStatus) GetTxnStatus() []*TxnStatus + func (m *ChangeDataRequest_NotifyTxnStatus) Marshal() (dAtA []byte, err error) + func (m *ChangeDataRequest_NotifyTxnStatus) MarshalTo(dAtA []byte) (int, error) + func (m *ChangeDataRequest_NotifyTxnStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangeDataRequest_NotifyTxnStatus) Reset() + func (m *ChangeDataRequest_NotifyTxnStatus) Size() (n int) + func (m *ChangeDataRequest_NotifyTxnStatus) String() string + func (m *ChangeDataRequest_NotifyTxnStatus) Unmarshal(dAtA []byte) error + func (m *ChangeDataRequest_NotifyTxnStatus) XXX_DiscardUnknown() + func (m *ChangeDataRequest_NotifyTxnStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangeDataRequest_NotifyTxnStatus) XXX_Merge(src proto.Message) + func (m *ChangeDataRequest_NotifyTxnStatus) XXX_Size() int + func (m *ChangeDataRequest_NotifyTxnStatus) XXX_Unmarshal(b []byte) error + type ChangeDataRequest_NotifyTxnStatus_ struct + NotifyTxnStatus *ChangeDataRequest_NotifyTxnStatus + func (m *ChangeDataRequest_NotifyTxnStatus_) MarshalTo(dAtA []byte) (int, error) + func (m *ChangeDataRequest_NotifyTxnStatus_) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangeDataRequest_NotifyTxnStatus_) Size() (n int) + type ChangeDataRequest_Register struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangeDataRequest_Register) Descriptor() ([]byte, []int) + func (*ChangeDataRequest_Register) ProtoMessage() + func (m *ChangeDataRequest_Register) Marshal() (dAtA []byte, err error) + func (m *ChangeDataRequest_Register) MarshalTo(dAtA []byte) (int, error) + func (m *ChangeDataRequest_Register) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangeDataRequest_Register) Reset() + func (m *ChangeDataRequest_Register) Size() (n int) + func (m *ChangeDataRequest_Register) String() string + func (m *ChangeDataRequest_Register) Unmarshal(dAtA []byte) error + func (m *ChangeDataRequest_Register) XXX_DiscardUnknown() + func (m *ChangeDataRequest_Register) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangeDataRequest_Register) XXX_Merge(src proto.Message) + func (m *ChangeDataRequest_Register) XXX_Size() int + func (m *ChangeDataRequest_Register) XXX_Unmarshal(b []byte) error + type ChangeDataRequest_Register_ struct + Register *ChangeDataRequest_Register + func (m *ChangeDataRequest_Register_) MarshalTo(dAtA []byte) (int, error) + func (m *ChangeDataRequest_Register_) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangeDataRequest_Register_) Size() (n int) + type ChangeDataServer interface + EventFeed func(ChangeData_EventFeedServer) error + type ChangeData_EventFeedClient interface + Recv func() (*ChangeDataEvent, error) + Send func(*ChangeDataRequest) error + type ChangeData_EventFeedServer interface + Recv func() (*ChangeDataRequest, error) + Send func(*ChangeDataEvent) error + type ClusterIDMismatch struct + Current uint64 + Request uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClusterIDMismatch) Descriptor() ([]byte, []int) + func (*ClusterIDMismatch) ProtoMessage() + func (m *ClusterIDMismatch) GetCurrent() uint64 + func (m *ClusterIDMismatch) GetRequest() uint64 + func (m *ClusterIDMismatch) Marshal() (dAtA []byte, err error) + func (m *ClusterIDMismatch) MarshalTo(dAtA []byte) (int, error) + func (m *ClusterIDMismatch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ClusterIDMismatch) Reset() + func (m *ClusterIDMismatch) Size() (n int) + func (m *ClusterIDMismatch) String() string + func (m *ClusterIDMismatch) Unmarshal(dAtA []byte) error + func (m *ClusterIDMismatch) XXX_DiscardUnknown() + func (m *ClusterIDMismatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClusterIDMismatch) XXX_Merge(src proto.Message) + func (m *ClusterIDMismatch) XXX_Size() int + func (m *ClusterIDMismatch) XXX_Unmarshal(b []byte) error + type Compatibility struct + RequiredVersion string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Compatibility) Descriptor() ([]byte, []int) + func (*Compatibility) ProtoMessage() + func (m *Compatibility) GetRequiredVersion() string + func (m *Compatibility) Marshal() (dAtA []byte, err error) + func (m *Compatibility) MarshalTo(dAtA []byte) (int, error) + func (m *Compatibility) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Compatibility) Reset() + func (m *Compatibility) Size() (n int) + func (m *Compatibility) String() string + func (m *Compatibility) Unmarshal(dAtA []byte) error + func (m *Compatibility) XXX_DiscardUnknown() + func (m *Compatibility) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Compatibility) XXX_Merge(src proto.Message) + func (m *Compatibility) XXX_Size() int + func (m *Compatibility) XXX_Unmarshal(b []byte) error + type DuplicateRequest struct + RegionId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DuplicateRequest) Descriptor() ([]byte, []int) + func (*DuplicateRequest) ProtoMessage() + func (m *DuplicateRequest) GetRegionId() uint64 + func (m *DuplicateRequest) Marshal() (dAtA []byte, err error) + func (m *DuplicateRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DuplicateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DuplicateRequest) Reset() + func (m *DuplicateRequest) Size() (n int) + func (m *DuplicateRequest) String() string + func (m *DuplicateRequest) Unmarshal(dAtA []byte) error + func (m *DuplicateRequest) XXX_DiscardUnknown() + func (m *DuplicateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DuplicateRequest) XXX_Merge(src proto.Message) + func (m *DuplicateRequest) XXX_Size() int + func (m *DuplicateRequest) XXX_Unmarshal(b []byte) error + type Error struct + ClusterIdMismatch *ClusterIDMismatch + Compatibility *Compatibility + DuplicateRequest *DuplicateRequest + EpochNotMatch *errorpb.EpochNotMatch + NotLeader *errorpb.NotLeader + RegionNotFound *errorpb.RegionNotFound + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetClusterIdMismatch() *ClusterIDMismatch + func (m *Error) GetCompatibility() *Compatibility + func (m *Error) GetDuplicateRequest() *DuplicateRequest + func (m *Error) GetEpochNotMatch() *errorpb.EpochNotMatch + func (m *Error) GetNotLeader() *errorpb.NotLeader + func (m *Error) GetRegionNotFound() *errorpb.RegionNotFound + func (m *Error) Marshal() (dAtA []byte, err error) + func (m *Error) MarshalTo(dAtA []byte) (int, error) + func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error) Reset() + func (m *Error) Size() (n int) + func (m *Error) String() string + func (m *Error) Unmarshal(dAtA []byte) error + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Merge(src proto.Message) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type Event struct + Event isEvent_Event + Index uint64 + RegionId uint64 + RequestId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (*Event) XXX_OneofWrappers() []interface{} + func (m *Event) GetAdmin() *Event_Admin + func (m *Event) GetEntries() *Event_Entries + func (m *Event) GetError() *Error + func (m *Event) GetEvent() isEvent_Event + func (m *Event) GetIndex() uint64 + func (m *Event) GetLongTxn() *Event_LongTxn + func (m *Event) GetRegionId() uint64 + func (m *Event) GetRequestId() uint64 + func (m *Event) GetResolvedTs() uint64 + func (m *Event) Marshal() (dAtA []byte, err error) + func (m *Event) MarshalTo(dAtA []byte) (int, error) + func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event) Reset() + func (m *Event) Size() (n int) + func (m *Event) String() string + func (m *Event) Unmarshal(dAtA []byte) error + func (m *Event) XXX_DiscardUnknown() + func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event) XXX_Merge(src proto.Message) + func (m *Event) XXX_Size() int + func (m *Event) XXX_Unmarshal(b []byte) error + type Event_Admin struct + AdminRequest *raft_cmdpb.AdminRequest + AdminResponse *raft_cmdpb.AdminResponse + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Event_Admin) Descriptor() ([]byte, []int) + func (*Event_Admin) ProtoMessage() + func (m *Event_Admin) GetAdminRequest() *raft_cmdpb.AdminRequest + func (m *Event_Admin) GetAdminResponse() *raft_cmdpb.AdminResponse + func (m *Event_Admin) Marshal() (dAtA []byte, err error) + func (m *Event_Admin) MarshalTo(dAtA []byte) (int, error) + func (m *Event_Admin) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event_Admin) Reset() + func (m *Event_Admin) Size() (n int) + func (m *Event_Admin) String() string + func (m *Event_Admin) Unmarshal(dAtA []byte) error + func (m *Event_Admin) XXX_DiscardUnknown() + func (m *Event_Admin) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event_Admin) XXX_Merge(src proto.Message) + func (m *Event_Admin) XXX_Size() int + func (m *Event_Admin) XXX_Unmarshal(b []byte) error + type Event_Admin_ struct + Admin *Event_Admin + func (m *Event_Admin_) MarshalTo(dAtA []byte) (int, error) + func (m *Event_Admin_) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event_Admin_) Size() (n int) + type Event_Entries struct + Entries []*Event_Row + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Event_Entries) Descriptor() ([]byte, []int) + func (*Event_Entries) ProtoMessage() + func (m *Event_Entries) GetEntries() []*Event_Row + func (m *Event_Entries) Marshal() (dAtA []byte, err error) + func (m *Event_Entries) MarshalTo(dAtA []byte) (int, error) + func (m *Event_Entries) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event_Entries) Reset() + func (m *Event_Entries) Size() (n int) + func (m *Event_Entries) String() string + func (m *Event_Entries) Unmarshal(dAtA []byte) error + func (m *Event_Entries) XXX_DiscardUnknown() + func (m *Event_Entries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event_Entries) XXX_Merge(src proto.Message) + func (m *Event_Entries) XXX_Size() int + func (m *Event_Entries) XXX_Unmarshal(b []byte) error + type Event_Entries_ struct + Entries *Event_Entries + func (m *Event_Entries_) MarshalTo(dAtA []byte) (int, error) + func (m *Event_Entries_) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event_Entries_) Size() (n int) + type Event_Error struct + Error *Error + func (m *Event_Error) MarshalTo(dAtA []byte) (int, error) + func (m *Event_Error) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event_Error) Size() (n int) + type Event_LogType int32 + const Event_COMMIT + const Event_COMMITTED + const Event_INITIALIZED + const Event_PREWRITE + const Event_ROLLBACK + const Event_UNKNOWN + func (Event_LogType) EnumDescriptor() ([]byte, []int) + func (x Event_LogType) String() string + type Event_LongTxn struct + TxnInfo []*TxnInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Event_LongTxn) Descriptor() ([]byte, []int) + func (*Event_LongTxn) ProtoMessage() + func (m *Event_LongTxn) GetTxnInfo() []*TxnInfo + func (m *Event_LongTxn) Marshal() (dAtA []byte, err error) + func (m *Event_LongTxn) MarshalTo(dAtA []byte) (int, error) + func (m *Event_LongTxn) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event_LongTxn) Reset() + func (m *Event_LongTxn) Size() (n int) + func (m *Event_LongTxn) String() string + func (m *Event_LongTxn) Unmarshal(dAtA []byte) error + func (m *Event_LongTxn) XXX_DiscardUnknown() + func (m *Event_LongTxn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event_LongTxn) XXX_Merge(src proto.Message) + func (m *Event_LongTxn) XXX_Size() int + func (m *Event_LongTxn) XXX_Unmarshal(b []byte) error + type Event_LongTxn_ struct + LongTxn *Event_LongTxn + func (m *Event_LongTxn_) MarshalTo(dAtA []byte) (int, error) + func (m *Event_LongTxn_) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event_LongTxn_) Size() (n int) + type Event_ResolvedTs struct + ResolvedTs uint64 + func (m *Event_ResolvedTs) MarshalTo(dAtA []byte) (int, error) + func (m *Event_ResolvedTs) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event_ResolvedTs) Size() (n int) + type Event_Row struct + CommitTs uint64 + ExpireTsUnixSecs uint64 + Key []byte + OldValue []byte + OpType Event_Row_OpType + StartTs uint64 + TxnSource uint64 + Type Event_LogType + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Event_Row) Descriptor() ([]byte, []int) + func (*Event_Row) ProtoMessage() + func (m *Event_Row) GetCommitTs() uint64 + func (m *Event_Row) GetExpireTsUnixSecs() uint64 + func (m *Event_Row) GetKey() []byte + func (m *Event_Row) GetOldValue() []byte + func (m *Event_Row) GetOpType() Event_Row_OpType + func (m *Event_Row) GetStartTs() uint64 + func (m *Event_Row) GetTxnSource() uint64 + func (m *Event_Row) GetType() Event_LogType + func (m *Event_Row) GetValue() []byte + func (m *Event_Row) Marshal() (dAtA []byte, err error) + func (m *Event_Row) MarshalTo(dAtA []byte) (int, error) + func (m *Event_Row) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event_Row) Reset() + func (m *Event_Row) Size() (n int) + func (m *Event_Row) String() string + func (m *Event_Row) Unmarshal(dAtA []byte) error + func (m *Event_Row) XXX_DiscardUnknown() + func (m *Event_Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event_Row) XXX_Merge(src proto.Message) + func (m *Event_Row) XXX_Size() int + func (m *Event_Row) XXX_Unmarshal(b []byte) error + type Event_Row_OpType int32 + const Event_Row_DELETE + const Event_Row_PUT + const Event_Row_UNKNOWN + func (Event_Row_OpType) EnumDescriptor() ([]byte, []int) + func (x Event_Row_OpType) String() string + type Header struct + ClusterId uint64 + TicdcVersion string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Header) Descriptor() ([]byte, []int) + func (*Header) ProtoMessage() + func (m *Header) GetClusterId() uint64 + func (m *Header) GetTicdcVersion() string + func (m *Header) Marshal() (dAtA []byte, err error) + func (m *Header) MarshalTo(dAtA []byte) (int, error) + func (m *Header) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Header) Reset() + func (m *Header) Size() (n int) + func (m *Header) String() string + func (m *Header) Unmarshal(dAtA []byte) error + func (m *Header) XXX_DiscardUnknown() + func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Header) XXX_Merge(src proto.Message) + func (m *Header) XXX_Size() int + func (m *Header) XXX_Unmarshal(b []byte) error + type ResolvedTs struct + Regions []uint64 + Ts uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResolvedTs) Descriptor() ([]byte, []int) + func (*ResolvedTs) ProtoMessage() + func (m *ResolvedTs) GetRegions() []uint64 + func (m *ResolvedTs) GetTs() uint64 + func (m *ResolvedTs) Marshal() (dAtA []byte, err error) + func (m *ResolvedTs) MarshalTo(dAtA []byte) (int, error) + func (m *ResolvedTs) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResolvedTs) Reset() + func (m *ResolvedTs) Size() (n int) + func (m *ResolvedTs) String() string + func (m *ResolvedTs) Unmarshal(dAtA []byte) error + func (m *ResolvedTs) XXX_DiscardUnknown() + func (m *ResolvedTs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResolvedTs) XXX_Merge(src proto.Message) + func (m *ResolvedTs) XXX_Size() int + func (m *ResolvedTs) XXX_Unmarshal(b []byte) error + type TxnInfo struct + Primary []byte + StartTs uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TxnInfo) Descriptor() ([]byte, []int) + func (*TxnInfo) ProtoMessage() + func (m *TxnInfo) GetPrimary() []byte + func (m *TxnInfo) GetStartTs() uint64 + func (m *TxnInfo) Marshal() (dAtA []byte, err error) + func (m *TxnInfo) MarshalTo(dAtA []byte) (int, error) + func (m *TxnInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxnInfo) Reset() + func (m *TxnInfo) Size() (n int) + func (m *TxnInfo) String() string + func (m *TxnInfo) Unmarshal(dAtA []byte) error + func (m *TxnInfo) XXX_DiscardUnknown() + func (m *TxnInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxnInfo) XXX_Merge(src proto.Message) + func (m *TxnInfo) XXX_Size() int + func (m *TxnInfo) XXX_Unmarshal(b []byte) error + type TxnStatus struct + CommitTs uint64 + IsRolledBack bool + MinCommitTs uint64 + StartTs uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TxnStatus) Descriptor() ([]byte, []int) + func (*TxnStatus) ProtoMessage() + func (m *TxnStatus) GetCommitTs() uint64 + func (m *TxnStatus) GetIsRolledBack() bool + func (m *TxnStatus) GetMinCommitTs() uint64 + func (m *TxnStatus) GetStartTs() uint64 + func (m *TxnStatus) Marshal() (dAtA []byte, err error) + func (m *TxnStatus) MarshalTo(dAtA []byte) (int, error) + func (m *TxnStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxnStatus) Reset() + func (m *TxnStatus) Size() (n int) + func (m *TxnStatus) String() string + func (m *TxnStatus) Unmarshal(dAtA []byte) error + func (m *TxnStatus) XXX_DiscardUnknown() + func (m *TxnStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxnStatus) XXX_Merge(src proto.Message) + func (m *TxnStatus) XXX_Size() int + func (m *TxnStatus) XXX_Unmarshal(b []byte) error + type UnimplementedChangeDataServer struct + func (*UnimplementedChangeDataServer) EventFeed(srv ChangeData_EventFeedServer) error