Struct Source 

pub struct Source {
    pub source_type: SourceType,
    pub connection: Option<ConnectionSpec>,
    pub manage_publication: bool,
}

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, so a compiled config carries no secret it wasn’t given literally.

Fields

source_type: SourceType

connection: Option<ConnectionSpec>

How to reach the database. None means “rely entirely on DATABASE_URL”, checked when the connection is resolved.

manage_publication: bool

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.

Implementations

impl Source

pub fn resolve_connection_url(&self) -> Result<ConnectionUrl, ResolveError>

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.

Trait Implementations

impl Clone for Source

fn clone(&self) -> Source

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Source

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Source

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Source

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.