schedulepb

package
v0.0.0-...-bcc2220 Latest Latest
Warning

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

 Go to latest Published: Dec 26, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTableSchedule        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTableSchedule          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTableSchedule = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var MessageType_name = map[int32]string{
	0: "MsgUnknown",
	1: "MsgDispatchTableRequest",
	2: "MsgDispatchTableResponse",
	3: "MsgHeartbeat",
	4: "MsgHeartbeatResponse",
}
View Source 
var MessageType_value = map[string]int32{
	"MsgUnknown":               0,
	"MsgDispatchTableRequest":  1,
	"MsgDispatchTableResponse": 2,
	"MsgHeartbeat":             3,
	"MsgHeartbeatResponse":     4,
}

Functions

This section is empty.

Types

type AddTableRequest 

type AddTableRequest struct {
	TableID     github_com_pingcap_tiflow_cdc_model.TableID `` /* 136-byte string literal not displayed */
	Span        tablepb.Span                                `protobuf:"bytes,4,opt,name=span,proto3" json:"span"`
	IsSecondary bool                                        `protobuf:"varint,2,opt,name=is_secondary,json=isSecondary,proto3" json:"is_secondary,omitempty"`
	Checkpoint  tablepb.Checkpoint                          `protobuf:"bytes,3,opt,name=checkpoint,proto3" json:"checkpoint"`
}

func (*AddTableRequest) Descriptor 

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

func (*AddTableRequest) GetCheckpoint 

func (m *AddTableRequest) GetCheckpoint() tablepb.Checkpoint

func (*AddTableRequest) GetIsSecondary 

func (m *AddTableRequest) GetIsSecondary() bool

func (*AddTableRequest) GetSpan 

func (m *AddTableRequest) GetSpan() tablepb.Span

func (*AddTableRequest) GetTableID 

func (m *AddTableRequest) GetTableID() github_com_pingcap_tiflow_cdc_model.TableID

func (*AddTableRequest) Marshal 

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

func (*AddTableRequest) MarshalTo 

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

func (*AddTableRequest) MarshalToSizedBuffer 

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

func (*AddTableRequest) ProtoMessage 

func (*AddTableRequest) ProtoMessage()

func (*AddTableRequest) Reset 

func (m *AddTableRequest) Reset()

func (*AddTableRequest) Size 

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

func (*AddTableRequest) String 

func (m *AddTableRequest) String() string

func (*AddTableRequest) Unmarshal 

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

func (*AddTableRequest) XXX_DiscardUnknown 

func (m *AddTableRequest) XXX_DiscardUnknown()

func (*AddTableRequest) XXX_Marshal 

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

func (*AddTableRequest) XXX_Merge 

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

func (*AddTableRequest) XXX_Size 

func (m *AddTableRequest) XXX_Size() int

func (*AddTableRequest) XXX_Unmarshal 

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

type AddTableResponse 

type AddTableResponse struct {
	Status     *tablepb.TableStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Checkpoint tablepb.Checkpoint   `protobuf:"bytes,2,opt,name=checkpoint,proto3" json:"checkpoint"`
}

func (*AddTableResponse) Descriptor 

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

func (*AddTableResponse) GetCheckpoint 

func (m *AddTableResponse) GetCheckpoint() tablepb.Checkpoint

func (*AddTableResponse) GetStatus 

func (m *AddTableResponse) GetStatus() *tablepb.TableStatus

func (*AddTableResponse) Marshal 

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

func (*AddTableResponse) MarshalTo 

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

func (*AddTableResponse) MarshalToSizedBuffer 

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

func (*AddTableResponse) ProtoMessage 

func (*AddTableResponse) ProtoMessage()

func (*AddTableResponse) Reset 

func (m *AddTableResponse) Reset()

func (*AddTableResponse) Size 

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

func (*AddTableResponse) String 

func (m *AddTableResponse) String() string

func (*AddTableResponse) Unmarshal 

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

func (*AddTableResponse) XXX_DiscardUnknown 

func (m *AddTableResponse) XXX_DiscardUnknown()

func (*AddTableResponse) XXX_Marshal 

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

func (*AddTableResponse) XXX_Merge 

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

func (*AddTableResponse) XXX_Size 

