Skip to main content
The AgentNetwork orchestrates agents, channels, and the event plane. Use AgentNetwork.setup() to wire everything together.

​
Setup

const network = AgentNetwork.setup(
  ({ mainChannel, createChannel, proxy, registerAgent, spawner }) => {
    // ...
  },
);

​
Setup Context

​
mainChannel(name)

Creates and designates the main channel. Start events are published here when the network is exposed as an API. Every network should have exactly one main channel. 
const main = mainChannel('main');

​
createChannel(name)

Creates an additional named channel. Names must be kebab-case. 
const client = createChannel('client');
const analytics = createChannel('analytics');

​
proxy

Provides proxy factories: 
const client = createChannel('client').proxy(proxy.sse());
const events = createChannel('events').proxy(proxy.kafka({ topic: 'events' }));

​
registerAgent(agent)

Registers an agent and returns a binding builder: 
registerAgent(myAgent)
  .subscribe(main)
  .publishTo(client);
An agent can subscribe to and publish to multiple channels: 
registerAgent(routerAgent)
  .subscribe(main)
  .subscribe(feedback)
  .publishTo(client)
  .publishTo(analytics);

​
spawner

Creates a spawner for dynamically creating agents at runtime (multi-tenant, on-demand): 
spawner(AgentFactory)
  .listen(main, spawnEvent)
  .registry({ analyst: analystFactory, writer: writerFactory })
  .defaultBinding(({ kind }) => ({ subscribe: ['main'], publishTo: ['client'] }))
  .onSpawn(({ kind, factory, payload, spawn }) => {
    const agent = factory.produce(payload.params);
    spawn(agent);
    return agent;
  });

​
Running the Network

const api = network.expose(
  registerSSEStream({
    channel: 'client',
    triggerEvents: [requestEvent],
  }),
);
See IO + Adapters.

​
Programmatic Run

await Effect.runPromise(
  Effect.scoped(
    Effect.gen(function* () {
      const plane = yield* network.run();
      // publish events, wait for results...
    }),
  ),
);

​
Accessors

network.getChannels();             // Map<ChannelName, ConfiguredChannel>
network.getMainChannel();          // ConfiguredChannel | undefined
network.getAgentRegistrations();   // Map<string, AgentRegistration>
network.getSpawnerRegistrations(); // ReadonlyArray<SpawnerRegistration>

​
See Also