v3

Documentation

Index

• func InitMetrics(registry *prometheus.Registry)
• func NewCoordinator(ctx context.Context, captureID model.CaptureID, ...) (internal.Scheduler, error)

Functions

func InitMetrics

func InitMetrics(registry *prometheus.Registry)

InitMetrics registers all metrics used in scheduler

func NewCoordinator

func NewCoordinator(
	ctx context.Context,
	captureID model.CaptureID,
	changefeedID model.ChangeFeedID,
	messageServer *p2p.MessageServer,
	messageRouter p2p.MessageRouter,
	ownerRevision int64,
	changefeedEpoch uint64,
	up *upstream.Upstream,
	cfg *config.SchedulerConfig,
	redoMetaManager redo.MetaManager,
) (internal.Scheduler, error)

NewCoordinator returns a two phase scheduler.