coordinator

Overview ¶

Package main demonstrates a distributed task coordinator using agentkit's bus and registry.

The coordinator publishes tasks to a message bus and tracks their completion. Workers claim and process tasks using queue subscriptions for load balancing.

Run: go run coordinator.go In other terminals: go run worker.go worker-1