pub struct EventConsumerOptions {
pub batch_limit: u32,
pub in_flight_limit: u32,
pub lease_seconds: u64,
pub maximum_wait_nanos: u64,
}Expand description
Bounded pull/stream policy accepted by the public consumer service.
Fields§
§batch_limit: u32Maximum events in one response.
in_flight_limit: u32Maximum live leases for this consumer.
lease_seconds: u64Lease lifetime in seconds.
maximum_wait_nanos: u64Long-poll bound in nanoseconds.
Trait Implementations§
Source§impl Clone for EventConsumerOptions
impl Clone for EventConsumerOptions
Source§fn clone(&self) -> EventConsumerOptions
fn clone(&self) -> EventConsumerOptions
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 moreimpl Copy for EventConsumerOptions
Source§impl Debug for EventConsumerOptions
impl Debug for EventConsumerOptions
Source§impl Default for EventConsumerOptions
impl Default for EventConsumerOptions
impl Eq for EventConsumerOptions
Source§impl PartialEq for EventConsumerOptions
impl PartialEq for EventConsumerOptions
Source§fn eq(&self, other: &EventConsumerOptions) -> bool
fn eq(&self, other: &EventConsumerOptions) -> bool
Tests for
self and other values to be equal, and is used by ==.impl StructuralPartialEq for EventConsumerOptions
Auto Trait Implementations§
impl Freeze for EventConsumerOptions
impl RefUnwindSafe for EventConsumerOptions
impl Send for EventConsumerOptions
impl Sync for EventConsumerOptions
impl Unpin for EventConsumerOptions
impl UnsafeUnpin for EventConsumerOptions
impl UnwindSafe for EventConsumerOptions
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<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].