func (m *AddTableResponse) XXX_Size() int

func (*AddTableResponse) XXX_Unmarshal 

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

type Barrier 

type Barrier struct {
	TableBarriers   []*TableBarrier                                    `protobuf:"bytes,1,rep,name=table_barriers,json=tableBarriers,proto3" json:"table_barriers,omitempty"`
	GlobalBarrierTs github_com_pingcap_tiflow_cdc_processor_tablepb.Ts `` /* 169-byte string literal not displayed */
}

Barrier contains the barrierTs of those tables that have ddl jobs that need to be replicated. The Scheduler will broadcast the barrierTs to all captures through the Heartbeat.

func (*Barrier) Descriptor 

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

func (*Barrier) GetGlobalBarrierTs 

func (m *Barrier) GetGlobalBarrierTs() github_com_pingcap_tiflow_cdc_processor_tablepb.Ts

func (*Barrier) GetTableBarriers 

func (m *Barrier) GetTableBarriers() []*TableBarrier

func (*Barrier) Marshal 

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

func (*Barrier) MarshalTo 

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

func (*Barrier) MarshalToSizedBuffer 

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

func (*Barrier) ProtoMessage 

func (*Barrier) ProtoMessage()

func (*Barrier) Reset 

func (m *Barrier) Reset()

func (*Barrier) Size 

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

func (*Barrier) String 

func (m *Barrier) String() string

func (*Barrier) Unmarshal 

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

func (*Barrier) XXX_DiscardUnknown 

func (m *Barrier) XXX_DiscardUnknown()

func (*Barrier) XXX_Marshal 

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

func (*Barrier) XXX_Merge 

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

func (*Barrier) XXX_Size 

func (m *Barrier) XXX_Size() int

func (*Barrier) XXX_Unmarshal 

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

type BarrierWithMinTs 

type BarrierWithMinTs struct {
	*Barrier
	// MinTableBarrierTs is the minimum commitTs of all DDL events and is only
	// used to check whether there is a pending DDL job at the checkpointTs when
	// initializing the changefeed.
	MinTableBarrierTs model.Ts
	RedoBarrierTs     model.Ts
}

BarrierWithMinTs is a barrier with the minimum commitTs of all barriers.

func NewBarrierWithMinTs 

func NewBarrierWithMinTs(ts model.Ts) *BarrierWithMinTs

NewBarrierWithMinTs creates a new BarrierWithMinTs.

type ChangefeedEpoch 

type ChangefeedEpoch struct {
	Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
}

func (*ChangefeedEpoch) Descriptor 

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

func (*ChangefeedEpoch) GetEpoch 

func (m *ChangefeedEpoch) GetEpoch() uint64

func (*ChangefeedEpoch) Marshal 

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

func (*ChangefeedEpoch) MarshalTo 

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

func (*ChangefeedEpoch) MarshalToSizedBuffer 

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

func (*ChangefeedEpoch) ProtoMessage 

func (*ChangefeedEpoch) ProtoMessage()

func (*ChangefeedEpoch) Reset 

func (m *ChangefeedEpoch) Reset()

func (*ChangefeedEpoch) Size 

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

func (*ChangefeedEpoch) String 

func (m *ChangefeedEpoch) String() string

func (*ChangefeedEpoch) Unmarshal 

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

func (*ChangefeedEpoch) XXX_DiscardUnknown 

func (m *ChangefeedEpoch) XXX_DiscardUnknown()

func (*ChangefeedEpoch) XXX_Marshal 

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

func (*ChangefeedEpoch) XXX_Merge 

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

func (*ChangefeedEpoch) XXX_Size 

func (m *ChangefeedEpoch) XXX_Size() int

func (*ChangefeedEpoch) XXX_Unmarshal 

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

type DispatchTableRequest 

type DispatchTableRequest struct {
	// Types that are valid to be assigned to Request:
	//	*DispatchTableRequest_AddTable
	//	*DispatchTableRequest_RemoveTable
	Request isDispatchTableRequest_Request `protobuf_oneof:"request"`
}

func (*DispatchTableRequest) Descriptor 

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

func (*DispatchTableRequest) GetAddTable 

func (m *DispatchTableRequest) GetAddTable() *AddTableRequest

func (*DispatchTableRequest) GetRemoveTable 

