Documentation
¶
Index ¶
- Variables
- type Compat
- func (c *Compat) AfterTransportReceive(msgs []*schedulepb.Message)
- func (c *Compat) BeforeTransportSend(msgs []*schedulepb.Message)
- func (c *Compat) CheckChangefeedEpochEnabled(captureID model.CaptureID) bool
- func (c *Compat) CheckSpanReplicationEnabled() bool
- func (c *Compat) UpdateCaptureInfo(aliveCaptures map[model.CaptureID]*model.CaptureInfo) bool
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // SpanReplicationMinVersion is the min version that allows span replication. SpanReplicationMinVersion = semver.New("6.6.0-alpha") // ChangefeedEpochMinVersion is the min version that enables changefeed epoch. ChangefeedEpochMinVersion = semver.New("6.7.0-alpha") )
Functions ¶
This section is empty.
Types ¶
type Compat ¶
type Compat struct {
// contains filtered or unexported fields
}
Compat is a compatibility layer between span replication and table replication.
func New ¶
func New( config *config.SchedulerConfig, captureInfo map[model.CaptureID]*model.CaptureInfo, ) *Compat
New returns a new Compat.
func (*Compat) AfterTransportReceive ¶
func (c *Compat) AfterTransportReceive(msgs []*schedulepb.Message)
AfterTransportReceive modifies messages in place after receiving messages, makes messages compatible with other end.
func (*Compat) BeforeTransportSend ¶
func (c *Compat) BeforeTransportSend(msgs []*schedulepb.Message)
BeforeTransportSend modifies messages in place before sending messages, makes messages compatible with other end.
func (*Compat) CheckChangefeedEpochEnabled ¶
CheckChangefeedEpochEnabled check if the changefeed enables epoch.
func (*Compat) CheckSpanReplicationEnabled ¶
CheckSpanReplicationEnabled check if the changefeed can enable span replication.
func (*Compat) UpdateCaptureInfo ¶
UpdateCaptureInfo update the latest alive capture info. Returns true if capture info has changed.
Source Files
Click to show internal directories.
Click to hide internal directories.