Packages

condukt

0.15.1
1.7.0 1.6.3 1.6.2 1.6.1 1.6.0 1.5.1 1.5.0 1.4.1 1.4.0 1.3.0 1.2.1 1.2.0 1.1.0 1.0.0 0.21.0 0.20.0 0.19.0 0.18.0 0.17.0 0.16.6 0.16.5 0.16.4 0.16.3 0.16.2 0.16.1 0.16.0 0.15.1 0.15.0 0.14.2 0.14.1 0.14.0 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.7.2 0.7.1 0.7.0 0.6.1 0.6.0 0.5.0

A framework for building AI agents in Elixir

HexDocs

Current section

Files

Jump to
Readme
44 Versions
10 Dependencies
Dependants
Files
Activity
condukt native condukt_workflows src lib.rs
Raw

native/condukt_workflows/src/lib.rs 

//! Rustler NIF for Condukt workflows.

//!

//! The crate owns four dirty-scheduler entry points:

//!

//! * Starlark evaluation.

//! * Starlark parse-only validation.

//! * PubGrub dependency resolution.

//! * Deterministic content-addressed tree hashing.



use rustler::{Env, NifResult, Term};



use crate::errors::EncodeResult;



mod errors;

mod eval;

mod hash;

mod resolve;

mod terms;



pub(crate) mod atoms {

    rustler::atoms! {

        ok,

        error,

        parse_error,

        eval_error,

        no_solution,

        missing_load,

        invalid_url,

        invalid_version,

        io_error,

        not_found,

    }

}



#[rustler::nif(schedule = "DirtyCpu")]

fn eval<'a>(

    env: Env<'a>,

    source: String,

    filename: String,

    globals: Term<'a>,

) -> NifResult<Term<'a>> {

    Ok(eval::eval(source, filename, globals).encode(env))

}



#[rustler::nif(schedule = "DirtyCpu")]

fn parse_only<'a>(env: Env<'a>, source: String, filename: String) -> NifResult<Term<'a>> {

    Ok(eval::parse_only(source, filename).encode(env))

}



#[rustler::nif(schedule = "DirtyCpu")]

fn resolve<'a>(

    env: Env<'a>,

    root: String,

    requirements: Term<'a>,

    index: Term<'a>,

) -> NifResult<Term<'a>> {

    Ok(resolve::resolve(root, requirements, index).encode(env))

}



#[rustler::nif(schedule = "DirtyIo")]

fn sha256_tree<'a>(env: Env<'a>, root_dir: String) -> NifResult<Term<'a>> {

    Ok(hash::sha256_tree(root_dir).encode(env))

}



rustler::init!("Elixir.Condukt.Workflows.NIF");