Struct Executor 

pub struct Executor {
    pub filter_executor: FilterExecutor,
    /* private fields */
}

Main executor for dsq operations

Fields

filter_executor: FilterExecutor

Implementations

impl Executor

pub fn new(config: Config) -> Self

Create a new executor with the given configuration

pub async fn execute_filter( &mut self, filter: &str, input_path: Option<&Path>, output_path: Option<&Path>, ) -> Result<()>

Execute a filter on input data

pub async fn execute_filter_on_value( &mut self, filter: &str, input_value: Value, output_path: Option<&Path>, ) -> Result<()>

Execute a filter on a value directly

pub fn validate_filter(&self, filter: &str) -> Result<()>

Validate that a filter is syntactically correct

pub fn explain_filter(&self, filter: &str) -> Result<String>

Explain what a filter does

pub async fn read_input(&self, path: &Path) -> Result<Value>

Read input from a file path

pub fn write_to_stdout(&self, value: &Value) -> Result<()>

Write output to stdout