flusso-schema 0.3.0

Config and schema loading for flusso: assembles flusso.toml and *.schema.yml into a validated Config.
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

use schema_core::{
    ConnectionSpec, ConnectionUrl, ResolveError, SourceType, resolve_connection_url,
};
use serde::{Deserialize, Serialize};

/// The database documents are read from. Today that's always Postgres.
///
/// The connection is stored unresolved (a literal or an environment reference)
/// and resolved at runtime by [`resolve_connection_url`](Source::resolve_connection_url),
/// so a compiled config carries no secret it wasn't given literally.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Source {
    pub source_type: SourceType,
    /// How to reach the database. `None` means "rely entirely on
    /// `DATABASE_URL`", checked when the connection is resolved.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub connection: Option<ConnectionSpec>,
    /// Whether flusso may auto-create/extend the publication to cover every
    /// table the indexes read. Defaults to `true`; a CLI flag can override it
    /// per run. See [`crate`] docs and the publication-management design.
    #[serde(default = "default_manage_publication")]
    pub manage_publication: bool,
}

/// Publication management is on unless explicitly disabled — and a default keeps
/// older compiled locks (written before this field existed) deserializing.
fn default_manage_publication() -> bool {
    true
}

impl Source {
    /// Resolve the connection URL now, in the current environment, applying the
    /// `DATABASE_URL` deployment override. Call this at connect time, not at
    /// load time, so the value is read where the pipeline runs.
    pub fn resolve_connection_url(&self) -> Result<ConnectionUrl, ResolveError> {
        resolve_connection_url(self.connection.as_ref())
    }
}