keyspan

Documentation

Index

• func NewMockRegionCache() *mockCache
• type Reconciler
  • func NewReconciler(changefeedID model.ChangeFeedID, up *upstream.Upstream, ...) (*Reconciler, error)
  • func NewReconcilerForTests(cache RegionCache, config *config.ChangefeedSchedulerConfig) *Reconciler
  • func (m *Reconciler) Reconcile(ctx context.Context, currentTables *replication.TableRanges, ...) []tablepb.Span
• type RegionCache

Functions

func NewMockRegionCache

func NewMockRegionCache() *mockCache

NewMockRegionCache returns a new MockCache.

Types

type Reconciler

type Reconciler struct {
	// contains filtered or unexported fields
}

Reconciler reconciles span and table mapping, make sure spans are in a desired state and covers all table ranges.

func NewReconciler

func NewReconciler(
	changefeedID model.ChangeFeedID,
	up *upstream.Upstream,
	config *config.ChangefeedSchedulerConfig,
) (*Reconciler, error)

NewReconciler returns a Reconciler.

func NewReconcilerForTests

func NewReconcilerForTests(
	cache RegionCache, config *config.ChangefeedSchedulerConfig,
) *Reconciler

NewReconcilerForTests returns a Reconciler.

func (*Reconciler) Reconcile

func (m *Reconciler) Reconcile(
	ctx context.Context,
	currentTables *replication.TableRanges,
	replications *spanz.BtreeMap[*replication.ReplicationSet],
	aliveCaptures map[model.CaptureID]*member.CaptureStatus,
	compat *compat.Compat,
) []tablepb.Span

Reconcile spans that need to be replicated based on current cluster status. It handles following cases: 1. Changefeed initialization 2. Owner switch. 3. Owner switch after some captures fail. 4. Add table by DDL. 5. Drop table by DDL. 6. Some captures fail, does NOT affect spans.

type RegionCache

type RegionCache interface {
	// ListRegionIDsInKeyRange lists ids of regions in [startKey,endKey].
	ListRegionIDsInKeyRange(
		bo *tikv.Backoffer, startKey, endKey []byte,
	) (regionIDs []uint64, err error)
	// LocateRegionByID searches for the region with ID.
	LocateRegionByID(bo *tikv.Backoffer, regionID uint64) (*tikv.KeyLocation, error)
}

RegionCache is a simplified interface of tikv.RegionCache. It is useful to restrict RegionCache usage and mocking in tests.