Struct ProjectionEngine 

pub struct ProjectionEngine<T: KeyValueStore> { /* private fields */ }

Main projection engine with generic KeyValueStore backend

Implementations

impl<T: KeyValueStore + 'static> ProjectionEngine<T>

pub fn new(config: ProjectionConfig, storage: Arc<T>) -> Self

Create a new projection engine with the given KeyValueStore backend

impl<T: KeyValueStore + 'static> ProjectionEngine<T>

pub async fn start(&self) -> Result<()>

Start the projection engine

pub async fn stop(&self) -> Result<()>

Stop the projection engine

pub async fn create_projection( &self, name: String, definition: ProjectionDefinition, ) -> Result<()>

Create a new projection

pub async fn delete_projection(&self, name: &str) -> Result<()>

Delete a projection

pub async fn get_projection_status( &self, name: &str, ) -> Result<Option<ProjectionState>>

Get projection status

pub async fn list_projections(&self) -> Vec<String>

List all projections

pub async fn process_ocel_events(&self, events: Vec<OcelEvent>) -> Result<()>

Process a batch of OCEL events

pub async fn process_events(&self, events: Vec<EventEnvelope>) -> Result<()>

Process a batch of events (legacy method)

pub async fn query_projections(&self, query: Value) -> Result<Value>

Query projections using storage backend

pub async fn query_view( &self, projection_name: &str, query: ViewQuery, ) -> Result<ViewResult>

Query a materialized view (legacy method)

pub async fn get_statistics(&self) -> EngineStatistics

Get engine statistics

pub async fn execute_gql_query( &self, query: &str, _user_id: Option<String>, _timeout_seconds: u64, _parameters: HashMap<String, Value>, ) -> Result<Value>

Execute GQL query (simplified implementation)

pub async fn execute_gql_statement( &self, statement: &str, _user_id: Option<String>, _timeout_seconds: u64, _parameters: HashMap<String, Value>, ) -> Result<Value>

Execute GQL statement (DDL/DML) (simplified implementation)

Trait Implementations

impl<T: KeyValueStore> Clone for ProjectionEngine<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.