Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Heartbeater ¶
func Heartbeater(hopts *HeartbeaterOptions) work.HandleMiddleware
Heartbeater refreshes InvisibleSec for long-running jobs periodically. As a result, if the job is lost, it won't take a long time before it is retried.
Types ¶
type HeartbeaterOptions ¶
type HeartbeaterOptions struct {
// Queue is where the current job is currently in.
Queue work.Queue
// After the job is dequeued, no other dequeuer can see this job for a while.
// InvisibleSec controls how long this period is.
InvisibleSec int64
// IntervalSec controls how often job InvisibleSec is refreshed.
IntervalSec int64
}
HeartbeaterOptions defines Heartbeater periodically refreshes InvisibleSec for long-running jobs.
Source Files
Click to show internal directories.
Click to hide internal directories.