README
¶
Task Queue Example
Demonstrates work distribution using the message bus queue groups.
Components
- coordinator/ - Submits tasks and collects results
- worker/ - Processes tasks from the queue
Running
Start one or more workers:
go run ./examples/task-queue/worker/
go run ./examples/task-queue/worker/ # second worker
In another terminal, start the coordinator:
go run ./examples/task-queue/coordinator/
What This Shows
- Queue groups for load balancing
- Work distribution across multiple workers
- Result collection
Directories
¶
| Path | Synopsis |
|---|---|
|
Package main demonstrates a distributed task coordinator using agentkit's bus and registry.
|
Package main demonstrates a distributed task coordinator using agentkit's bus and registry. |
|
Package main demonstrates a task worker using agentkit's bus and registry.
|
Package main demonstrates a task worker using agentkit's bus and registry. |
Click to show internal directories.
Click to hide internal directories.