@@ -3,3 +3,3 @@
   "crates/app",
   "crates/eval",
-  "crates/ir",
+  "crates/ir", "crates/prowocessing",

@@ -25,2 +16,2 @@
-        let config = if let Some(config) = args.config_path {
-            Ok(config)
+    pub fn read(args: &CliConfigs) -> Self {
+        let config = if let Some(config) = &args.config_path {

@@ -12,0 +27,4 @@
+    },
+    Dev {
+        #[command(subcommand)]
+        dev_command: DevCommands,

@@ -27,0 +85,4 @@
+                    let pipe = PipelineBuilder::new().add(1).stringify().build();
+                    println!(
+                        "{:?}",
+                        pipe.run(vec![num0.into(), num1.into()].into()).into_inner()[0]

@@ -0,0 +1,7 @@
+//! Definitions of the data transfer and storage types.
+
+/// Types for element and pipeline IO

@@ -0,0 +3,4 @@
+/// Types for element and pipeline IO
+pub mod io;
+
+/// Raw data types contained in `io`

@@ -0,0 +4,4 @@
+pub struct Inputs<'a>(Vec<Data<'a>>);
+
+impl<'a> Inputs<'a> {
+    /// get inner value(s)

@@ -0,0 +24,4 @@
+
+impl<'a> From<&'a Outputs> for Inputs<'a> {
+    fn from(value: &'a Outputs) -> Self {
+        Self(value.0.iter().map(std::convert::Into::into).collect())

@@ -0,0 +28,4 @@
+    }
+}
+
+/// Newtype struct around `OwnedData` for pipeline/element outputs

@@ -0,0 +33,4 @@
+
+impl Outputs {
+    /// consume self and return inner value(s)
+    pub fn into_inner(self) -> Vec<OwnedData> {

@@ -0,0 +2,4 @@
+
+/// Owned data type, for use mostly in outputs and storage
+#[derive(Clone, Debug)]
+pub enum OwnedData {

@@ -0,0 +20,4 @@
+}
+
+/// Unowned data type, for inputs into runner functions
+#[derive(Clone, Copy)]

@@ -0,0 +28,4 @@
+
+impl Data<'_> {
+    /// converts itself to `OwnedData`
+    pub fn to_owned_data(&self) -> OwnedData {

@@ -0,0 +5,4 @@
+use super::data::io::Outputs;
+
+pub(crate) trait PipelineElement {
+    /// return a static runner function pointer to avoid dynamic dispatch during pipeline execution - Types MUST match the signature

@@ -0,0 +10,4 @@
+};
+
+/// Addition
+pub struct Add(pub i32);

@@ -0,0 +68,4 @@
+            outputs: vec![DataType::String],
+        }
+    }
+}

@@ -0,0 +7,4 @@
+/// TODO:
+/// - Bind additional inputs if instruction has more then one and is passd without any additional
+/// - allow binding to pointers to other pipelines?
+/// - allow referencing earlier data

@@ -0,0 +90,4 @@
+
+/// Runnable pipeline - at the core of this library
+pub struct Pipeline {
+    runners: Vec<fn(&Inputs) -> Outputs>,