Skip to content

InboxBlock

autogen.beta.network.rule.InboxBlock dataclass #

InboxBlock(max_pending=1000, overflow='reject', high_water=None)

Inbox capacity policy.

Only reject is enforced today; drop_oldest / drop_newest are recognised but treated as reject until the dispatch path grows the alternate behaviours.

high_water is a soft threshold for backpressure signalling (fires :meth:HubListener.on_inbox_pressure). Defaults to None which auto-resolves to 80% of max_pending when the hub evaluates pressure. 0 disables the signal.

max_pending class-attribute instance-attribute #

max_pending = 1000

overflow class-attribute instance-attribute #

overflow = 'reject'

high_water class-attribute instance-attribute #

high_water = None