Distributed Decision Making Kit

import { createDistributedDecisions } from 'agent-tools-kit/cross-system'

const decisions = createDistributedDecisions({
  consensus: 'raft',
  partitionTolerance: true,
  timeout: 5000,
})

const result = await decisions.propose({
  action: 'elect-leader',
  candidates: ['node-alpha', 'node-beta', 'node-gamma'],
})

result.on('vote', (node, vote) => {
  console.log(`${node.name} voted: ${vote}`)
})

const decision = await result.commit()
console.log('Consensus:', decision.reached, 'Value:', decision.value)