Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
MaxRetries int // Maximum retry attempts (-1 for infinite)
BaseDelay time.Duration // Initial retry delay
MaxDelay time.Duration // Maximum retry delay
StatePath string // Path to save queue state
}
Config holds queue configuration
type Persistence ¶
type Persistence struct {
// contains filtered or unexported fields
}
Persistence handles saving and loading queue state
func NewPersistence ¶
func NewPersistence(statePath string) (*Persistence, error)
NewPersistence creates a new persistence handler
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue is a thread-safe FIFO queue with persistence
func (*Queue) Dequeue ¶
Dequeue removes and returns the item from the front of the queue Returns nil if queue is empty or all items are not ready for retry
Source Files
Click to show internal directories.
Click to hide internal directories.