Struct actyx_sdk::service::SubscribeMonotonicRequest[−][src]

pub struct SubscribeMonotonicRequest {
    pub session: SessionId,
    pub query: Query,
    pub from: StartFrom,
}

Expand description

Subscribe to live updates as the Event Services receives or publishes new events, until the recipient would need to time travel

Time travel is defined as receiving an event that needs to be sorted earlier than an event that has already been received.

Send this request to retrieve an unbounded stream of events.

Fields

session: SessionId

This id uniquely identifies one particular session. Connecting again with this SessionId shall only be done after a TimeTravel message has been received. The subscription is stored with the Session and all previous state is destroyed upon receiving a different subscription for this session.

query: Query

Definition of the events to be received by this session, i.e. a selection of tags coupled with other flags like “isLocal”.

from: StartFrom

The consumer may already have kept state and know at which point to resume a previously interrupted stream. In this case, StartFrom::Offsets is used, otherwise StartFrom::Snapshot indicates that the PondService shall figure out where best to start out from, possibly sending a State message first.

Struct actyx_sdk::service::SubscribeMonotonicRequest[−][src]

Fields

Trait Implementations

impl Clone for SubscribeMonotonicRequest

fn clone(&self) -> SubscribeMonotonicRequest

fn clone_from(&mut self, source: &Self)

impl Debug for SubscribeMonotonicRequest

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl<'de> Deserialize<'de> for SubscribeMonotonicRequest

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where __D: Deserializer<'de>,

impl PartialEq<SubscribeMonotonicRequest> for SubscribeMonotonicRequest

fn eq(&self, other: &SubscribeMonotonicRequest) -> bool

fn ne(&self, other: &SubscribeMonotonicRequest) -> bool

impl Serialize for SubscribeMonotonicRequest

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where __S: Serializer,

impl StructuralPartialEq for SubscribeMonotonicRequest

Auto Trait Implementations

impl !RefUnwindSafe for SubscribeMonotonicRequest

impl Send for SubscribeMonotonicRequest

impl Sync for SubscribeMonotonicRequest

impl Unpin for SubscribeMonotonicRequest

impl !UnwindSafe for SubscribeMonotonicRequest

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Az for T

pub fn az<Dst>(self) -> Dst where T: Cast<Dst>,

impl<T> Borrow<T> for T where T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<Src, Dst> CastFrom<Src> for Dst where Src: Cast<Dst>,

pub fn cast_from(src: Src) -> Dst

impl<T> CheckedAs for T

pub fn checked_as<Dst>(self) -> Option<Dst> where T: CheckedCast<Dst>,

impl<Src, Dst> CheckedCastFrom<Src> for Dst where Src: CheckedCast<Dst>,

pub fn checked_cast_from(src: Src) -> Option<Dst>

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for T where U: From<T>,

pub fn into(self) -> U

impl<Src, Dst> LosslessTryInto<Dst> for Src where Dst: LosslessTryFrom<Src>,

pub fn lossless_try_into(self) -> Option<Dst>

impl<Src, Dst> LossyInto<Dst> for Src where Dst: LossyFrom<Src>,

pub fn lossy_into(self) -> Dst

impl<T> OverflowingAs for T

pub fn overflowing_as<Dst>(self) -> (Dst, bool) where T: OverflowingCast<Dst>,

impl<Src, Dst> OverflowingCastFrom<Src> for Dst where Src: OverflowingCast<Dst>,

pub fn overflowing_cast_from(src: Src) -> (Dst, bool)

impl<T> References<RawCodec> for T

pub fn references<R, E>( _c: RawCodec, _r: &mut R, _set: &mut E) -> Result<(), Error> where R: Read, E: Extend<Cid<UInt<UInt<UInt<UInt<UInt<UInt<UInt<UTerm, B1>, B0>, B0>, B0>, B0>, B0>, B0>>>,

impl<T> Same<T> for T

type Output = T

impl<T> SaturatingAs for T

pub fn saturating_as<Dst>(self) -> Dst where T: SaturatingCast<Dst>,

impl<Src, Dst> SaturatingCastFrom<Src> for Dst where Src: SaturatingCast<Dst>,

pub fn saturating_cast_from(src: Src) -> Dst

impl<T> ToOwned for T where T: Clone,

type Owned = T

pub fn to_owned(&self) -> T

pub fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> UnwrappedAs for T

pub fn unwrapped_as<Dst>(self) -> Dst where T: UnwrappedCast<Dst>,

impl<Src, Dst> UnwrappedCastFrom<Src> for Dst where Src: UnwrappedCast<Dst>,

pub fn unwrapped_cast_from(src: Src) -> Dst

impl<V, T> VZip<V> for T where V: MultiLane<T>,

pub fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

impl<T> WrappingAs for T

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error> where
__D: Deserializer<'de>,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error> where
S: Serializer,

impl<T> Any for T where
T: 'static + ?Sized,

pub fn az<Dst>(self) -> Dst where
T: Cast<Dst>,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<Src, Dst> CastFrom<Src> for Dst where
Src: Cast<Dst>,

pub fn checked_as<Dst>(self) -> Option<Dst> where
T: CheckedCast<Dst>,

impl<Src, Dst> CheckedCastFrom<Src> for Dst where
Src: CheckedCast<Dst>,

impl<T, U> Into<U> for T where
U: From<T>,

impl<Src, Dst> LosslessTryInto<Dst> for Src where
Dst: LosslessTryFrom<Src>,

impl<Src, Dst> LossyInto<Dst> for Src where
Dst: LossyFrom<Src>,

pub fn overflowing_as<Dst>(self) -> (Dst, bool ) where
T: OverflowingCast<Dst>,

impl<Src, Dst> OverflowingCastFrom<Src> for Dst where
Src: OverflowingCast<Dst>,

pub fn overflowing_cast_from(src: Src) -> (Dst, bool )

pub fn references<R, E>(
_c: RawCodec,
_r: &mut R,
_set: &mut E
) -> Result<(), Error> where
R: Read,
E: Extend<Cid<UInt<UInt<UInt<UInt<UInt<UInt<UInt<UTerm, B1>, B0>, B0>, B0>, B0>, B0>, B0>>>,

pub fn saturating_as<Dst>(self) -> Dst where
T: SaturatingCast<Dst>,

impl<Src, Dst> SaturatingCastFrom<Src> for Dst where
Src: SaturatingCast<Dst>,

impl<T> ToOwned for T where
T: Clone,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

pub fn unwrapped_as<Dst>(self) -> Dst where
T: UnwrappedCast<Dst>,

impl<Src, Dst> UnwrappedCastFrom<Src> for Dst where
Src: UnwrappedCast<Dst>,

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

pub fn wrapping_as<Dst>(self) -> Dst where
T: WrappingCast<Dst>,

impl<Src, Dst> WrappingCastFrom<Src> for Dst where
Src: WrappingCast<Dst>,

impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,