Documentation
¶
Overview ¶
Package queuetest is the conformance suite for queue drivers:
queuetest.Run(t, driver, queuetest.Options{Pending: driver.Pending, Advance: clock.Add})
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Options ¶
type Options struct {
// Pending counts stored jobs (waiting or running).
Pending func(ctx context.Context) (int, error)
// Advance moves the driver's clock forward; nil skips the test of
// abandoned reservations.
Advance func(d time.Duration)
}
Options describe the driver under test.
Click to show internal directories.
Click to hide internal directories.