Add parser for configurable workload

Cargo.toml

@@ -26,3 +26,5 @@ aya-obj = "0.2.1"
 caps = "0.5.5"
 io-uring = "0.7.10"
 enum_dispatch = "0.3.13"
+pest = "2.8.1"
+pest_derive = "2.8.1"

src/script/ast.rs

@@ -0,0 +1,46 @@
+use std::collections::HashMap;
+
+#[derive(Debug, Clone, PartialEq)]
+pub enum Arg {
+    /// Simple constant
+    Const { text: String },
+
+    /// Variable available at runtime
+    Var { name: String },
+
+    /// Helper like random_path
+    Dynamic { name: String, args: Vec<Arg> },
+}
+
+#[derive(Debug, Clone, PartialEq)]
+pub enum Instruction {
+    Task { name: Arg, args: Vec<Arg> },
+    Open { path: Arg },
+    Debug { text: Arg },
+    Ping { server: Arg },
+}
+
+#[derive(Debug, Clone, PartialEq)]
+pub enum MachineInstruction {
+    Server { port: u16 },
+    Profile { target: String },
+    Path { value: String },
+}
+
+#[derive(Debug, Clone, PartialEq)]
+pub enum Dist {
+    Exp { rate: f64 },
+}
+
+#[derive(Debug, Clone)]
+pub enum Node {
+    Machine {
+        m_instructions: Vec<MachineInstruction>,
+    },
+    Work {
+        name: String,
+        args: HashMap<String, String>,
+        instructions: Vec<Instruction>,
+        dist: Option<Dist>,
+    },
+}

src/script/grammar.peg

@@ -0,0 +1,102 @@
+WHITESPACE = _{" " | "\t" | NEWLINE}
+COMMENT = _{"//" ~ (!NEWLINE ~ ANY)*}
+
+ident_char = {ASCII_ALPHA | "_" | "$"}
+ident = @{ident_char ~ (ASCII_DIGIT | ident_char)*}
+
+constant = {
+    "\"" ~ value ~ "\""
+  | ASCII_DIGIT*
+}
+
+randomPath = { "random_path" }
+randomString = { "random_string" }
+
+dynamicName = {
+    randomPath
+  | randomString
+}
+
+dynamic = {dynamicName ~ args}
+
+// constant should be the last
+arg = {
+    dynamic
+  | ident
+  | constant
+}
+
+args = {"(" ~ (arg ~ ("," ~ arg)* ~ ","?)? ~ ")"}
+value = {(ASCII_ALPHANUMERIC| "." | " " | "/" | ":")*}
+
+param = {ident ~ "=" ~ value}
+params = {"(" ~ (param ~ ("," ~ param)* ~ ","?)? ~ ")"}
+
+task = { "task" }
+network = { "network" }
+port = { "port" }
+open = { "open" }
+ping = { "ping" }
+debug = { "debug" }
+
+funcName = {
+    task
+  | network
+  | port
+  | open
+  | ping
+  | debug
+}
+
+exp = { "exp" }
+zipf = { "zipf" }
+uniform = { "uniform" }
+
+distName = {
+    exp
+  | zipf
+  | uniform
+}
+
+expr = {
+    function
+  | instruction
+}
+
+opt = {ident ~ "=" ~ value ~ ";" }
+
+dist = {":" ~ distName ~ "{" ~ opt* ~ "}"}
+
+work = {ident ~ params?}
+
+instruction = {funcName ~ args? ~ ";"}
+
+instructions = { expr* }
+
+function = {
+    work
+    ~ "{" ~ instructions ~ "}"
+    ~ dist?
+}
+
+server = { "server" }
+load = { "load" }
+memory = { "memory" }
+profile = { "profile" }
+path = { "path" }
+
+mInstrName = {
+    server
+  | load
+  | memory
+  | profile
+  | path
+}
+
+machineInstruction = {mInstrName ~ args? ~ ";"}
+
+machine = {"machine" ~ "{" ~ machineInstruction* ~ "}"}
+
+file = {
+    SOI ~ machine? ~ (expr*) ~ EOI
+}

src/script/mod.rs

@@ -0,0 +1,3 @@
+pub mod ast;
+pub mod parser;
+pub mod rules;