executor

type Config struct {
	PollingFrequency time.Duration
	RateLimiter      RateLimiter
}

type Controller interface {
	Reconcile(ctx context.Context) (Result, error)
}

type Executor interface {
	Start(ctx context.Context) StopWaitFn
	Running() bool
	Trigger()
}

type RateLimiter interface {
	// When gets an item and gets to decide how long that item should wait
	When(item any) time.Duration
	// Forget indicates that an item is finished being retried.  Doesn't matter whether its for perm failing
	// or for success, we'll stop tracking it
	Forget(item any)
}

type Result struct {
	Requeue      bool
	RequeueAfter time.Duration
}

type StopWaitFn func()