actioner

type Interface interface {
	Schedule(context.Context, string, *queue.QueuedJob) (counter.Interface, error)
	Enqueue(counter.Interface)
	Deschedule(counter.Interface)
	RemoveConsumer(counter.Interface)
	Trigger(*api.TriggerRequest, func(*api.TriggerResponse))
	AddToControlLoop(*queue.ControlEvent)
	DeliverablePrefixes(...string) []int64
	UnDeliverablePrefixes(...string)
	Stage(int64, string) bool
	Unstage(int64)
}

type Options struct {
	Queue        *eventsqueue.Processor[int64, counter.Interface]
	TriggerFn    api.TriggerFunction
	ControlLoop  *loop.Interface[*queue.ControlEvent]
	SchedBuilder *scheduler.Builder
	Key          *key.Key
	Client       clientapi.Interface
	Consumer     *consumer.Consumer
}