Distributed clustering — one-line multi-node support

[gregwinn]

Summary

Make BEAM distribution trivial. Winn.connect(:node@host) and your agents, events, and pipelines automatically span machines. The BEAM has 35 years of battle-tested distribution — Winn should make it a one-liner.

Syntax

Winn.connect(:app@us_east)
Winn.connect(:app@eu_west)

# Agents, events, and pipelines automatically
# span all connected nodes — zero config
Event.emit(:order_placed, order)

Design

• Winn.connect/1 wraps net_kernel and net_adm:ping for node discovery
• Agents started on any node are accessible from any other via pg (process groups)
• Events (on/emit from Reactive on/emit event system — language-level pub/sub #103) broadcast across all connected nodes automatically
• Pipelines (pipeline keyword — supervised multi-stage data flows #104) can distribute stages across nodes for horizontal scaling
• Winn.nodes() returns connected node list
• Winn.disconnect/1 for graceful leave

Dependencies

• Benefits from agent keyword — stateful actors as a language primitive #102 (agent keyword) — distributed agents
• Benefits from Reactive on/emit event system — language-level pub/sub #103 (on/emit events) — cross-node event broadcast
• Benefits from pipeline keyword — supervised multi-stage data flows #104 (pipeline keyword) — distributed stage placement

Target Version

v1.0.0 — The Winn Platform