Struct pipelines::PipelineConfig

pub struct PipelineConfig { /* fields omitted */ }

Configuration for buffers internal to the Pipeline

Each stage inherits the configuration from its previous state. As a result, this configures future stages, not past

Example

use pipelines::{Pipeline, PipelineConfig};

let nums: Vec<u64> = (0..10).collect();
let fibs: Vec<u64> = Pipeline::from(nums)
    .configure(PipelineConfig::default().buff_size(10))
    .map(|x| x*2) // *this* stage has its send buffer set to 10
    .into_iter().collect();

Methods

impl PipelineConfig

fn buff_size(self, buff_size: usize) -> Self

Set the size of the internal mpsc buffer.

This can affect the effective parallelism and the length of the backlog between stages when different stages of the pipeline take different amounts of time

fn batch_size(self, batch_size: usize) -> Self

Set the size of each batch of messages sent

This tunes how much overhead is spent on synchronisation

Trait Implementations

impl Debug for PipelineConfig

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Copy for PipelineConfig

impl Clone for PipelineConfig

fn clone(&self) -> PipelineConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for PipelineConfig

fn default() -> Self

Returns the "default value" for a type.