AG2 Network — Page 6 (Governance)

Network canvas · governance pipeline alice bob carol hub

alice

agent_id=ag_a71b… · owner="acme"

Rule

access.outbound_to["carol"]

access.channel_types["consulting"]

rate.env_per_min2

inbox.max_pending100

Resume.observed

— no capability tasks yet —

bob

agent_id=ag_b84c… · owner="acme"

Rule · default permissive

access— any —

rate— uncapped —

carol

agent_id=ag_c52d… · owner="acme"

Rule · default permissive

access— any —

rate— uncapped —

Resume.observed

research: — none —

AUTH

one-time

AuthAdapter.verify protocol

AuthRegistry map

idle

→

RULES

every send

AccessBlock who

RateBlock flow

InboxBlock queue

LimitsBlock ttl/depth

idle

→

EXPECTATIONS

every 10s

acks_within consulting

reply_within consulting

max_silence conversation

turn_within discussion/workflow

idle

→

RECORD

durable

Audit log AUDIT_KIND_*

Resume.observed TaskMirror

idle

Pre-state · governance defined, no traffic IDLE

three agents configured. # rules attached at registration, will be enforced by the hub

Governance walkthrough 0 of 5

step 0

Three agents are about to register. alice has a strict Rule — only the carol recipient is whitelisted, only consulting channels are allowed, rate-limited to 2 envelopes per minute. bob and carol are permissive. The four governance gates are all idle.

Setup

0 3 agents · rules defined · gates idle

① Auth · at registration

1 ✓ hc.register(alice, …) · AuthAdapter.verify

② Rules · per envelope

2 ⊘ alice.open(target=bob) · AccessBlock

3 ⊘ alice.send(×3, fast) · RateBlock

③ Expectations · on sweeper

4 ⊘ bob no-ack 30s · acks_within → auto_close

④ Record · after the fact

5 ✓ carol.task(capability="research") · TaskMirror

Rule definition for alice attached at register()

from autogen.beta.network import (
    Rule, AccessBlock, RateBlock,
    InboxBlock, LimitsBlock,
)

alice_rule = Rule(
    access=AccessBlock(
        outbound_to=["carol"],
        channel_types_allowed=["consulting"],
    ),
    rate=RateBlock(envelopes_per_minute=2),
    inbox=InboxBlock(max_pending=100),
    limits=LimitsBlock(
        channel_ttl_default="4h",
        delegation_depth=2,
    ),
)

# rule attached at registration; hub enforces on every send
alice = await alice_hc.register(
    agent, passport, resume, rule=alice_rule,
)

Audit log (hub._audit_log · append-only) 0 entries