Documentation
¶
Index ¶
Constants ¶
View Source
const ( ActionBackoff = "backoff" ActionDeferred = "deferred" ActionDetached = "detached" ActionEnsured = "ensured" ActionStartFailed = "start_failed" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Reconciler ¶
type Reconciler struct {
Wake WakeRunner
Adapter Adapter
Now func() time.Time
BackoffBase time.Duration
BackoffMax time.Duration
Jitter func(time.Duration) time.Duration
InjectVia string
WakeTimeout time.Duration
ActiveCheckInterval time.Duration
DetachedBackoffBase time.Duration
DetachedBackoffMax time.Duration
}
func (Reconciler) StartFresh ¶
type WakeRunner ¶
type WakeRunner interface {
StartWake(ctx context.Context, req amq.StartWakeRequest) error
}
Click to show internal directories.
Click to hide internal directories.