Service Discovery

@app.reasoner(tags=["orchestrator"])
async def dynamic_router(question: str) -> dict:
    # 1. Discover active agents with input schemas — zero hardcoded addresses
    caps = app.discover(
        tags=["public"],
        health_status="active",
        include_input_schema=True,
        format="json",
    )
    print(f"{caps.json.total_agents} agents online, {len(caps.json.capabilities)} capabilities")

    # 2. Feed discovered capabilities + schemas into an LLM — it picks the best agent
    result = await app.ai(
        system=(
            "You are a routing agent. Pick the best tool for the user's question.\n"
            "Available capabilities:\n" + caps.raw
        ),
        user=question,
        tools="discover",  # built-in: turns discovered capabilities into callable tools
    )

    # 3. The LLM chose an agent and called it — no static routing table needed
    return result

# New agents register at startup → the router discovers them automatically.
# No config changes, no redeployment, no service mesh.

agent.reasoner('dynamicRouter', async (ctx) => {
  // 1. Discover active agents with input schemas — zero hardcoded addresses
  const caps = await agent.discover({
    tags: ['public'],
    healthStatus: 'active',
    includeInputSchema: true,
    format: 'json',
  });
  console.log(`${caps.json?.totalAgents} agents online`);

  // 2. Feed discovered capabilities + schemas into an LLM — it picks the best agent
  const result = await ctx.ai(ctx.input.question, {
    system: `You are a routing agent. Pick the best tool.\nAvailable:\n${caps.raw}`,
  });

  // 3. The LLM chose an agent and called it — no static routing table needed
  return result;
});

// New agents register at startup → the router discovers them automatically.

a.RegisterReasoner("dynamic_router", func(ctx context.Context, input map[string]any) (any, error) {
    // 1. Discover active agents with input schemas — zero hardcoded addresses
    caps, err := a.Discover(ctx,
        agent.WithTags([]string{"public"}),
        agent.WithHealthStatus("active"),
        agent.WithDiscoveryInputSchema(true),
        agent.WithFormat("json"),
    )
    if err != nil {
        return nil, err
    }
    fmt.Printf("%d agents online, %d capabilities\n",
        caps.JSON.TotalAgents, len(caps.JSON.Capabilities))

    // 2. Use compact format in LLM context for dynamic tool selection
    // 3. Route to the best agent based on discovered capabilities
    return map[string]any{
        "available_agents": caps.JSON.TotalAgents,
        "capabilities":     caps.JSON.Capabilities,
    }, nil
})

// New agents register at startup → the router discovers them automatically.