Module actor_manager 

Structs

ExecutorParams

Parameters to construct executors.

StreamActorManager 🔒

Spawning actors, called by crate::task::barrier_worker::managed_state::PartialGraphState.

Constants

CONFIG_OVERRIDE_CACHE_DEFAULT_CAPACITY

Default capacity for ConfigOverrideCache. Since we only support per-job config override right now, 256 jobs should be sufficient on a single node.

Functions

actor_vnode_bitmap 🔒

An actor without a vnode bitmap is a singleton, which owns the only SINGLETON_VNODE.

Type Aliases

ConfigOverrideCache