compat

Documentation

Index

• Variables
• type Compat
  • func New(config *config.SchedulerConfig, ...) *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

Variables

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")
)

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

func (c *Compat) CheckChangefeedEpochEnabled(captureID model.CaptureID) bool

CheckChangefeedEpochEnabled check if the changefeed enables epoch.

func (*Compat) CheckSpanReplicationEnabled

func (c *Compat) CheckSpanReplicationEnabled() bool

CheckSpanReplicationEnabled check if the changefeed can enable span replication.

func (*Compat) UpdateCaptureInfo

func (c *Compat) UpdateCaptureInfo(
	aliveCaptures map[model.CaptureID]*model.CaptureInfo,
) bool

UpdateCaptureInfo update the latest alive capture info. Returns true if capture info has changed.