#1 Asynq
Package asynq provides a framework for Redis based distrubted task queue.
Package deheap provides a doubly-ended heap (min-max heap).
Health score 81/100, confidence 100/100.
| Latest version | v1.1.2 |
| Imported by | 15 packages |
| Stars | 16 |
| Forks | 2 |
| Last activity | 2 months ago |
| Latest release | v1.1.2 (2 months ago) |
| License | MIT |
| Known vuln records | 0 |
| Symbol | Kind | Synopsis |
|---|---|---|
| Deheap | Type | type Deheap struct{} |
| Deheap.Fix | Method | func (p *Deheap[T]) Fix(i int) |
| Deheap.Len | Method | func (p *Deheap[T]) Len() int |
| Deheap.Peek | Method | func (p *Deheap[T]) Peek() T |
| Deheap.PeekMax | Method | func (p *Deheap[T]) PeekMax() T |
| Deheap.Pop | Method | func (p *Deheap[T]) Pop() T |
| Deheap.PopMax | Method | func (p *Deheap[T]) PopMax() T |
| Deheap.Push | Method | func (p *Deheap[T]) Push(o T) |
| Deheap.Remove | Method | func (p *Deheap[T]) Remove(i int) T |
| Deheap.Verify | Method | func (p *Deheap[T]) Verify() bool |
| From | Function | func From[T cmp.Ordered](items ...T) *Deheap[T] |
| New | Function | func New[T cmp.Ordered]() *Deheap[T] |
Package asynq provides a framework for Redis based distrubted task queue.
🪓 An orchestration engine for background tasks, AI agents, and durable workflows
Package queue provides multiple thread-safe generic queue implementations.
Machinery is an asynchronous task queue/job queue based on distributed message passing.
Simple job queues for Go backed by Redis