Struct necsim_partitioning_threads::ThreadsPartitioning

pub struct ThreadsPartitioning { /* private fields */ }

Implementations

impl ThreadsPartitioning

pub fn set_migration_interval(&mut self, migration_interval: Duration)

pub fn set_progress_interval(&mut self, progress_interval: Duration)

pub fn set_panic_interval(&mut self, panic_interval: Duration)

Trait Implementations

impl Debug for ThreadsPartitioning

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ThreadsPartitioning

fn deserialize<D: Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error>

Deserialize this value from the given Serde deserializer.

impl Partitioning for ThreadsPartitioning

fn with_local_partition<R: Reporter, P: ReporterContext<Reporter = R>, A: Data, Q: Data + Serialize + DeserializeOwned>( self, reporter_context: P, event_log: Self::Auxiliary, args: A, inner: for<'p> fn(_: &'p mut Self::LocalPartition<'p, R>, _: A) -> Q, fold: fn(_: Q, _: Q) -> Q ) -> Result<(Q, Self::FinalisableReporter<R>)>

Errors

Returns MissingEventLog if the local partition is non-monolithic and the event_log is None. Returns InvalidEventSubLog if creating a sub-event_log failed.

type Auxiliary = Option<EventLogConfig>

type FinalisableReporter<R: Reporter> = FinalisableThreadsReporter<R>

type LocalPartition<'p, R: Reporter> = ThreadsLocalPartition<R>

fn get_size(&self) -> PartitionSize

impl Serialize for ThreadsPartitioning

fn serialize<S: Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error>

Serialize this value into the given Serde serializer.