phlow-runtime 0.4.2

Phlow is a fast, modular runtime for building backends with YAML flows, Rust modules, and native OpenTelemetry observability.
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

use phlow_sdk::valu3;
use std::fmt::Display;
use zip::result::ZipError;

pub struct ModuleError {
    pub module: String,
}

impl Display for ModuleError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "Module: {}", self.module)
    }
}

pub enum Error {
    VersionNotFound(ModuleError),
    ModuleLoaderError(String),
    ModuleNotFound(String),
    StepsNotDefined,
    LibLoadingError(libloading::Error),
    LoaderErrorJsonValu3(valu3::Error),
    LoaderErrorScript(serde_yaml::Error),
    GetFileError(reqwest::Error),
    FileCreateError(std::io::Error),
    ZipErrorError(ZipError),
    BufferError(reqwest::Error),
    CopyError(std::io::Error),
    MainNotFound(String),
}

impl std::fmt::Debug for Error {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Error::VersionNotFound(err) => write!(f, "Version not found: {}", err),
            Error::ModuleLoaderError(err) => write!(f, "Module loader error: {}", err),
            Error::StepsNotDefined => write!(f, "Steps not defined"),
            Error::ModuleNotFound(name) => write!(f, "Module not found: {}", name),
            Error::LibLoadingError(err) => write!(f, "Lib loading error: {:?}", err),
            Error::LoaderErrorJsonValu3(err) => write!(f, "Json Valu3 error: {:?}", err),
            Error::LoaderErrorScript(err) => write!(f, "Script error: {:?}", err),
            Error::GetFileError(err) => write!(f, "Get file error: {:?}", err),
            Error::FileCreateError(err) => write!(f, "File create error: {:?}", err),
            Error::BufferError(err) => write!(f, "Buffer error: {:?}", err),
            Error::CopyError(err) => write!(f, "Copy error: {:?}", err),
            Error::ZipErrorError(err) => write!(f, "Zip error: {:?}", err),
            Error::MainNotFound(err) => write!(f, "Main not found: {:?}", err),
        }
    }
}

impl Display for Error {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Error::VersionNotFound(err) => write!(f, "Version not found: {}", err),
            Error::ModuleLoaderError(err) => write!(f, "Module loader error: {}", err),
            Error::StepsNotDefined => write!(f, "Steps not defined"),
            Error::ModuleNotFound(name) => write!(f, "Module not found: {}", name),
            Error::LibLoadingError(err) => write!(f, "Lib loading error: {:?}", err),
            Error::LoaderErrorJsonValu3(err) => write!(f, "Json Valu3 error: {:?}", err),
            Error::LoaderErrorScript(err) => write!(f, "Yaml error: {:?}", err),
            Error::GetFileError(err) => write!(f, "Get file error: {:?}", err),
            Error::FileCreateError(err) => write!(f, "File create error: {:?}", err),
            Error::BufferError(err) => write!(f, "Buffer error: {:?}", err),
            Error::CopyError(err) => write!(f, "Copy error: {:?}", err),
            Error::ZipErrorError(err) => write!(f, "Zip error: {:?}", err),
            Error::MainNotFound(err) => write!(f, "Main not found: {:?}", err),
        }
    }
}