Unit 10 · React safely to live events

Give events one safe front door

You publish normalized events into an inbox where policies authenticate, authorize, retry, dead-letter, and route them. Source callbacks never call a model directly.

AxEventRuntime10 focused minutesNot started

Worked example

See the idea in context

source := ax.NewAxMCPEventSourceWithPolicy(
    client, "inventory", "tenant:demo", "authenticated",
    ax.AxMCPSubscribeAll(),
)
runtime, err := ax.NewAxEventRuntime([]ax.AxEventRoute{{
    ID: "resource-wake", Action: "wake",
    TargetID: "inventory-agent", RequireAuthenticated: true,
    Match: map[string]ax.Value{"types": ax.Array("mcp.resource.updated")},
}}, nil)
if err != nil { panic(err) }
runtime.RegisterTarget(ax.AxEventTarget{
    ID: "inventory-agent",
    MapInput: func(event ax.AxEventEnvelope, _ *ax.AxEventContinuation) (ax.Value, error) {
        return map[string]ax.Value{"uri": event.Data.(map[string]ax.Value)["uri"]}, nil
    },
    Invoke: invokeAgent,
})
runtime.AddSource(source)
if err := runtime.Start(); err != nil { panic(err) }

Run itIn your own project

go get github.com/ax-llm/ax/packages/go

import axllm "github.com/ax-llm/ax/packages/go"

client := axllm.NewAI("openai", map[string]axllm.Value{"apiKey": os.Getenv("OPENAI_API_KEY")})
classify := axllm.NewAx("review:string -> sentiment:class \"positive, negative, neutral\"", nil)

Set OPENAI_APIKEY in your environment before running provider-backed code.

In the ax repo

From a clone of the ax repo:

npm run example -- go src/examples/go/mcp/resource_wake_agent.go

Active practice

Show that you can use it

Answer 2 in a row to learn this · attempt 1

Keep exploring

See the idea in context

Show that you can use it

Source-backed follow-up