#1 Asynq
Package asynq provides a framework for Redis based distrubted task queue.
Health score 44/100, confidence 75/100.
| Latest version | v0.2.1 |
| Imported by | 29 packages |
| Stars | 0 |
| Forks | 0 |
| Last activity | 5 years ago |
| Latest release | Unknown |
| License | Unknown |
| 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
Machinery is an asynchronous task queue/job queue based on distributed message passing.
Package queue provides multiple thread-safe generic queue implementations.
Doubly-ended heap (min-max heap) with O(log n) access to both minimum and maximum elements.
Package asynq provides a framework for Redis based distrubted task queue.
🪓 An orchestration engine for background tasks, AI agents, and durable workflows
Machinery is an asynchronous task queue/job queue based on distributed message passing.
Package queue provides multiple thread-safe generic queue implementations.
Package goworker is a Resque-compatible, Go-based background worker.