workflow

type Controller interface {
	Start(ctx context.Context, workspace string) error
	Cancel(ctx context.Context, workspace string) error
}

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

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

type RunnerConfig struct {
	BatchInterval time.Duration
	SleepInterval time.Duration
}

type RunnerProgress struct {
	ProcessedRecords int64
	TotalRecords     int64
	LastProcessedAt  time.Time
}