marina 0.2.5

A dataset manager for robotics to organize, share, and discover datasets and metadata across storage backends.
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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

use std::io::IsTerminal;

use indicatif::{ProgressBar, ProgressStyle};

use crate::progress::ProgressReporter;

pub fn make_count_progress_bar(total: usize, label: impl Into<String>, unit: &str) -> ProgressBar {
    if !std::io::stdout().is_terminal() {
        return ProgressBar::hidden();
    }

    if total > 0 {
        let pb = ProgressBar::new(total as u64);
        pb.set_style(
            ProgressStyle::with_template(&format!(
                "{{msg}} [{{bar:40.cyan/blue}}] {{pos}}/{{len}} {unit} ({{eta}})"
            ))
            .unwrap_or_else(|_| ProgressStyle::default_bar()),
        );
        pb.set_message(label.into());
        pb
    } else {
        let pb = ProgressBar::new_spinner();
        pb.set_style(
            ProgressStyle::with_template("{spinner} {msg}")
                .unwrap_or_else(|_| ProgressStyle::default_spinner())
                .tick_chars("|/-\\ "),
        );
        pb.set_message(label.into());
        pb.enable_steady_tick(std::time::Duration::from_millis(100));
        pb
    }
}

pub fn make_byte_progress_bar(total_bytes: u64, label: impl Into<String>) -> ProgressBar {
    if !std::io::stdout().is_terminal() {
        return ProgressBar::hidden();
    }

    if total_bytes > 0 {
        let pb = ProgressBar::new(total_bytes);
        pb.set_style(
            ProgressStyle::with_template(
                "{msg} [{bar:40.cyan/blue}] {bytes}/{total_bytes} ({eta})",
            )
            .unwrap_or_else(|_| ProgressStyle::default_bar()),
        );
        pb.set_message(label.into());
        pb
    } else {
        let pb = ProgressBar::new_spinner();
        pb.set_style(
            ProgressStyle::with_template("{spinner} {msg}")
                .unwrap_or_else(|_| ProgressStyle::default_spinner())
                .tick_chars("|/-\\ "),
        );
        pb.set_message(label.into());
        pb.enable_steady_tick(std::time::Duration::from_millis(100));
        pb
    }
}

pub fn emit_count_progress(
    progress: &mut ProgressReporter<'_>,
    phase: &'static str,
    label: &str,
    current: usize,
    total: usize,
) {
    if total > 0 {
        let pct = (current as f64 / total as f64) * 100.0;
        progress.emit(
            phase,
            format!("{} {}/{} ({:.1}%)", label, current, total, pct),
        );
    } else {
        progress.emit(phase, format!("{} {}", label, current));
    }
}