pub struct SubscriptionManager { /* private fields */ }Expand description
Subscription manager for tracking active subscriptions.
Implementations§
Source§impl SubscriptionManager
impl SubscriptionManager
Sourcepub async fn create_subscription(
&self,
session_id: SessionId,
query_name: impl Into<String>,
args: Value,
) -> Result<SubscriptionInfo>
pub async fn create_subscription( &self, session_id: SessionId, query_name: impl Into<String>, args: Value, ) -> Result<SubscriptionInfo>
Create a new subscription.
Sourcepub async fn get_subscription(
&self,
subscription_id: SubscriptionId,
) -> Option<SubscriptionInfo>
pub async fn get_subscription( &self, subscription_id: SubscriptionId, ) -> Option<SubscriptionInfo>
Get a subscription by ID.
Sourcepub async fn update_subscription(
&self,
subscription_id: SubscriptionId,
read_set: ReadSet,
result_hash: String,
)
pub async fn update_subscription( &self, subscription_id: SubscriptionId, read_set: ReadSet, result_hash: String, )
Update a subscription after execution.
Sourcepub async fn remove_subscription(&self, subscription_id: SubscriptionId)
pub async fn remove_subscription(&self, subscription_id: SubscriptionId)
Remove a subscription.
Sourcepub async fn remove_session_subscriptions(&self, session_id: SessionId)
pub async fn remove_session_subscriptions(&self, session_id: SessionId)
Remove all subscriptions for a session.
Sourcepub async fn find_affected_subscriptions(
&self,
change: &Change,
) -> Vec<SubscriptionId>
pub async fn find_affected_subscriptions( &self, change: &Change, ) -> Vec<SubscriptionId>
Find subscriptions affected by a change.
Sourcepub async fn get_by_query_hash(&self, query_hash: &str) -> Vec<SubscriptionInfo>
pub async fn get_by_query_hash(&self, query_hash: &str) -> Vec<SubscriptionInfo>
Get subscriptions by query hash (for coalescing).
Auto Trait Implementations§
impl Freeze for SubscriptionManager
impl !RefUnwindSafe for SubscriptionManager
impl Send for SubscriptionManager
impl Sync for SubscriptionManager
impl Unpin for SubscriptionManager
impl !UnwindSafe for SubscriptionManager
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> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request