func (m *DispatchTableRequest) GetRemoveTable() *RemoveTableRequest

func (*DispatchTableRequest) GetRequest 

func (m *DispatchTableRequest) GetRequest() isDispatchTableRequest_Request

func (*DispatchTableRequest) Marshal 

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

func (*DispatchTableRequest) MarshalTo 

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

func (*DispatchTableRequest) MarshalToSizedBuffer 

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

func (*DispatchTableRequest) ProtoMessage 

func (*DispatchTableRequest) ProtoMessage()

func (*DispatchTableRequest) Reset 

func (m *DispatchTableRequest) Reset()

func (*DispatchTableRequest) Size 

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

func (*DispatchTableRequest) String 

func (m *DispatchTableRequest) String() string

func (*DispatchTableRequest) Unmarshal 

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

func (*DispatchTableRequest) XXX_DiscardUnknown 

func (m *DispatchTableRequest) XXX_DiscardUnknown()

func (*DispatchTableRequest) XXX_Marshal 

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

func (*DispatchTableRequest) XXX_Merge 

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

func (*DispatchTableRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DispatchTableRequest) XXX_Size 

func (m *DispatchTableRequest) XXX_Size() int

func (*DispatchTableRequest) XXX_Unmarshal 

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

type DispatchTableRequest_AddTable 

type DispatchTableRequest_AddTable struct {
	AddTable *AddTableRequest `protobuf:"bytes,1,opt,name=add_table,json=addTable,proto3,oneof" json:"add_table,omitempty"`
}

func (*DispatchTableRequest_AddTable) MarshalTo 

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

func (*DispatchTableRequest_AddTable) MarshalToSizedBuffer 

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

func (*DispatchTableRequest_AddTable) Size 

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

type DispatchTableRequest_RemoveTable 

type DispatchTableRequest_RemoveTable struct {
	RemoveTable *RemoveTableRequest `protobuf:"bytes,2,opt,name=remove_table,json=removeTable,proto3,oneof" json:"remove_table,omitempty"`
}

func (*DispatchTableRequest_RemoveTable) MarshalTo 

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

func (*DispatchTableRequest_RemoveTable) MarshalToSizedBuffer 

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

func (*DispatchTableRequest_RemoveTable) Size 

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

type DispatchTableResponse 

type DispatchTableResponse struct {
	// Types that are valid to be assigned to Response:
	//
	//	*DispatchTableResponse_AddTable
	//	*DispatchTableResponse_RemoveTable
	Response isDispatchTableResponse_Response `protobuf_oneof:"response"`
}

func (*DispatchTableResponse) Descriptor 

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

func (*DispatchTableResponse) GetAddTable 

func (m *DispatchTableResponse) GetAddTable() *AddTableResponse

func (*DispatchTableResponse) GetRemoveTable 

func (m *DispatchTableResponse) GetRemoveTable() *RemoveTableResponse

func (*DispatchTableResponse) GetResponse 

func (m *DispatchTableResponse) GetResponse() isDispatchTableResponse_Response

func (*DispatchTableResponse) Marshal 

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

func (*DispatchTableResponse) MarshalTo 

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

func (*DispatchTableResponse) MarshalToSizedBuffer 

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

func (*DispatchTableResponse) ProtoMessage 

func (*DispatchTableResponse) ProtoMessage()

func (*DispatchTableResponse) Reset 

func (m *DispatchTableResponse) Reset()

func (*DispatchTableResponse) Size 

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

func (*DispatchTableResponse) String 

func (m *DispatchTableResponse) String() string

func (*DispatchTableResponse) Unmarshal 

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

func (*DispatchTableResponse) XXX_DiscardUnknown 

func (m *DispatchTableResponse) XXX_DiscardUnknown()

func (*DispatchTableResponse) XXX_Marshal 

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

func (*DispatchTableResponse) XXX_Merge 

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

func (*DispatchTableResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DispatchTableResponse) XXX_Size 

func (m *DispatchTableResponse) XXX_Size() int

func (*DispatchTableResponse) XXX_Unmarshal 

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

type DispatchTableResponse_AddTable 

type DispatchTableResponse_AddTable struct {
	AddTable *AddTableResponse `protobuf:"bytes,1,opt,name=add_table,json=addTable,proto3,oneof" json:"add_table,omitempty"`
}

