Struct PipelineCompiler 

pub struct PipelineCompiler {
    config: CompiledConfig,
    names: NameRegistry,
}

The Pack Config Compiler transforms a parsed AST into runtime configuration.

Input is a CellstateAst built from a cstate.toml manifest and YAML fence blocks in Markdown prompt files. Use [compose_pack] to obtain the AST, then call PipelineCompiler::compile to produce a CompiledConfig.

Example

use cellstate_pipeline::{compose_pack, PackInput};
let output = compose_pack(PackInput { ... })?;
// output.config is the compiled runtime configuration

Fields

config: CompiledConfig

Current configuration being built

names: NameRegistry

Name registry for duplicate detection

Implementations

impl PipelineCompiler

pub fn new() -> Self

Create a new compiler instance.

pub fn compile(ast: &CellstateAst) -> CompileResult<CompiledConfig>

Compile an AST into a runtime configuration.

fn register_definition(&mut self, def: &Definition) -> CompileResult<()>

Register a definition’s name for duplicate detection.

fn compile_definition(&mut self, def: &Definition) -> CompileResult<()>

Compile a single definition.

fn compile_adapter(def: &AdapterDef) -> CompileResult<AdapterConfig>

Compile an adapter definition.

fn compile_memory(def: &MemoryDef) -> CompileResult<MemoryConfig>

Compile a memory definition.

fn compile_memory_type(mt: &MemoryType) -> CompileResult<MemoryCategory>

fn compile_field(def: &FieldDef) -> CompileResult<FieldConfig>

fn compile_field_security(sec: &FieldSecurity) -> CompiledFieldSecurity

fn compile_field_type(ft: &FieldType) -> CompileResult<FieldType>

fn compile_retention(ret: &Retention) -> CompileResult<TTL>

fn compile_lifecycle(lc: &Lifecycle) -> CompileResult<CompiledLifecycle>

fn compile_trigger(trigger: &Trigger) -> CompileResult<CompiledTrigger>

fn compile_action(action: &Action) -> CompileResult<CompiledAction>

fn compile_index(def: &IndexDef) -> CompileResult<IndexConfig>

fn compile_modifiers( modifiers: &[ModifierDef], ) -> CompileResult<MemoryModifiers>

fn compile_policy(def: &PolicyDef) -> CompileResult<PolicyConfig>

Compile a policy definition.

fn compile_policy_rule(rule: &PolicyRule) -> CompileResult<CompiledPolicyRule>

fn compile_injection(def: &InjectionDef) -> CompileResult<InjectionConfig>

Compile an injection definition.

fn compile_injection_mode( mode: &InjectionMode, ) -> CompileResult<CompiledInjectionMode>

fn compile_filter(expr: &FilterExpr) -> CompileResult<CompiledFilter>

fn compile_compare_op(op: &CompareOp) -> CompileResult<CompiledOperator>

fn compile_filter_value( value: &FilterValue, ) -> CompileResult<CompiledFilterValue>

fn compile_trajectory(def: &TrajectoryDef) -> CompileResult<TrajectoryConfig>

Compile a trajectory definition.

fn compile_agent(def: &AgentDef) -> CompileResult<AgentConfig>

Compile an agent definition.

fn compile_cache(def: &CacheDef) -> CompileResult<CacheConfig>

Compile a cache definition.

fn compile_freshness(def: &FreshnessDef) -> CompileResult<CompiledFreshness>

fn compile_provider(def: &ProviderDef) -> CompileResult<CompiledProviderConfig>

Compile a provider definition.

fn resolve_env_value(env: &EnvValue) -> CompileResult<String>

fn compile_evolution(def: &EvolutionDef) -> CompileResult<EvolutionConfig>

Compile an evolution definition.

fn compile_summarization_policy( def: &SummarizationPolicyDef, ) -> CompileResult<SummarizationPolicyConfig>

Compile a summarization policy definition.

fn compile_summarization_trigger( trigger: &SummarizationTriggerParsed, ) -> CompileResult<CompiledTrigger>

fn compile_abstraction_level( level: &AbstractionLevelParsed, ) -> CompileResult<CompiledAbstractionLevel>

fn parse_duration(s: &str) -> CompileResult<Duration>

Parse a duration string (e.g., “30s”, “5m”, “1h”, “24h”).

fn validate(&self) -> CompileResult<()>

Final validation pass - check cross-references.

Trait Implementations

impl Default for PipelineCompiler

fn default() -> Self

Returns the “default value” for a type.