cdcpb

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCdcpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCdcpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCdcpb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ChangeDataRequest_KvAPI_name = map[int32]string{
	0: "TiDB",
	1: "RawKV",
	2: "TxnKV",
}
View Source 
var ChangeDataRequest_KvAPI_value = map[string]int32{
	"TiDB":  0,
	"RawKV": 1,
	"TxnKV": 2,
}
View Source 
var Event_LogType_name = map[int32]string{
	0: "UNKNOWN",
	1: "PREWRITE",
	2: "COMMIT",
	3: "ROLLBACK",
	4: "COMMITTED",
	5: "INITIALIZED",
}
View Source 
var Event_LogType_value = map[string]int32{
	"UNKNOWN":     0,
	"PREWRITE":    1,
	"COMMIT":      2,
	"ROLLBACK":    3,
	"COMMITTED":   4,
	"INITIALIZED": 5,
}
View Source 
var Event_Row_OpType_name = map[int32]string{
	0: "UNKNOWN",
	1: "PUT",
	2: "DELETE",
}
View Source 
var Event_Row_OpType_value = map[string]int32{
	"UNKNOWN": 0,
	"PUT":     1,
	"DELETE":  2,
}

Functions

func RegisterChangeDataServer 

func RegisterChangeDataServer(s *grpc.Server, srv ChangeDataServer)

Types

type ChangeDataClient 

type ChangeDataClient interface {
	EventFeed(ctx context.Context, opts ...grpc.CallOption) (ChangeData_EventFeedClient, error)
}

ChangeDataClient is the client API for ChangeData service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewChangeDataClient 

func NewChangeDataClient(cc *grpc.ClientConn) ChangeDataClient

type ChangeDataEvent 

