pithos_lib 0.6.4

Library and components for encrypting / compressing pithos (.pto) files, including specification
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

use crate::helpers::notifications::{Message, Notifier};
use anyhow::Result;
use async_channel::{Receiver, Sender};
use std::sync::Arc;

#[derive(Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Debug)]
pub enum TransformerType {
    Unspecified,
    ReadWriter,
    All,
    AsyncSenderSink,
    ZstdCompressor,
    GzipCompressor,
    ZstdDecompressor,
    ChaCha20Encrypt,
    ChaCha20Decrypt,
    Filter,
    FooterGenerator,
    HyperSink,
    SizeProbe,
    TarEncoder,
    TarDecoder,
    Sink,
    Hashing,
    ZipEncoder,
    FooterExtractor,
}

// Marker trait to signal that this Transformer can be a "final" destination for data
pub trait Sink: Transformer {}

#[async_trait::async_trait]
pub trait ReadWriter {
    async fn process(&mut self) -> Result<()>;
    async fn announce_all(&mut self, message: Message) -> Result<()>;
    async fn add_message_receiver(&mut self, rx: Receiver<Message>) -> Result<()>;
}

#[async_trait::async_trait]
pub trait Transformer {
    #[allow(unused_variables)]
    async fn initialize(&mut self, idx: usize) -> (TransformerType, Sender<Message>);

    async fn process_bytes(&mut self, buf: &mut bytes::BytesMut) -> Result<()>;

    async fn set_notifier(&mut self, notifier: Arc<Notifier>) -> Result<()>;
}