pub enum RealtimeMessage {
Subscribe {
id: String,
query: String,
args: Value,
},
Unsubscribe {
subscription_id: SubscriptionId,
},
Ping,
Pong,
Data {
subscription_id: String,
data: Value,
},
DeltaUpdate {
subscription_id: String,
delta: Delta<Value>,
},
JobUpdate {
client_sub_id: String,
job: JobData,
},
WorkflowUpdate {
client_sub_id: String,
workflow: WorkflowData,
},
Error {
code: String,
message: String,
},
ErrorWithId {
id: String,
code: String,
message: String,
},
AuthSuccess,
AuthFailed {
reason: String,
},
}Expand description
Message types for real-time communication.
Variants§
Subscribe
Subscribe to a query.
Unsubscribe
Unsubscribe from a subscription.
Fields
§
subscription_id: SubscriptionIdPing
Ping for keepalive.
Pong
Pong response.
Data
Initial data for subscription.
DeltaUpdate
Delta update for subscription.
JobUpdate
Job progress update.
WorkflowUpdate
Workflow progress update.
Error
Error message.
ErrorWithId
Error message with subscription ID.
AuthSuccess
Authentication successful.
AuthFailed
Authentication failed.
Trait Implementations§
Source§impl Clone for RealtimeMessage
impl Clone for RealtimeMessage
Source§fn clone(&self) -> RealtimeMessage
fn clone(&self) -> RealtimeMessage
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for RealtimeMessage
impl RefUnwindSafe for RealtimeMessage
impl Send for RealtimeMessage
impl Sync for RealtimeMessage
impl Unpin for RealtimeMessage
impl UnwindSafe for RealtimeMessage
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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