Struct BuiltTopology 

pub struct BuiltTopology { /* private fields */ }

A built topology.

Built topologies represent a topology blueprint where each configured component, along with their associated connections to other components, was validated and built successfully.

A built topology must be spawned via spawn.

Implementations

impl BuiltTopology

pub fn with_ambient_worker_pool(self) -> Self

Configures the topology to use the ambient Tokio runtime.

Component subtasks will be spawned on whatever runtime is currently active when spawn is called. This avoids creating a dedicated thread pool, which is useful for resource-constrained environments like Lambda.

pub fn with_explicit_worker_pool(self, handle: Handle) -> Self

Configures the topology to use an externally provided Tokio runtime.

Component subtasks will be spawned on the runtime associated with the given handle.

pub async fn spawn( self, health_registry: &HealthRegistry, memory_limiter: MemoryLimiter, ) -> Result<RunningTopology, GenericError>

Spawns the topology.

By default, a dedicated, multi-threaded Tokio runtime (8 threads) is created for components to spawn compute-heavy subtasks on. Use with_ambient_worker_pool or with_explicit_worker_pool to change this before calling spawn.

A handle is returned that can be used to trigger the topology to shutdown.

Errors

If an error occurs while spawning the topology, an error is returned.