#1 Asynq
Package asynq provides a framework for Redis based distrubted task queue.
Simple job queues for Go backed by Redis
Health score 79/100, confidence 60/100.
| Latest version | Unknown |
| Imported by | 29 packages |
| Stars | 278 |
| Forks | 27 |
| Last activity | 2 months ago |
| Latest release | v0.2.0 (6 years ago) |
| License | MIT |
| Known vuln records | 0 |
| Symbol | Kind | Synopsis |
|---|---|---|
| AfterRequestFunc | Type | type AfterRequestFunc func() |
| GetContextAfterRequestFuncs | Function | func GetContextAfterRequestFuncs(ctx context.Context) []AfterRequestFunc |
| Bokchoy | Type | type Bokchoy struct{ ... } |
| Bokchoy.Empty | Method | func (b *Bokchoy) Empty(ctx context.Context) error |
| Bokchoy.Flush | Method | func (b *Bokchoy) Flush() error |
| Bokchoy.Handle | Method | func (b *Bokchoy) Handle(queueName string, sub Handler, options ...Option) |
| Bokchoy.HandleFunc | Method | func (b *Bokchoy) HandleFunc(queueName string, f HandlerFunc, options ...Option) |
| Bokchoy.Logger | Field | Logger logging.Logger |
| Bokchoy.Publish | Method | func (b *Bokchoy) Publish(ctx context.Context, queueName string, payload interface{}, options ...Option) (*Task, error) |
| Bokchoy.Queue | Method | func (b *Bokchoy) Queue(name string) *Queue |
| Bokchoy.QueueNames | Method | func (b *Bokchoy) QueueNames() []string |
| Bokchoy.Run | Method | func (b *Bokchoy) Run(ctx context.Context, options ...Option) error |
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.
Package deheap provides a doubly-ended heap (min-max heap).