type ChangeDataEvent struct {
	Events               []*Event    `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	ResolvedTs           *ResolvedTs `protobuf:"bytes,2,opt,name=resolved_ts,json=resolvedTs,proto3" json:"resolved_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ChangeDataEvent) Descriptor 

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

func (*ChangeDataEvent) GetEvents 

func (m *ChangeDataEvent) GetEvents() []*Event

func (*ChangeDataEvent) GetResolvedTs 

func (m *ChangeDataEvent) GetResolvedTs() *ResolvedTs

func (*ChangeDataEvent) Marshal 

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

func (*ChangeDataEvent) MarshalTo 

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

func (*ChangeDataEvent) MarshalToSizedBuffer 

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

func (*ChangeDataEvent) ProtoMessage 

func (*ChangeDataEvent) ProtoMessage()

func (*ChangeDataEvent) Reset 

func (m *ChangeDataEvent) Reset()

func (*ChangeDataEvent) Size 

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

func (*ChangeDataEvent) String 

func (m *ChangeDataEvent) String() string

func (*ChangeDataEvent) Unmarshal 

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

func (*ChangeDataEvent) XXX_DiscardUnknown 

func (m *ChangeDataEvent) XXX_DiscardUnknown()

func (*ChangeDataEvent) XXX_Marshal 

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

func (*ChangeDataEvent) XXX_Merge 

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

func (*ChangeDataEvent) XXX_Size 

func (m *ChangeDataEvent) XXX_Size() int

func (*ChangeDataEvent) XXX_Unmarshal 

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

type ChangeDataRequest 

type ChangeDataRequest struct {
	Header       *Header             `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RegionId     uint64              `protobuf:"varint,2,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	RegionEpoch  *metapb.RegionEpoch `protobuf:"bytes,3,opt,name=region_epoch,json=regionEpoch,proto3" json:"region_epoch,omitempty"`
	CheckpointTs uint64              `protobuf:"varint,4,opt,name=checkpoint_ts,json=checkpointTs,proto3" json:"checkpoint_ts,omitempty"`
	StartKey     []byte              `protobuf:"bytes,5,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey       []byte              `protobuf:"bytes,6,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	// Used for CDC to identify events corresponding to different requests.
	RequestId uint64          `protobuf:"varint,7,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ExtraOp   kvrpcpb.ExtraOp `protobuf:"varint,8,opt,name=extra_op,json=extraOp,proto3,enum=kvrpcpb.ExtraOp" json:"extra_op,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*ChangeDataRequest_Register_
	//	*ChangeDataRequest_NotifyTxnStatus_
	Request isChangeDataRequest_Request `protobuf_oneof:"request"`
	KvApi   ChangeDataRequest_KvAPI     `protobuf:"varint,11,opt,name=kv_api,json=kvApi,proto3,enum=cdcpb.ChangeDataRequest_KvAPI" json:"kv_api,omitempty"`
	// Whether to filter out the value write by cdc itself.
	FilterLoop           bool     `protobuf:"varint,12,opt,name=filter_loop,json=filterLoop,proto3" json:"filter_loop,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChangeDataRequest) Descriptor 

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

func (*ChangeDataRequest) GetCheckpointTs 

func (m *ChangeDataRequest) GetCheckpointTs() uint64

func (*ChangeDataRequest) GetEndKey 

func (m *ChangeDataRequest) GetEndKey() []byte

func (*ChangeDataRequest) GetExtraOp 

func (m *ChangeDataRequest) GetExtraOp() kvrpcpb.ExtraOp

func (*ChangeDataRequest) GetFilterLoop 

func (m *ChangeDataRequest) GetFilterLoop() bool

func (*ChangeDataRequest) GetHeader 

func (m *ChangeDataRequest) GetHeader() *Header

func (*ChangeDataRequest) GetKvApi 

func (m *ChangeDataRequest) GetKvApi() ChangeDataRequest_KvAPI

func (*ChangeDataRequest) GetNotifyTxnStatus 

func (m *ChangeDataRequest) GetNotifyTxnStatus() *ChangeDataRequest_NotifyTxnStatus

func (*ChangeDataRequest) GetRegionEpoch 

func (m *ChangeDataRequest) GetRegionEpoch() *metapb.RegionEpoch

func (*ChangeDataRequest) GetRegionId 

func (m *ChangeDataRequest) GetRegionId() uint64

func (*ChangeDataRequest) GetRegister 

func (m *ChangeDataRequest) GetRegister() *ChangeDataRequest_Register

func (*ChangeDataRequest) GetRequest 

func (m *ChangeDataRequest) GetRequest() isChangeDataRequest_Request

func (*ChangeDataRequest) GetRequestId 

func (m *ChangeDataRequest) GetRequestId() uint64

func (*ChangeDataRequest) GetStartKey 

func (m *ChangeDataRequest) GetStartKey() []byte

func (*ChangeDataRequest) Marshal 

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

func (*ChangeDataRequest) MarshalTo 

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

func (*ChangeDataRequest) MarshalToSizedBuffer 

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

func (*ChangeDataRequest) ProtoMessage 

func (*ChangeDataRequest) ProtoMessage()

func (*ChangeDataRequest) Reset 

func (m *ChangeDataRequest) Reset()

func (*ChangeDataRequest) Size 

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

func (*ChangeDataRequest) String 

func (m *ChangeDataRequest) String() string

func (*ChangeDataRequest) Unmarshal 

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

func (*ChangeDataRequest) XXX_DiscardUnknown 

func (m *ChangeDataRequest) XXX_DiscardUnknown()

func (*ChangeDataRequest) XXX_Marshal 

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

func (*ChangeDataRequest) XXX_Merge 

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

func (*ChangeDataRequest) XXX_OneofWrappers 

func (*ChangeDataRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ChangeDataRequest) XXX_Size 

func (m *ChangeDataRequest) XXX_Size() int

func (*ChangeDataRequest) XXX_Unmarshal 

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

type ChangeDataRequest_KvAPI 

type ChangeDataRequest_KvAPI int32

KvAPI specifies to capture data written by different KV API. See more details in https://github.com/tikv/rfcs/blob/master/text/0069-api-v2.md. 

const (
	ChangeDataRequest_TiDB  ChangeDataRequest_KvAPI = 0
	ChangeDataRequest_RawKV ChangeDataRequest_KvAPI = 1
	ChangeDataRequest_TxnKV ChangeDataRequest_KvAPI = 2
)

func (ChangeDataRequest_KvAPI) EnumDescriptor 

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

func (ChangeDataRequest_KvAPI) String 

func (x ChangeDataRequest_KvAPI) String() string

type ChangeDataRequest_NotifyTxnStatus 

type ChangeDataRequest_NotifyTxnStatus struct {
	TxnStatus            []*TxnStatus `protobuf:"bytes,1,rep,name=txn_status,json=txnStatus,proto3" json:"txn_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ChangeDataRequest_NotifyTxnStatus) Descriptor 

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

func (*ChangeDataRequest_NotifyTxnStatus) GetTxnStatus 

func (m *ChangeDataRequest_NotifyTxnStatus) GetTxnStatus() []*TxnStatus

func (*ChangeDataRequest_NotifyTxnStatus) Marshal 

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

func (*ChangeDataRequest_NotifyTxnStatus) MarshalTo 

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

func (*ChangeDataRequest_NotifyTxnStatus) MarshalToSizedBuffer 

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

func (*ChangeDataRequest_NotifyTxnStatus) ProtoMessage 

func (*ChangeDataRequest_NotifyTxnStatus) ProtoMessage()

func (*ChangeDataRequest_NotifyTxnStatus) Reset 

func (m *ChangeDataRequest_NotifyTxnStatus) Reset()

func (*ChangeDataRequest_NotifyTxnStatus) Size 

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

func (*ChangeDataRequest_NotifyTxnStatus) String 

func (m *ChangeDataRequest_NotifyTxnStatus) String() string

func (*ChangeDataRequest_NotifyTxnStatus) Unmarshal 

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

func (*ChangeDataRequest_NotifyTxnStatus) XXX_DiscardUnknown 

func (m *ChangeDataRequest_NotifyTxnStatus) XXX_DiscardUnknown()

func (*ChangeDataRequest_NotifyTxnStatus) XXX_Marshal 

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

func (*ChangeDataRequest_NotifyTxnStatus) XXX_Merge 

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

func (*ChangeDataRequest_NotifyTxnStatus) XXX_Size 

func (m *ChangeDataRequest_NotifyTxnStatus) XXX_Size() int

func (*ChangeDataRequest_NotifyTxnStatus) XXX_Unmarshal 

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

type ChangeDataRequest_NotifyTxnStatus_ 

type ChangeDataRequest_NotifyTxnStatus_ struct {
	NotifyTxnStatus *ChangeDataRequest_NotifyTxnStatus `protobuf:"bytes,10,opt,name=notify_txn_status,json=notifyTxnStatus,proto3,oneof" json:"notify_txn_status,omitempty"`
}

func (*ChangeDataRequest_NotifyTxnStatus_) MarshalTo 

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

func (*ChangeDataRequest_NotifyTxnStatus_) MarshalToSizedBuffer 

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

func (*ChangeDataRequest_NotifyTxnStatus_) Size 

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

type ChangeDataRequest_Register 

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

func (*ChangeDataRequest_Register) Descriptor 

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

func (*ChangeDataRequest_Register) Marshal 

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

func (*ChangeDataRequest_Register) MarshalTo 

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

func (*ChangeDataRequest_Register) MarshalToSizedBuffer 

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

func (*ChangeDataRequest_Register) ProtoMessage 

func (*ChangeDataRequest_Register) ProtoMessage()

func (*ChangeDataRequest_Register) Reset 

func (m *ChangeDataRequest_Register) Reset()

func (*ChangeDataRequest_Register) Size 

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

func (*ChangeDataRequest_Register) String 

func (m *ChangeDataRequest_Register) String() string

func (*ChangeDataRequest_Register) Unmarshal 

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

func (*ChangeDataRequest_Register) XXX_DiscardUnknown 

func (m *ChangeDataRequest_Register) XXX_DiscardUnknown()

func (*ChangeDataRequest_Register) XXX_Marshal 

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

func (*ChangeDataRequest_Register) XXX_Merge 

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

func (*ChangeDataRequest_Register) XXX_Size 

func (m *ChangeDataRequest_Register) XXX_Size() int

func (*ChangeDataRequest_Register) XXX_Unmarshal 

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

type ChangeDataRequest_Register_ 

type ChangeDataRequest_Register_ struct {
	Register *ChangeDataRequest_Register `protobuf:"bytes,9,opt,name=register,proto3,oneof" json:"register,omitempty"`
}

func (*ChangeDataRequest_Register_) MarshalTo 

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

func (*ChangeDataRequest_Register_) MarshalToSizedBuffer 

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

func (*ChangeDataRequest_Register_) Size 

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

type ChangeDataServer 

type ChangeDataServer interface {
	EventFeed(ChangeData_EventFeedServer) error
}

ChangeDataServer is the server API for ChangeData service.

type ChangeData_EventFeedClient 

type ChangeData_EventFeedClient interface {
	Send(*ChangeDataRequest) error
	Recv() (*ChangeDataEvent, error)
	grpc.ClientStream
}

type ChangeData_EventFeedServer 

type ChangeData_EventFeedServer interface {
	Send(*ChangeDataEvent) error
	Recv() (*ChangeDataRequest, error)
	grpc.ServerStream
}

type ClusterIDMismatch 

type ClusterIDMismatch struct {
	// The current tikv cluster ID.
	Current uint64 `protobuf:"varint,1,opt,name=current,proto3" json:"current,omitempty"`
	// The cluster ID of the TiCDC request.
	Request              uint64   `protobuf:"varint,2,opt,name=request,proto3" json:"request,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ClusterIDMismatch is an error variable that tells people that the cluster ID of the request does not match the TiKV cluster ID.

func (*ClusterIDMismatch) Descriptor 

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

func (*ClusterIDMismatch) GetCurrent 

func (m *ClusterIDMismatch) GetCurrent() uint64

func (*ClusterIDMismatch) GetRequest 

func (m *ClusterIDMismatch) GetRequest() uint64

func (*ClusterIDMismatch) Marshal 

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

func (*ClusterIDMismatch) MarshalTo 

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

func (*ClusterIDMismatch) MarshalToSizedBuffer 

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

func (*ClusterIDMismatch) ProtoMessage 

func (*ClusterIDMismatch) ProtoMessage()

func (*ClusterIDMismatch) Reset 

func (m *ClusterIDMismatch) Reset()

func (*ClusterIDMismatch) Size 

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

func (*ClusterIDMismatch) String 

func (m *ClusterIDMismatch) String() string

func (*ClusterIDMismatch) Unmarshal 

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

func (*ClusterIDMismatch) XXX_DiscardUnknown 

func (m *ClusterIDMismatch) XXX_DiscardUnknown()

func (*ClusterIDMismatch) XXX_Marshal 

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

func (*ClusterIDMismatch) XXX_Merge 

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

func (*ClusterIDMismatch) XXX_Size 

func (m *ClusterIDMismatch) XXX_Size() int

func (*ClusterIDMismatch) XXX_Unmarshal 

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

type Compatibility 

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

func (*Compatibility) Descriptor 

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

func (*Compatibility) GetRequiredVersion 

func (m *Compatibility) GetRequiredVersion() string

func (*Compatibility) Marshal 

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

func (*Compatibility) MarshalTo 

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

func (*Compatibility) MarshalToSizedBuffer 

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

func (*Compatibility) ProtoMessage 

func (*Compatibility) ProtoMessage()

func (*Compatibility) Reset 

func (m *Compatibility) Reset()

func (*Compatibility) Size 

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

func (*Compatibility) String 

func (m *Compatibility) String() string

func (*Compatibility) Unmarshal 

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

func (*Compatibility) XXX_DiscardUnknown 

func (m *Compatibility) XXX_DiscardUnknown()

func (*Compatibility) XXX_Marshal 

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

func (*Compatibility) XXX_Merge 

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

func (*Compatibility) XXX_Size 

func (m *Compatibility) XXX_Size() int

func (*Compatibility) XXX_Unmarshal 

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

type DuplicateRequest 

type DuplicateRequest struct {
	RegionId             uint64   `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DuplicateRequest) Descriptor 

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

func (*DuplicateRequest) GetRegionId 

func (m *DuplicateRequest) GetRegionId() uint64

func (*DuplicateRequest) Marshal 

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

func (*DuplicateRequest) MarshalTo 

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

func (*DuplicateRequest) MarshalToSizedBuffer 

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

func (*DuplicateRequest) ProtoMessage 

func (*DuplicateRequest) ProtoMessage()

func (*DuplicateRequest) Reset 

func (m *DuplicateRequest) Reset()

func (*DuplicateRequest) Size 

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

func (*DuplicateRequest) String 

func (m *DuplicateRequest) String() string

func (*DuplicateRequest) Unmarshal 

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

func (*DuplicateRequest) XXX_DiscardUnknown 

func (m *DuplicateRequest) XXX_DiscardUnknown()

func (*DuplicateRequest) XXX_Marshal 

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

func (*DuplicateRequest) XXX_Merge 

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

func (*DuplicateRequest) XXX_Size 

func (m *DuplicateRequest) XXX_Size() int

func (*DuplicateRequest) XXX_Unmarshal 

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

type Error 

type Error struct {
	NotLeader            *errorpb.NotLeader      `protobuf:"bytes,1,opt,name=not_leader,json=notLeader,proto3" json:"not_leader,omitempty"`
	RegionNotFound       *errorpb.RegionNotFound `protobuf:"bytes,2,opt,name=region_not_found,json=regionNotFound,proto3" json:"region_not_found,omitempty"`
	EpochNotMatch        *errorpb.EpochNotMatch  `protobuf:"bytes,3,opt,name=epoch_not_match,json=epochNotMatch,proto3" json:"epoch_not_match,omitempty"`
	DuplicateRequest     *DuplicateRequest       `protobuf:"bytes,4,opt,name=duplicate_request,json=duplicateRequest,proto3" json:"duplicate_request,omitempty"`
	Compatibility        *Compatibility          `protobuf:"bytes,5,opt,name=compatibility,proto3" json:"compatibility,omitempty"`
	ClusterIdMismatch    *ClusterIDMismatch      `protobuf:"bytes,6,opt,name=cluster_id_mismatch,json=clusterIdMismatch,proto3" json:"cluster_id_mismatch,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*Error) Descriptor 

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

func (*Error) GetClusterIdMismatch 

func (m *Error) GetClusterIdMismatch() *ClusterIDMismatch

func (*Error) GetCompatibility 

func (m *Error) GetCompatibility() *Compatibility

func (*Error) GetDuplicateRequest 

func (m *Error) GetDuplicateRequest() *DuplicateRequest

func (*Error) GetEpochNotMatch 

func (m *Error) GetEpochNotMatch() *errorpb.EpochNotMatch

func (*Error) GetNotLeader 

func (m *Error) GetNotLeader() *errorpb.NotLeader

func (*Error) GetRegionNotFound 

func (m *Error) GetRegionNotFound() *errorpb.RegionNotFound

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) MarshalToSizedBuffer 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type Event 

type Event struct {
	RegionId  uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	Index     uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	RequestId uint64 `protobuf:"varint,7,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Types that are valid to be assigned to Event:
	//	*Event_Entries_
	//	*Event_Admin_
	//	*Event_Error
	//	*Event_ResolvedTs
	//	*Event_LongTxn_
	Event                isEvent_Event `protobuf_oneof:"event"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Event) Descriptor 

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

func (*Event) GetAdmin 

func (m *Event) GetAdmin() *Event_Admin

func (*Event) GetEntries 

func (m *Event) GetEntries() *Event_Entries

func (*Event) GetError 

func (m *Event) GetError() *Error

func (*Event) GetEvent 

func (m *Event) GetEvent() isEvent_Event

func (*Event) GetIndex 

func (m *Event) GetIndex() uint64

func (*Event) GetLongTxn 

func (m *Event) GetLongTxn() *Event_LongTxn

func (*Event) GetRegionId 

func (m *Event) GetRegionId() uint64

func (*Event) GetRequestId 

func (m *Event) GetRequestId() uint64

func (*Event) GetResolvedTs deprecated 

func (m *Event) GetResolvedTs() uint64

Deprecated: Do not use.

func (*Event) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) MarshalToSizedBuffer 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

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

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

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

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_OneofWrappers 

func (*Event) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type Event_Admin 

type Event_Admin struct {
	AdminRequest         *raft_cmdpb.AdminRequest  `protobuf:"bytes,1,opt,name=admin_request,json=adminRequest,proto3" json:"admin_request,omitempty"`
	AdminResponse        *raft_cmdpb.AdminResponse `protobuf:"bytes,2,opt,name=admin_response,json=adminResponse,proto3" json:"admin_response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*Event_Admin) Descriptor 

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

func (*Event_Admin) GetAdminRequest 

func (m *Event_Admin) GetAdminRequest() *raft_cmdpb.AdminRequest

func (*Event_Admin) GetAdminResponse 

func (m *Event_Admin) GetAdminResponse() *raft_cmdpb.AdminResponse

func (*Event_Admin) Marshal 

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

func (*Event_Admin) MarshalTo 

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

func (*Event_Admin) MarshalToSizedBuffer 

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

func (*Event_Admin) ProtoMessage 

func (*Event_Admin) ProtoMessage()

func (*Event_Admin) Reset 

func (m *Event_Admin) Reset()

func (*Event_Admin) Size 

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

func (*Event_Admin) String 

func (m *Event_Admin) String() string

func (*Event_Admin) Unmarshal 

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

func (*Event_Admin) XXX_DiscardUnknown 

func (m *Event_Admin) XXX_DiscardUnknown()

func (*Event_Admin) XXX_Marshal 

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

func (*Event_Admin) XXX_Merge 

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

func (*Event_Admin) XXX_Size 

func (m *Event_Admin) XXX_Size() int

func (*Event_Admin) XXX_Unmarshal 

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

type Event_Admin_ 

type Event_Admin_ struct {
	Admin *Event_Admin `protobuf:"bytes,4,opt,name=admin,proto3,oneof" json:"admin,omitempty"`
}

func (*Event_Admin_) MarshalTo 

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

func (*Event_Admin_) MarshalToSizedBuffer 

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

func (*Event_Admin_) Size 

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

type Event_Entries 

type Event_Entries struct {
	Entries              []*Event_Row `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Event_Entries) Descriptor 

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

func (*Event_Entries) GetEntries 

func (m *Event_Entries) GetEntries() []*Event_Row

func (*Event_Entries) Marshal 

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

func (*Event_Entries) MarshalTo 

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

func (*Event_Entries) MarshalToSizedBuffer 

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

func (*Event_Entries) ProtoMessage 

func (*Event_Entries) ProtoMessage()

func (*Event_Entries) Reset 

func (m *Event_Entries) Reset()

func (*Event_Entries) Size 

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

func (*Event_Entries) String 

func (m *Event_Entries) String() string

func (*Event_Entries) Unmarshal 

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

func (*Event_Entries) XXX_DiscardUnknown 

func (m *Event_Entries) XXX_DiscardUnknown()

func (*Event_Entries) XXX_Marshal 

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

func (*Event_Entries) XXX_Merge 

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

func (*Event_Entries) XXX_Size 

func (m *Event_Entries) XXX_Size() int

func (*Event_Entries) XXX_Unmarshal 

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

type Event_Entries_ 

type Event_Entries_ struct {
	Entries *Event_Entries `protobuf:"bytes,3,opt,name=entries,proto3,oneof" json:"entries,omitempty"`
}

func (*Event_Entries_) MarshalTo 

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

func (*Event_Entries_) MarshalToSizedBuffer 

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

func (*Event_Entries_) Size 

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

type Event_Error 

type Event_Error struct {
	Error *Error `protobuf:"bytes,5,opt,name=error,proto3,oneof" json:"error,omitempty"`
}

func (*Event_Error) MarshalTo 

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

func (*Event_Error) MarshalToSizedBuffer 

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

func (*Event_Error) Size 

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

type Event_LogType 

type Event_LogType int32
const (
	Event_UNKNOWN     Event_LogType = 0
	Event_PREWRITE    Event_LogType = 1
	Event_COMMIT      Event_LogType = 2
	Event_ROLLBACK    Event_LogType = 3
	Event_COMMITTED   Event_LogType = 4
	Event_INITIALIZED Event_LogType = 5
)

func (Event_LogType) EnumDescriptor 

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

func (Event_LogType) String 

func (x Event_LogType) String() string

type Event_LongTxn 

type Event_LongTxn struct {
	TxnInfo              []*TxnInfo `protobuf:"bytes,1,rep,name=txn_info,json=txnInfo,proto3" json:"txn_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Event_LongTxn) Descriptor 

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

func (*Event_LongTxn) GetTxnInfo 

func (m *Event_LongTxn) GetTxnInfo() []*TxnInfo

func (*Event_LongTxn) Marshal 

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

func (*Event_LongTxn) MarshalTo 

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

func (*Event_LongTxn) MarshalToSizedBuffer 

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

func (*Event_LongTxn) ProtoMessage 

func (*Event_LongTxn) ProtoMessage()

func (*Event_LongTxn) Reset 

func (m *Event_LongTxn) Reset()

func (*Event_LongTxn) Size 

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

func (*Event_LongTxn) String 

func (m *Event_LongTxn) String() string

func (*Event_LongTxn) Unmarshal 

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

func (*Event_LongTxn) XXX_DiscardUnknown 

func (m *Event_LongTxn) XXX_DiscardUnknown()

func (*Event_LongTxn) XXX_Marshal 

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

func (*Event_LongTxn) XXX_Merge 

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

func (*Event_LongTxn) XXX_Size 

func (m *Event_LongTxn) XXX_Size() int

func (*Event_LongTxn) XXX_Unmarshal 

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

type Event_LongTxn_ 

type Event_LongTxn_ struct {
	LongTxn *Event_LongTxn `protobuf:"bytes,8,opt,name=long_txn,json=longTxn,proto3,oneof" json:"long_txn,omitempty"`
}

func (*Event_LongTxn_) MarshalTo 

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

func (*Event_LongTxn_) MarshalToSizedBuffer 

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

func (*Event_LongTxn_) Size 

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

type Event_ResolvedTs 

type Event_ResolvedTs struct {
	ResolvedTs uint64 `protobuf:"varint,6,opt,name=resolved_ts,json=resolvedTs,proto3,oneof" json:"resolved_ts,omitempty"`
}

func (*Event_ResolvedTs) MarshalTo 

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

func (*Event_ResolvedTs) MarshalToSizedBuffer 

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

func (*Event_ResolvedTs) Size 

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

type Event_Row 

type Event_Row struct {
	StartTs  uint64           `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	CommitTs uint64           `protobuf:"varint,2,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	Type     Event_LogType    `protobuf:"varint,3,opt,name=type,proto3,enum=cdcpb.Event_LogType" json:"type,omitempty"`
	OpType   Event_Row_OpType `protobuf:"varint,4,opt,name=op_type,json=opType,proto3,enum=cdcpb.Event_Row_OpType" json:"op_type,omitempty"`
	Key      []byte           `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	Value    []byte           `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
	OldValue []byte           `protobuf:"bytes,7,opt,name=old_value,json=oldValue,proto3" json:"old_value,omitempty"`
	// expire_ts_unix_secs is used for RawKV (see `ChangeDataRequest.KvApi`),
	// and represents the expiration time of this row.
	// Absolute time, seconds since Unix epoch.
	ExpireTsUnixSecs uint64 `protobuf:"varint,8,opt,name=expire_ts_unix_secs,json=expireTsUnixSecs,proto3" json:"expire_ts_unix_secs,omitempty"`
	// The source of this row.
	TxnSource            uint64   `protobuf:"varint,9,opt,name=txn_source,json=txnSource,proto3" json:"txn_source,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Event_Row) Descriptor 

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

func (*Event_Row) GetCommitTs 

func (m *Event_Row) GetCommitTs() uint64

func (*Event_Row) GetExpireTsUnixSecs 

func (m *Event_Row) GetExpireTsUnixSecs() uint64

func (*Event_Row) GetKey 

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

func (*Event_Row) GetOldValue 

func (m *Event_Row) GetOldValue() []byte

func (*Event_Row) GetOpType 

func (m *Event_Row) GetOpType() Event_Row_OpType

func (*Event_Row) GetStartTs 

func (m *Event_Row) GetStartTs() uint64

func (*Event_Row) GetTxnSource 

func (m *Event_Row) GetTxnSource() uint64

func (*Event_Row) GetType 

func (m *Event_Row) GetType() Event_LogType

func (*Event_Row) GetValue 

func (m *Event_Row) GetValue() []byte

func (*Event_Row) Marshal 

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

func (*Event_Row) MarshalTo 

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

func (*Event_Row) MarshalToSizedBuffer 

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

func (*Event_Row) ProtoMessage 

func (*Event_Row) ProtoMessage()

func (*Event_Row) Reset 

func (m *Event_Row) Reset()

func (*Event_Row) Size 

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

func (*Event_Row) String 

func (m *Event_Row) String() string

func (*Event_Row) Unmarshal 

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

func (*Event_Row) XXX_DiscardUnknown 

func (m *Event_Row) XXX_DiscardUnknown()

func (*Event_Row) XXX_Marshal 

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

func (*Event_Row) XXX_Merge 

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

func (*Event_Row) XXX_Size 

func (m *Event_Row) XXX_Size() int

func (*Event_Row) XXX_Unmarshal 

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

type Event_Row_OpType 

type Event_Row_OpType int32
const (
	Event_Row_UNKNOWN Event_Row_OpType = 0
	Event_Row_PUT     Event_Row_OpType = 1
	Event_Row_DELETE  Event_Row_OpType = 2
)

func (Event_Row_OpType) EnumDescriptor 

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

func (Event_Row_OpType) String 

func (x Event_Row_OpType) String() string
type Header struct {
	ClusterId            uint64   `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	TicdcVersion         string   `protobuf:"bytes,2,opt,name=ticdc_version,json=ticdcVersion,proto3" json:"ticdc_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Header) Descriptor 

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

func (*Header) GetClusterId 

func (m *Header) GetClusterId() uint64

func (*Header) GetTicdcVersion 

func (m *Header) GetTicdcVersion() string

func (*Header) Marshal 

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

func (*Header) MarshalTo 

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

func (*Header) MarshalToSizedBuffer 

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

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) Reset 

func (m *Header) Reset()

func (*Header) Size 

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

func (*Header) String 

func (m *Header) String() string

func (*Header) Unmarshal 

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

func (*Header) XXX_DiscardUnknown 

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal 

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

func (*Header) XXX_Merge 

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

func (*Header) XXX_Size 

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal 

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

type ResolvedTs 

type ResolvedTs struct {
	Regions              []uint64 `protobuf:"varint,1,rep,packed,name=regions,proto3" json:"regions,omitempty"`
	Ts                   uint64   `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResolvedTs) Descriptor 

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

func (*ResolvedTs) GetRegions 

func (m *ResolvedTs) GetRegions() []uint64

func (*ResolvedTs) GetTs 

func (m *ResolvedTs) GetTs() uint64

func (*ResolvedTs) Marshal 

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

func (*ResolvedTs) MarshalTo 

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

func (*ResolvedTs) MarshalToSizedBuffer 

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

func (*ResolvedTs) ProtoMessage 

func (*ResolvedTs) ProtoMessage()

func (*ResolvedTs) Reset 

func (m *ResolvedTs) Reset()

func (*ResolvedTs) Size 

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

func (*ResolvedTs) String 

func (m *ResolvedTs) String() string

func (*ResolvedTs) Unmarshal 

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

func (*ResolvedTs) XXX_DiscardUnknown 

func (m *ResolvedTs) XXX_DiscardUnknown()

func (*ResolvedTs) XXX_Marshal 

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

func (*ResolvedTs) XXX_Merge 

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

func (*ResolvedTs) XXX_Size 

func (m *ResolvedTs) XXX_Size() int

func (*ResolvedTs) XXX_Unmarshal 

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

type TxnInfo 

type TxnInfo struct {
	StartTs              uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	Primary              []byte   `protobuf:"bytes,2,opt,name=primary,proto3" json:"primary,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TxnInfo) Descriptor 

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

func (*TxnInfo) GetPrimary 

func (m *TxnInfo) GetPrimary() []byte

func (*TxnInfo) GetStartTs 

func (m *TxnInfo) GetStartTs() uint64

func (*TxnInfo) Marshal 

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

func (*TxnInfo) MarshalTo 

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

func (*TxnInfo) MarshalToSizedBuffer 

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

func (*TxnInfo) ProtoMessage 

func (*TxnInfo) ProtoMessage()

func (*TxnInfo) Reset 

func (m *TxnInfo) Reset()

func (*TxnInfo) Size 

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

func (*TxnInfo) String 

func (m *TxnInfo) String() string

func (*TxnInfo) Unmarshal 

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

func (*TxnInfo) XXX_DiscardUnknown 

func (m *TxnInfo) XXX_DiscardUnknown()

func (*TxnInfo) XXX_Marshal 

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

func (*TxnInfo) XXX_Merge 

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

func (*TxnInfo) XXX_Size 

func (m *TxnInfo) XXX_Size() int

func (*TxnInfo) XXX_Unmarshal 

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

type TxnStatus 

type TxnStatus struct {
	StartTs              uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	MinCommitTs          uint64   `protobuf:"varint,2,opt,name=min_commit_ts,json=minCommitTs,proto3" json:"min_commit_ts,omitempty"`
	CommitTs             uint64   `protobuf:"varint,3,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	IsRolledBack         bool     `protobuf:"varint,4,opt,name=is_rolled_back,json=isRolledBack,proto3" json:"is_rolled_back,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TxnStatus) Descriptor 

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

func (*TxnStatus) GetCommitTs 

func (m *TxnStatus) GetCommitTs() uint64

func (*TxnStatus) GetIsRolledBack 

func (m *TxnStatus) GetIsRolledBack() bool

func (*TxnStatus) GetMinCommitTs 

func (m *TxnStatus) GetMinCommitTs() uint64

func (*TxnStatus) GetStartTs 

func (m *TxnStatus) GetStartTs() uint64

func (*TxnStatus) Marshal 

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

func (*TxnStatus) MarshalTo 

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

func (*TxnStatus) MarshalToSizedBuffer 

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

func (*TxnStatus) ProtoMessage 

func (*TxnStatus) ProtoMessage()

func (*TxnStatus) Reset 

func (m *TxnStatus) Reset()

func (*TxnStatus) Size 

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

func (*TxnStatus) String 

func (m *TxnStatus) String() string

func (*TxnStatus) Unmarshal 

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

func (*TxnStatus) XXX_DiscardUnknown 

func (m *TxnStatus) XXX_DiscardUnknown()

func (*TxnStatus) XXX_Marshal 

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

func (*TxnStatus) XXX_Merge 

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

func (*TxnStatus) XXX_Size 

func (m *TxnStatus) XXX_Size() int

func (*TxnStatus) XXX_Unmarshal 

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

type UnimplementedChangeDataServer 

type UnimplementedChangeDataServer struct {
}

UnimplementedChangeDataServer can be embedded to have forward compatible implementations.

func (*UnimplementedChangeDataServer) EventFeed 

func (*UnimplementedChangeDataServer) EventFeed(srv ChangeData_EventFeedServer) 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.