async

type Cleaner interface {
	Clean(context.Context) error
}

type Engine interface {
	// RegisterJob registers a new Job with the async engine
	RegisterJob(name string, fn model.JobFunction) error
	// SubmitTask submits an idempotent task to the async engine for reliable,
	// asynchronous completion
	SubmitTask(model.Task) error
	// Start causes the async engine to begin executing queued tasks
	Start(context.Context) error
}

type Heart interface {
	// Beat sends a single heartbeat
	Beat() error
	// Start sends heartbeats at regular intervals
	Start(context.Context) error
}

type Worker interface {
	// GetID returns the worker's ID
	GetID() string
	// RegisterJob registers a new Job with the worker
	RegisterJob(name string, fn model.JobFunction) error
	// Work causes the worker to begin completing tasks
	Work(context.Context) error
}