func (*DispatchTableResponse_AddTable) MarshalTo 

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

func (*DispatchTableResponse_AddTable) MarshalToSizedBuffer 

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

func (*DispatchTableResponse_AddTable) Size 

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

type DispatchTableResponse_RemoveTable 

type DispatchTableResponse_RemoveTable struct {
	RemoveTable *RemoveTableResponse `protobuf:"bytes,2,opt,name=remove_table,json=removeTable,proto3,oneof" json:"remove_table,omitempty"`
}

func (*DispatchTableResponse_RemoveTable) MarshalTo 

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

func (*DispatchTableResponse_RemoveTable) MarshalToSizedBuffer 

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

func (*DispatchTableResponse_RemoveTable) Size 

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

type Heartbeat 

type Heartbeat struct {
	TableIDs     []github_com_pingcap_tiflow_cdc_model.TableID `` /* 146-byte string literal not displayed */
	IsStopping   bool                                          `protobuf:"varint,2,opt,name=is_stopping,json=isStopping,proto3" json:"is_stopping,omitempty"`
	Spans        []tablepb.Span                                `protobuf:"bytes,3,rep,name=spans,proto3" json:"spans"`
	CollectStats bool                                          `protobuf:"varint,4,opt,name=collect_stats,json=collectStats,proto3" json:"collect_stats,omitempty"`
	Barrier      *Barrier                                      `protobuf:"bytes,5,opt,name=barrier,proto3" json:"barrier,omitempty"`
}

func (*Heartbeat) Descriptor 

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

func (*Heartbeat) GetBarrier 

func (m *Heartbeat) GetBarrier() *Barrier

func (*Heartbeat) GetCollectStats 

func (m *Heartbeat) GetCollectStats() bool

func (*Heartbeat) GetIsStopping 

func (m *Heartbeat) GetIsStopping() bool

func (*Heartbeat) GetSpans 

func (m *Heartbeat) GetSpans() []tablepb.Span

func (*Heartbeat) GetTableIDs 

func (m *Heartbeat) GetTableIDs() []github_com_pingcap_tiflow_cdc_model.TableID

func (*Heartbeat) Marshal 

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

func (*Heartbeat) MarshalTo 

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

func (*Heartbeat) MarshalToSizedBuffer 

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

func (*Heartbeat) ProtoMessage 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) Reset 

func (m *Heartbeat) Reset()

func (*Heartbeat) Size 

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

func (*Heartbeat) String 

func (m *Heartbeat) String() string

func (*Heartbeat) Unmarshal 

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

func (*Heartbeat) XXX_DiscardUnknown 

func (m *Heartbeat) XXX_DiscardUnknown()

func (*Heartbeat) XXX_Marshal 

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

func (*Heartbeat) XXX_Merge 

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

func (*Heartbeat) XXX_Size 

func (m *Heartbeat) XXX_Size() int

func (*Heartbeat) XXX_Unmarshal 

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

type HeartbeatResponse 

type HeartbeatResponse struct {
	Tables   []tablepb.TableStatus                        `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables"`
	Liveness github_com_pingcap_tiflow_cdc_model.Liveness `protobuf:"varint,2,opt,name=liveness,proto3,casttype=github.com/pingcap/tiflow/cdc/model.Liveness" json:"liveness,omitempty"`
}

func (*HeartbeatResponse) Descriptor 

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

func (*HeartbeatResponse) GetLiveness 

func (m *HeartbeatResponse) GetLiveness() github_com_pingcap_tiflow_cdc_model.Liveness

func (*HeartbeatResponse) GetTables 

func (m *HeartbeatResponse) GetTables() []tablepb.TableStatus

func (*HeartbeatResponse) Marshal 

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

func (*HeartbeatResponse) MarshalTo 

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

func (*HeartbeatResponse) MarshalToSizedBuffer 

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

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) Reset 

func (m *HeartbeatResponse) Reset()

func (*HeartbeatResponse) Size 

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

func (*HeartbeatResponse) String 

func (m *HeartbeatResponse) String() string

func (*HeartbeatResponse) Unmarshal 

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

func (*HeartbeatResponse) XXX_DiscardUnknown 

