file-engine 1.1.1

Async, cross-platform file operations engine for desktop apps and developer tools: copy, move, sync, watch, and compress files with progress reporting and cancellation.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

use crate::profiler::{Entry, Workload};

use super::batch::{pack, Batch};
use super::config::BatchConfig;

#[derive(Debug, Clone)]
pub struct StreamJob {
    pub entry: Entry,
}

#[derive(Debug, Clone, Default)]
pub struct ExecutionPlan {
    pub batches: Vec<Batch>,
    pub streams: Vec<StreamJob>,
}

pub(crate) fn plan(workload: Workload, config: &BatchConfig) -> ExecutionPlan {
    let batches = pack(workload.small, config);
    let streams = workload
        .large
        .into_iter()
        .map(|entry| StreamJob { entry })
        .collect();
    ExecutionPlan { batches, streams }
}