package changefeed

import "context"

type Scheduler interface {
	ScheduleChangefeed(ctx context.Context, clusterID, changefeedID string) error
	ScaleChangefeedResource(ctx context.Context, clusterID, changefeedID string) error
	DeleteChangefeedResource(ctx context.Context, clusterID, changefeedID string) error
	IsChangefeedResourceReady(ctx context.Context, clusterID, changefeedID string) (bool, error)
	IsChangefeedResourceReleased(ctx context.Context, clusterID, changefeedID string) (bool, error)
}