Struct DistributedReplayBuilder 

pub struct DistributedReplayBuilder { /* private fields */ }

Builder for a validated distributed replay plan.

Implementations

impl DistributedReplayBuilder

pub fn new(multi_config_path: impl AsRef<Path>) -> CuResult<Self>

Load a strict multi-Copper config and start building a distributed replay plan.

pub fn with_catalog(self, catalog: DistributedReplayCatalog) -> Self

Replace the discovered catalog explicitly.

pub fn discover_logs<I, P>(self, inputs: I) -> CuResult<Self>

where I: IntoIterator<Item = P>, P: AsRef<Path>,

Discover logs from files and/or directories.

Directories are walked recursively by DistributedReplayCatalog.

pub fn discover_logs_under(self, root: impl AsRef<Path>) -> CuResult<Self>

Convenience wrapper for recursive discovery under one root directory.

pub fn instances<I>(self, instances: I) -> Self

where I: IntoIterator<Item = u32>,

Restrict plan construction to a subset of instance ids.

pub fn register<App>(self, subsystem_id: &str) -> CuResult<Self>

where App: CuDistributedReplayApplication<NoopSectionStorage, NoopLogger> + CuDistributedReplayApplication<MmapSectionStorage, UnifiedLoggerWrite> + 'static,

Register the generated app type expected for one subsystem.

pub fn build(self) -> CuResult<DistributedReplayPlan>

Validate discovery + registrations and prepare a typed replay plan.

Trait Implementations

impl Clone for DistributedReplayBuilder

fn clone(&self) -> DistributedReplayBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DistributedReplayBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.