Struct dendrite::axon_server::event::GetEventsRequest [−][src]
Request message to open an Event Stream from the Event Store.
Fields
tracking_token: i64
The token to start streaming from
number_of_permits: i64
The number of messages the server may send before it needs to wait for more permits
client_id: String
The unique identifier of this client instance. Used for monitoring.
component_name: String
The component name of this client instance. Used for monitoring.
processor: String
The name of the processor requesting this stream. Used for monitoring.
blacklist: Vec<PayloadDescription>
An enumeration of payload types that need to be blacklisted. The Server will stop sending messages of these types in order to reduce I/O. Note that the Server may occasionally send a blacklisted message to prevent time-outs and stale tokens on clients.
force_read_from_leader: bool
Indicates whether to force reading events from the leader node of an Axon Server. Forcing reads from leader reduces the staleness of the data read, but also puts extra burden on the leader, reducing overall scalability.
This property has no effect on connections to AxonServer SE.
Trait Implementations
impl Clone for GetEventsRequest
[src]
fn clone(&self) -> GetEventsRequest
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for GetEventsRequest
[src]
impl Default for GetEventsRequest
[src]
impl Message for GetEventsRequest
[src]
fn encode_raw<B>(&self, buf: &mut B) where
B: BufMut,
[src]
B: BufMut,
fn merge_field<B>(
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
[src]
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
fn encoded_len(&self) -> usize
[src]
fn clear(&mut self)
[src]
pub fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
[src]
B: BufMut,
pub fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
[src]
B: BufMut,
pub fn decode<B>(buf: B) -> Result<Self, DecodeError> where
Self: Default,
B: Buf,
[src]
Self: Default,
B: Buf,
pub fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
Self: Default,
B: Buf,
[src]
Self: Default,
B: Buf,
pub fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
[src]
B: Buf,
pub fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
[src]
B: Buf,
impl PartialEq<GetEventsRequest> for GetEventsRequest
[src]
fn eq(&self, other: &GetEventsRequest) -> bool
[src]
fn ne(&self, other: &GetEventsRequest) -> bool
[src]
impl StructuralPartialEq for GetEventsRequest
[src]
Auto Trait Implementations
impl RefUnwindSafe for GetEventsRequest
impl Send for GetEventsRequest
impl Sync for GetEventsRequest
impl Unpin for GetEventsRequest
impl UnwindSafe for GetEventsRequest
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoRequest<T> for T
[src]
pub fn into_request(self) -> Request<T>
[src]
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
pub fn vzip(self) -> V
impl<T> VecU8Message for T where
T: Message,
[src]
T: Message,
impl<T> WithSubscriber for T
[src]
pub fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,