Documentation
¶
Overview ¶
Package recovery reconciles expired runtime leases into fenced retries.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithParallelism ¶
func WithParallelism(workers int) func(*Controller)
WithParallelism bounds concurrent per-candidate recovery within one batch (default 4; 1 = serial).
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController(repository Repository, batch int, leaseTTL time.Duration) *Controller
type Repository ¶
type Repository interface {
ListExpiredAttempts(context.Context, time.Time, int) ([]store.RecoveryCandidate, error)
RecoverExpiredAttempt(context.Context, store.RecoverExpiredAttemptInput) (store.RecoveryResult, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.