Struct PipelineBundle 

pub struct PipelineBundle { /* private fields */ }

Root directory for a fixture bundle (tests/fixtures/ghcn, etc.).

Implementations

impl PipelineBundle

pub fn from_repo_fixture(name: &str) -> Self

Bundle rooted at tests/fixtures/<name> under the repository (via CARGO_MANIFEST_DIR).

pub fn from_root(root: impl AsRef<Path>) -> Self

Bundle with an explicit filesystem root (JVM tests pass tests/fixtures/ghcn).

pub fn root(&self) -> &Path

pub fn load_schema(&self, rel: &str) -> IngestionResult<Schema>

Load a serde Schema from rel (e.g. schemas/json_source.schema.json).

pub fn expect_schema(&self, rel: &str) -> Schema

Like Self::load_schema, but panics with bundle path context (integration tests).

pub fn resolve_pipeline_json( &self, pipeline_rel: &str, bindings: &HashMap<String, String>, ) -> IngestionResult<String>

Load a pipeline template, expand *_ref schema pointers, substitute {{KEY}} placeholders.

pub fn resolve_payload_json( &self, payload_rel: &str, bindings: &HashMap<String, String>, ) -> IngestionResult<String>

Load an rdp_ingest_ordered_paths_json (or similar) payload template.

pub fn schema_json(&self, schema_rel: &str) -> IngestionResult<String>

Schema JSON string for path ingest FFI (rdp_ingest_xml_path, etc.).

pub fn pipeline_transform_sql( &self, pipeline_rel: &str, ) -> IngestionResult<String>

Polars SQL from a pipeline template (transform.sql), e.g. SQLQueries.java / pytest parity.

pub fn load_query_sql(&self, query_rel: &str) -> IngestionResult<String>

SQL text from queries/*.sql.json ({ "sql": "..." }), e.g. sql_parity JOIN fixtures.

Trait Implementations

impl Clone for PipelineBundle

fn clone(&self) -> PipelineBundle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineBundle

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

Formats the value using the given formatter.