func (m *HeartbeatResponse) XXX_DiscardUnknown()

func (*HeartbeatResponse) XXX_Marshal 

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

func (*HeartbeatResponse) XXX_Merge 

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

func (*HeartbeatResponse) XXX_Size 

func (m *HeartbeatResponse) XXX_Size() int

func (*HeartbeatResponse) XXX_Unmarshal 

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

type Message 

type Message struct {
	Header                *Message_Header                               `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	MsgType               MessageType                                   `` /* 140-byte string literal not displayed */
	From                  github_com_pingcap_tiflow_cdc_model.CaptureID `protobuf:"bytes,3,opt,name=from,proto3,casttype=github.com/pingcap/tiflow/cdc/model.CaptureID" json:"from,omitempty"`
	To                    github_com_pingcap_tiflow_cdc_model.CaptureID `protobuf:"bytes,4,opt,name=to,proto3,casttype=github.com/pingcap/tiflow/cdc/model.CaptureID" json:"to,omitempty"`
	DispatchTableRequest  *DispatchTableRequest                         `protobuf:"bytes,5,opt,name=dispatch_table_request,json=dispatchTableRequest,proto3" json:"dispatch_table_request,omitempty"`
	DispatchTableResponse *DispatchTableResponse                        `` /* 126-byte string literal not displayed */
	Heartbeat             *Heartbeat                                    `protobuf:"bytes,7,opt,name=heartbeat,proto3" json:"heartbeat,omitempty"`
	HeartbeatResponse     *HeartbeatResponse                            `protobuf:"bytes,8,opt,name=heartbeat_response,json=heartbeatResponse,proto3" json:"heartbeat_response,omitempty"`
}

func (*Message) Descriptor 

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

func (*Message) GetDispatchTableRequest 

func (m *Message) GetDispatchTableRequest() *DispatchTableRequest

func (*Message) GetDispatchTableResponse 

func (m *Message) GetDispatchTableResponse() *DispatchTableResponse

func (*Message) GetFrom 

func (m *Message) GetFrom() github_com_pingcap_tiflow_cdc_model.CaptureID

func (*Message) GetHeader 

func (m *Message) GetHeader() *Message_Header

func (*Message) GetHeartbeat 

func (m *Message) GetHeartbeat() *Heartbeat

func (*Message) GetHeartbeatResponse 

func (m *Message) GetHeartbeatResponse() *HeartbeatResponse

func (*Message) GetMsgType 

func (m *Message) GetMsgType() MessageType

func (*Message) GetTo 

func (m *Message) GetTo() github_com_pingcap_tiflow_cdc_model.CaptureID

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) MarshalToSizedBuffer 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

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

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

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

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type MessageType 

type MessageType int32
const (
	MsgUnknown               MessageType = 0
	MsgDispatchTableRequest  MessageType = 1
	MsgDispatchTableResponse MessageType = 2
	MsgHeartbeat             MessageType = 3
	MsgHeartbeatResponse     MessageType = 4
)

func (MessageType) EnumDescriptor 

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

func (MessageType) String 

func (x MessageType) String() string

type Message_Header 

type Message_Header struct {
	// The semantic version of the node that sent this message.
	Version         string          `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	OwnerRevision   OwnerRevision   `protobuf:"bytes,2,opt,name=owner_revision,json=ownerRevision,proto3" json:"owner_revision"`
	ProcessorEpoch  ProcessorEpoch  `protobuf:"bytes,3,opt,name=processor_epoch,json=processorEpoch,proto3" json:"processor_epoch"`
	ChangefeedEpoch ChangefeedEpoch `protobuf:"bytes,4,opt,name=changefeed_epoch,json=changefeedEpoch,proto3" json:"changefeed_epoch"`
}

func (*Message_Header) Descriptor 

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

func (*Message_Header) GetChangefeedEpoch 

func (m *Message_Header) GetChangefeedEpoch() ChangefeedEpoch

func (*Message_Header) GetOwnerRevision 

func (m *Message_Header) GetOwnerRevision() OwnerRevision

func (*Message_Header) GetProcessorEpoch 

func (m *Message_Header) GetProcessorEpoch() ProcessorEpoch

func (*Message_Header) GetVersion 

