flusso-kernel 0.17.0

The flusso kernel: the shared vocabulary every layer trades in (values, validated newtypes, index schemas and mappings, adapter options).
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

use nutype::nutype;
use std::path::PathBuf;

#[nutype(derive(
    Debug,
    Clone,
    AsRef,
    Deref,
    Hash,
    Eq,
    PartialEq,
    Serialize,
    Deserialize
))]
pub struct SchemaPath(PathBuf);

impl AsRef<std::path::Path> for SchemaPath {
    fn as_ref(&self) -> &std::path::Path {
        self.as_path()
    }
}

/// A path to a `*.schema.yml`, relative to the config file.
impl schemars::JsonSchema for SchemaPath {
    fn schema_name() -> std::borrow::Cow<'static, str> {
        std::borrow::Cow::Borrowed("SchemaPath")
    }

    fn json_schema(_: &mut schemars::SchemaGenerator) -> schemars::Schema {
        schemars::json_schema!({
            "type": "string",
            "format": "uri-reference",
            "pattern": "^[^/][^:]*\\.ya?ml$",
            "description": "Path to the index schema YAML file, resolved relative to the config file's directory."
        })
    }
}