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

use marina::{BagRef, Marina, ProgressReporter, ResolveResult, WriterProgress};

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let mut marina = Marina::load()?;

    // Resolve a local path or cached/remote reference.
    match marina.resolve_target("tag", None).await? {
        ResolveResult::LocalPath(path) | ResolveResult::Cached(path) => {
            println!("resolved local/cached path: {}", path.display());
        }
        ResolveResult::RemoteAvailable { registry, bag, .. } => {
            println!("remote available: {} in {}", bag, registry);
        }
        ResolveResult::Ambiguous { candidates } => {
            for (registry, bag) in candidates {
                println!("ambiguous: {} in {}", bag, registry);
            }
        }
    }

    // Pull a concrete bag ref.
    let bag: BagRef = "tag:ouster".parse()?;
    let mut out = std::io::stdout();
    let mut sink = WriterProgress::new(&mut out);
    let mut progress = ProgressReporter::new(&mut sink);
    let local = marina
        .pull_exact_with_progress(&bag, None, &mut progress)
        .await?;
    println!("pulled to {}", local.display());

    // Read local catalog.
    for entry in marina.list_cached_bags() {
        println!(
            "{} -> {} ({} bytes)",
            entry.bag,
            entry.local_dir.display(),
            entry.original_bytes,
        );
    }

    Ok(())
}