Module execute 

Supervised, isolated execution of routing functions.

Each invocation runs in its own supervised process, never on the calling thread. A panic is contained and surfaced as FunctionError::Crashed; a function running past the supervision timeout is abandoned and surfaced as FunctionError::TimedOut. Neither outcome affects any other channel.

Structs

ConsumerId

Identifier of a consumer that a routing function may select.

ConsumerStateView

Per-consumer state presented to a routing function during execution.

RoutingDecision

Routing decision produced by a routing function.

RoutingMessage

Owned, supervisor-marshalled view of a message a routing function evaluates.

SupervisedExecutor

Executes routing functions in supervised, isolated processes.

Enums

FunctionError

Failure surfaced when a supervised routing function does not complete.