Struct PipelineParser 

pub struct PipelineParser;

TOML pipeline parser

Implementations

impl PipelineParser

pub fn from_str(toml: &str) -> Result<PipelineDefinition, PipelineError>

Parse a pipeline definition from a TOML string.

Example

use stygian_graph::application::pipeline_parser::PipelineParser;

let def = PipelineParser::from_str(r#"
[[nodes]]
name = "n1"
service = "http"
"#).unwrap();

assert_eq!(def.nodes[0].name, "n1");

pub fn from_file(path: &str) -> Result<PipelineDefinition, PipelineError>

Load a pipeline definition from a TOML file on disk.

Applies template variables after loading.

Example

use stygian_graph::application::pipeline_parser::PipelineParser;

let def = PipelineParser::from_file("pipeline.toml").unwrap();
assert!(!def.nodes.is_empty());

pub fn from_figment_file( path: &str, ) -> Result<PipelineDefinition, PipelineError>

Load a pipeline definition using Figment layered configuration.

Layers (later overrides earlier):

1. TOML file at path
2. Environment variables with prefix STYGIAN_ (e.g. STYGIAN_NODES_0_URL)

Applies template variable expansion after loading.

Errors

Returns Err(PipelineError::FigmentError) if figment cannot extract the config, or Err(PipelineError::Io) if the file cannot be read.

Example

use stygian_graph::application::pipeline_parser::PipelineParser;

let def = PipelineParser::from_figment_file("pipeline.toml").unwrap();
assert!(!def.nodes.is_empty());