Struct EngineFactory 

pub struct EngineFactory { /* private fields */ }

Constructs engines with one process-local timing provider.

The serializable engine configuration contains only a provider descriptor. A Runner resolves external timing providers before constructing this factory, which then shares the provider across all attention-DP ranks.

Implementations

impl EngineFactory

pub fn new(config: EngineConfig) -> Result<Self>

Construct a factory for a built-in timing model.

pub fn with_timing_model( config: EngineConfig, timing: Arc<dyn TimingModel>, ) -> Result<Self>

Construct a factory with a process-local timing provider.

pub fn build_rank(&self, identity: RankIdentity) -> Result<SchedulerRank>

Build one scheduler/KV/timing rank with an explicit identity.

pub fn build( &self, identity: EngineIdentity, dp_size: NonZeroU32, ) -> Result<Engine>

Build a single-rank or attention-DP logical engine.

Trait Implementations

impl Clone for EngineFactory

fn clone(&self) -> EngineFactory

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.