duraq library
A durable queuing system implemented in Dart.
Classes
-
DeadLetterQueue<
T> - Handles failed queue entries that have exceeded their retry attempts
- ExponentialBackoff
- Implements exponential backoff retry strategy with jitter
- IsarStorage
- Isar-based implementation of StorageInterface
- MemoryQueueMetrics
- In-memory implementation of QueueMetrics
- MetricValue
- Represents a single metric measurement
-
Queue<
T> - A type-safe queue implementation
-
QueueEntry<
T> - Represents an entry in a queue
- QueueLock
- Represents a lock on a queue entry
- QueueManager
- Manages multiple queues
- QueueMetrics
- Interface for queue metrics collection
- QueueOperation
- Common queue operations for metrics
- RetryPolicy
- Interface defining retry behavior for failed queue entries
- SQLiteStorage
- SQLite-based implementation of StorageInterface
- StorageInterface
- Interface for queue storage implementations
Enums
- EntryStatus
- Status of a queue entry