#1 hatchet
🪓 An orchestration engine for background tasks, AI agents, and durable workflows
Package asynq provides a framework for Redis based distrubted task queue.
Health score 94/100, confidence 100/100.
| Latest version | v0.26.0 |
| Imported by | 2.3K packages |
| Stars | 13.3K |
| Forks | 938 |
| Last activity | 2 days ago |
| Latest release | v0.26.0 (3 months ago) |
| License | MIT |
| Known vuln records | 0 |
| Symbol | Kind | Synopsis |
|---|---|---|
| Client | Type | type Client struct{} |
| Client.Close | Method | func (c *Client) Close() error |
| Client.Enqueue | Method | func (c *Client) Enqueue(task *Task, opts ...Option) (*TaskInfo, error) |
| Client.EnqueueContext | Method | func (c *Client) EnqueueContext(ctx context.Context, task *Task, opts ...Option) (*TaskInfo, error) |
| Client.Ping | Method | func (c *Client) Ping() error |
| NewClient | Function | func NewClient(r RedisConnOpt) *Client |
| NewClientFromRedisClient | Function | func NewClientFromRedisClient(c redis.UniversalClient) *Client |
| ClusterNode | Type | type ClusterNode struct{ ... } |
| ClusterNode.Addr | Field | Addr string |
| ClusterNode.ID | Field | ID string |
| Config | Type | type Config struct{ ... } |
| Config.BaseContext | Field | BaseContext func() context.Context |
🪓 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.
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.