Documentation
¶
Overview ¶
Package queuetest provides a backend-agnostic conformance test suite for queue.Service implementations and a deterministic FakeClock for use in backend-specific tests.
Each backend's test file calls queuetest.Run with a factory that produces a fresh queue.Service per sub-test. The suite covers FIFO, priority, delay, retry, dead letter routing, concurrency, panic recovery, visibility-timeout recovery, and graceful shutdown.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Factory ¶
Factory produces a fresh queue.Service per sub-test along with a teardown function. The factory is responsible for using a unique namespace per call so durable backends do not bleed state between sub-tests.
type FakeClock ¶
type FakeClock struct {
// contains filtered or unexported fields
}
FakeClock is a deterministic Clock controlled by tests.
func NewFakeClock ¶
NewFakeClock returns a FakeClock anchored at t (zero time = time.Unix(0,0)).
func (*FakeClock) Advance ¶
Advance moves the clock forward by d, firing any timers whose deadline has elapsed.
Source Files