[−][src]Enum nakadion::handler::HandlerAssignment
Defines what a BatchHandler
will receive.
This value should the same for the whole lifetime of the
BatchHandler
. "Should" because in the end it is the
BatchHandlerFactory
which returns BatchHandler
s. But it
is guaranteed that Nakadion
will only pass events to a BatchHandler
as defined by the DispatchStrategy
.
Variants
Everything can be passed to the BatchHandler
.
EventType(EventTypeName)
The BatchHandler
will only receive events
of the given event type but from any partition.
EventTypePartition(EventTypePartition)
The BatchHandler
will only receive events
of the given event type on the given partition.
Implementations
impl HandlerAssignment
[src]
pub fn event_type(&self) -> Option<&EventTypeName>
[src]
pub fn partition(&self) -> Option<&PartitionId>
[src]
pub fn event_type_and_partition(
&self
) -> (Option<&EventTypeName>, Option<&PartitionId>)
[src]
&self
) -> (Option<&EventTypeName>, Option<&PartitionId>)
pub fn into_event_type_and_partition(
self
) -> (Option<EventTypeName>, Option<PartitionId>)
[src]
self
) -> (Option<EventTypeName>, Option<PartitionId>)
Trait Implementations
impl Clone for HandlerAssignment
[src]
fn clone(&self) -> HandlerAssignment
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for HandlerAssignment
[src]
impl Display for HandlerAssignment
[src]
impl Eq for HandlerAssignment
[src]
impl PartialEq<HandlerAssignment> for HandlerAssignment
[src]
fn eq(&self, other: &HandlerAssignment) -> bool
[src]
fn ne(&self, other: &HandlerAssignment) -> bool
[src]
impl StructuralEq for HandlerAssignment
[src]
impl StructuralPartialEq for HandlerAssignment
[src]
Auto Trait Implementations
impl RefUnwindSafe for HandlerAssignment
impl Send for HandlerAssignment
impl Sync for HandlerAssignment
impl Unpin for HandlerAssignment
impl UnwindSafe for HandlerAssignment
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,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<Q, K> Equivalent<K> for Q where
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
[src]
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
fn equivalent(&self, key: &K) -> bool
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> SendSyncUnwindSafe for T where
T: Send + Sync + UnwindSafe + ?Sized,
T: Send + Sync + UnwindSafe + ?Sized,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T> ToString for T where
T: Display + ?Sized,
[src]
T: Display + ?Sized,
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.
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.
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>,