State Sync Kit

Consistent state synchronization across instances.

Configuration

State Sync

Active

8

Queued

42

Failed

1

Worker 1BUSYProcessing task-42
Worker 2IDLEWaiting for work
Worker 3BUSYProcessing task-43
Queue42 tasksPriority ordered

Integration Code

import { createDistributed } from 'agent-tools-kit/distributed'

const pool = createDistributed({ type: 'worker-pool', autoScale: true })
await pool.start()
await pool.enqueue({ task: 'process', data: {} })