#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 68/100, confidence 80/100.
| Latest version | v1.1.2 |
| Imported by | 15 packages |
| Stars | 0 |
| Forks | 0 |
| Last activity | 2 months ago |
| Latest release | Unknown |
| License | Unknown |
| 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.
Package goworker is a Resque-compatible, Go-based background worker.
Package gocelery is Celery Distributed Task Queue in Go Celery distributed tasks are used heavily in many python web applications and this library allows you to implement celery workers in Go as well as being able to submit celery tasks in Go.