pub struct ContinuousQueryManager { /* private fields */ }Expand description
Continuous query manager
Implementations§
Source§impl ContinuousQueryManager
impl ContinuousQueryManager
Sourcepub async fn new(
store: Arc<dyn RdfStore>,
config: QueryManagerConfig,
) -> Result<Self>
pub async fn new( store: Arc<dyn RdfStore>, config: QueryManagerConfig, ) -> Result<Self>
Create a new continuous query manager
Sourcepub async fn register_query(
&self,
query: String,
metadata: QueryMetadata,
channel: QueryResultChannel,
) -> Result<String>
pub async fn register_query( &self, query: String, metadata: QueryMetadata, channel: QueryResultChannel, ) -> Result<String>
Register a continuous query
Sourcepub async fn unregister_query(&self, query_id: &str) -> Result<()>
pub async fn unregister_query(&self, query_id: &str) -> Result<()>
Unregister a query
Sourcepub async fn pause_query(&self, query_id: &str) -> Result<()>
pub async fn pause_query(&self, query_id: &str) -> Result<()>
Pause a query
Sourcepub async fn resume_query(&self, query_id: &str) -> Result<()>
pub async fn resume_query(&self, query_id: &str) -> Result<()>
Resume a query
Sourcepub async fn register_subscription(
&self,
query: String,
metadata: QueryMetadata,
channel: QueryResultChannel,
) -> Result<String>
pub async fn register_subscription( &self, query: String, metadata: QueryMetadata, channel: QueryResultChannel, ) -> Result<String>
Register a SPARQL subscription query with enhanced syntax
Sourcepub async fn get_query_status(&self, query_id: &str) -> Result<QueryStatus>
pub async fn get_query_status(&self, query_id: &str) -> Result<QueryStatus>
Get query status
Sourcepub async fn list_queries(&self) -> Vec<QueryInfo>
pub async fn list_queries(&self) -> Vec<QueryInfo>
List all queries
Sourcepub async fn get_stats(&self) -> QueryManagerStats
pub async fn get_stats(&self) -> QueryManagerStats
Get manager statistics
Sourcepub fn subscribe(&self) -> Receiver<QueryEvent>
pub fn subscribe(&self) -> Receiver<QueryEvent>
Subscribe to query events
Auto Trait Implementations§
impl Freeze for ContinuousQueryManager
impl !RefUnwindSafe for ContinuousQueryManager
impl Send for ContinuousQueryManager
impl Sync for ContinuousQueryManager
impl Unpin for ContinuousQueryManager
impl !UnwindSafe for ContinuousQueryManager
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
Source§fn to_subset(&self) -> Option<SS>
fn to_subset(&self) -> Option<SS>
The inverse inclusion map: attempts to construct
self from the equivalent element of its
superset. Read moreSource§fn is_in_subset(&self) -> bool
fn is_in_subset(&self) -> bool
Checks if
self is actually part of its subset T (and can be converted to it).Source§fn to_subset_unchecked(&self) -> SS
fn to_subset_unchecked(&self) -> SS
Use with care! Same as
self.to_subset but without any property checks. Always succeeds.Source§fn from_subset(element: &SS) -> SP
fn from_subset(element: &SS) -> SP
The inclusion map: converts
self to the equivalent element of its superset.