func (m *Message_Header) GetVersion() string

func (*Message_Header) Marshal 

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

func (*Message_Header) MarshalTo 

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

func (*Message_Header) MarshalToSizedBuffer 

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

func (*Message_Header) ProtoMessage 

func (*Message_Header) ProtoMessage()

func (*Message_Header) Reset 

func (m *Message_Header) Reset()

func (*Message_Header) Size 

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

func (*Message_Header) String 

func (m *Message_Header) String() string

func (*Message_Header) Unmarshal 

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

func (*Message_Header) XXX_DiscardUnknown 

func (m *Message_Header) XXX_DiscardUnknown()

func (*Message_Header) XXX_Marshal 

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

func (*Message_Header) XXX_Merge 

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

func (*Message_Header) XXX_Size 

func (m *Message_Header) XXX_Size() int

func (*Message_Header) XXX_Unmarshal 

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

type OwnerRevision 

type OwnerRevision struct {
	Revision int64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
}

func (*OwnerRevision) Descriptor 

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

func (*OwnerRevision) GetRevision 

func (m *OwnerRevision) GetRevision() int64

func (*OwnerRevision) Marshal 

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

func (*OwnerRevision) MarshalTo 

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

func (*OwnerRevision) MarshalToSizedBuffer 

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

func (*OwnerRevision) ProtoMessage 

func (*OwnerRevision) ProtoMessage()

func (*OwnerRevision) Reset 

func (m *OwnerRevision) Reset()

func (*OwnerRevision) Size 

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

func (*OwnerRevision) String 

func (m *OwnerRevision) String() string

func (*OwnerRevision) Unmarshal 

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

func (*OwnerRevision) XXX_DiscardUnknown 

func (m *OwnerRevision) XXX_DiscardUnknown()

func (*OwnerRevision) XXX_Marshal 

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

func (*OwnerRevision) XXX_Merge 

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

func (*OwnerRevision) XXX_Size 

func (m *OwnerRevision) XXX_Size() int

func (*OwnerRevision) XXX_Unmarshal 

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

type ProcessorEpoch 

