pub struct SubscriptionEvent {
pub id: i64,
pub subscription_id: String,
pub correlation_id: String,
pub event_type: String,
pub payload: String,
pub delivered_at: String,
pub delivery_status: String,
}Expand description
One row of the subscription_events per-delivery audit log. K6
writes one row before each network send; K7’s
memory_subscription_replay tool reads the rows back ordered by
delivered_at for replay-from-cursor support.
Fields§
§id: i64§subscription_id: String§correlation_id: String§event_type: String§payload: String§delivered_at: String§delivery_status: StringTrait Implementations§
Source§impl Clone for SubscriptionEvent
impl Clone for SubscriptionEvent
Source§fn clone(&self) -> SubscriptionEvent
fn clone(&self) -> SubscriptionEvent
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for SubscriptionEvent
impl Debug for SubscriptionEvent
Source§impl<'de> Deserialize<'de> for SubscriptionEvent
impl<'de> Deserialize<'de> for SubscriptionEvent
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for SubscriptionEvent
impl RefUnwindSafe for SubscriptionEvent
impl Send for SubscriptionEvent
impl Sync for SubscriptionEvent
impl Unpin for SubscriptionEvent
impl UnsafeUnpin for SubscriptionEvent
impl UnwindSafe for SubscriptionEvent
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,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
impl<T> ErasedDestructor for Twhere
T: 'static,
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 more