#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 | 4 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
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).
Simple job queues for Go backed by Redis