type ProcessorEpoch struct {
	Epoch string `protobuf:"bytes,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
}

func (*ProcessorEpoch) Descriptor 

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

func (*ProcessorEpoch) GetEpoch 

func (m *ProcessorEpoch) GetEpoch() string

func (*ProcessorEpoch) Marshal 

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

func (*ProcessorEpoch) MarshalTo 

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

func (*ProcessorEpoch) MarshalToSizedBuffer 

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

func (*ProcessorEpoch) ProtoMessage 

func (*ProcessorEpoch) ProtoMessage()

func (*ProcessorEpoch) Reset 

func (m *ProcessorEpoch) Reset()

func (*ProcessorEpoch) Size 

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

func (*ProcessorEpoch) String 

func (m *ProcessorEpoch) String() string

func (*ProcessorEpoch) Unmarshal 

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

func (*ProcessorEpoch) XXX_DiscardUnknown 

func (m *ProcessorEpoch) XXX_DiscardUnknown()

func (*ProcessorEpoch) XXX_Marshal 

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

func (*ProcessorEpoch) XXX_Merge 

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

func (*ProcessorEpoch) XXX_Size 

func (m *ProcessorEpoch) XXX_Size() int

func (*ProcessorEpoch) XXX_Unmarshal 

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

type RemoveTableRequest 

type RemoveTableRequest struct {
	TableID github_com_pingcap_tiflow_cdc_model.TableID `` /* 136-byte string literal not displayed */
	Span    tablepb.Span                                `protobuf:"bytes,2,opt,name=span,proto3" json:"span"`
}

func (*RemoveTableRequest) Descriptor 

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

func (*RemoveTableRequest) GetSpan 

func (m *RemoveTableRequest) GetSpan() tablepb.Span

func (*RemoveTableRequest) GetTableID 

func (m *RemoveTableRequest) GetTableID() github_com_pingcap_tiflow_cdc_model.TableID

func (*RemoveTableRequest) Marshal 

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

func (*RemoveTableRequest) MarshalTo 

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

func (*RemoveTableRequest) MarshalToSizedBuffer 

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

func (*RemoveTableRequest) ProtoMessage 

func (*RemoveTableRequest) ProtoMessage()

func (*RemoveTableRequest) Reset 

func (m *RemoveTableRequest) Reset()

func (*RemoveTableRequest) Size 

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

func (*RemoveTableRequest) String 

func (m *RemoveTableRequest) String() string

func (*RemoveTableRequest) Unmarshal 

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

func (*RemoveTableRequest) XXX_DiscardUnknown 

func (m *RemoveTableRequest) XXX_DiscardUnknown()

func (*RemoveTableRequest) XXX_Marshal 

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

func (*RemoveTableRequest) XXX_Merge 

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

func (*RemoveTableRequest) XXX_Size 

func (m *RemoveTableRequest) XXX_Size() int

func (*RemoveTableRequest) XXX_Unmarshal 

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

type RemoveTableResponse 

type RemoveTableResponse struct {
	Status     *tablepb.TableStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Checkpoint tablepb.Checkpoint   `protobuf:"bytes,2,opt,name=checkpoint,proto3" json:"checkpoint"`
}

func (*RemoveTableResponse) Descriptor 

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

func (*RemoveTableResponse) GetCheckpoint 

func (m *RemoveTableResponse) GetCheckpoint() tablepb.Checkpoint

func (*RemoveTableResponse) GetStatus 

func (m *RemoveTableResponse) GetStatus() *tablepb.TableStatus

func (*RemoveTableResponse) Marshal 

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

func (*RemoveTableResponse) MarshalTo 

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

func (*RemoveTableResponse) MarshalToSizedBuffer 

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

func (*RemoveTableResponse) ProtoMessage 

func (*RemoveTableResponse) ProtoMessage()

func (*RemoveTableResponse) Reset 

func (m *RemoveTableResponse) Reset()

func (*RemoveTableResponse) Size 

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

func (*RemoveTableResponse) String 

func (m *RemoveTableResponse) String() string

func (*RemoveTableResponse) Unmarshal 

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

func (*RemoveTableResponse) XXX_DiscardUnknown 

func (m *RemoveTableResponse) XXX_DiscardUnknown()

func (*RemoveTableResponse) XXX_Marshal 

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

func (*RemoveTableResponse) XXX_Merge 

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

func (*RemoveTableResponse) XXX_Size 

func (m *RemoveTableResponse) XXX_Size() int

func (*RemoveTableResponse) XXX_Unmarshal 

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

type TableBarrier 

type TableBarrier struct {
	TableID github_com_pingcap_tiflow_cdc_model.TableID `` /* 136-byte string literal not displayed */
	// The barrier timestamp of the table.
	BarrierTs github_com_pingcap_tiflow_cdc_processor_tablepb.Ts `` /* 149-byte string literal not displayed */
}

func (*TableBarrier) Descriptor 

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

func (*TableBarrier) GetBarrierTs 

func (m *TableBarrier) GetBarrierTs() github_com_pingcap_tiflow_cdc_processor_tablepb.Ts

func (*TableBarrier) GetTableID 

func (m *TableBarrier) GetTableID() github_com_pingcap_tiflow_cdc_model.TableID

func (*TableBarrier) Marshal 

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

func (*TableBarrier) MarshalTo 

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

func (*TableBarrier) MarshalToSizedBuffer 

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

func (*TableBarrier) ProtoMessage 

func (*TableBarrier) ProtoMessage()

func (*TableBarrier) Reset 

func (m *TableBarrier) Reset()

func (*TableBarrier) Size 

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

func (*TableBarrier) String 

func (m *TableBarrier) String() string

func (*TableBarrier) Unmarshal 

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

func (*TableBarrier) XXX_DiscardUnknown 

func (m *TableBarrier) XXX_DiscardUnknown()

func (*TableBarrier) XXX_Marshal 

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

func (*TableBarrier) XXX_Merge 

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

func (*TableBarrier) XXX_Size 

func (m *TableBarrier) XXX_Size() int

func (*TableBarrier) XXX_Unmarshal 

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

type Watermark 

type Watermark struct {
	CheckpointTs     model.Ts
	ResolvedTs       model.Ts
	LastSyncedTs     model.Ts
	PullerResolvedTs model.Ts
}

Watermark contains various ts variables to make code easier

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.