apalis-core 0.7.4

Core for apalis: simple, extensible multithreaded background processing for Rust
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

use std::marker::PhantomData;

use serde::{Deserialize, Serialize};

use crate::error::BoxDynError;

/// A codec allows backends to encode and decode data
pub trait Codec {
    /// The mode of storage by the codec
    type Compact;
    /// Error encountered by the codec
    type Error: Into<BoxDynError>;
    /// The encoding method
    fn encode<I>(input: I) -> Result<Self::Compact, Self::Error>
    where
        I: Serialize;
    /// The decoding method
    fn decode<O>(input: Self::Compact) -> Result<O, Self::Error>
    where
        O: for<'de> Deserialize<'de>;
}

/// A noop codec to use as a placeholder when backend does not support encoding and decoding
/// Panics if any of its methods are called
#[derive(Debug, Clone)]
pub struct NoopCodec<Compact> {
    compact: PhantomData<Compact>,
}

impl<Compact> Codec for NoopCodec<Compact> {
    type Compact = Compact;
    type Error = BoxDynError;

    fn decode<O>(_: Self::Compact) -> Result<O, Self::Error>
    where
        O: for<'de> Deserialize<'de>,
    {
        unreachable!("NoopCodec doesn't have decoding functionality")
    }
    fn encode<I>(_: I) -> Result<Self::Compact, Self::Error>
    where
        I: Serialize,
    {
        unreachable!("NoopCodec doesn't have decoding functionality")
    }
}

/// Encoding for tasks using json
#[cfg(feature = "json")]
pub mod json;