Struct RspProcessor 

pub struct RspProcessor { /* private fields */ }

RSP query parser and processor

Implementations

impl RspProcessor

pub async fn new( store: Arc<dyn RdfStore>, query_manager: Arc<ContinuousQueryManager>, config: RspConfig, ) -> Result<Self>

Create a new RSP processor

pub async fn register_stream(&self, descriptor: StreamDescriptor) -> Result<()>

Register a stream

pub async fn unregister_stream(&self, uri: &str) -> Result<()>

Unregister a stream

pub fn parse_query(&self, query: &str) -> Result<RspQuery>

Parse an RSP query

pub async fn execute_query( &self, query: &str, channel: QueryResultChannel, ) -> Result<String>

Register and execute an RSP query

pub async fn process_event( &self, stream_uri: &str, event: &StreamEvent, ) -> Result<()>

Process a stream event (add to windows)

pub fn detect_language(&self, query: &str) -> Result<RspLanguage>

Detect RSP query language

pub fn parse_duration_string(&self, s: &str) -> Result<ChronoDuration>

Parse duration string (e.g., “5m”, “1h”, “30s”)

pub async fn get_window_stats(&self, stream_uri: &str) -> Option<WindowStats>

Get window statistics

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

List registered streams