[−][src]Struct nakadi_types::subscription::SubscriptionInputBuilder
A builder for creating a SubscriptionInput
Subscription
Subscription is a high level consumption unit.
Subscriptions allow applications to easily scale the number of clients by managing consumed event offsets and distributing load between instances. The key properties that identify subscription are ‘owning_application’, ‘event_types’ and ‘consumer_group’. It’s not possible to have two different subscriptions with these properties being the same.
See also Nakadi Manual
Fields
id: Option<SubscriptionId>
owning_application: Option<OwningApplication>
event_types: Option<EventTypeNames>
consumer_group: Option<ConsumerGroup>
read_from: Option<ReadFrom>
initial_cursors: Option<Vec<EventTypeCursor>>
Implementations
impl SubscriptionInputBuilder
[src]
pub fn id<T: Into<SubscriptionId>>(self, id: T) -> Self
[src]
pub fn owning_application<T: Into<OwningApplication>>(
self,
owning_application: T
) -> Self
[src]
self,
owning_application: T
) -> Self
pub fn event_types<T: Into<EventTypeNames>>(self, event_types: T) -> Self
[src]
pub fn consumer_group<T: Into<ConsumerGroup>>(self, consumer_group: T) -> Self
[src]
pub fn read_from(self, read_from: ReadFrom) -> Self
[src]
pub fn initial_cursors(self, initial_cursors: Vec<EventTypeCursor>) -> Self
[src]
pub fn authorization<T: Into<SubscriptionAuthorization>>(
self,
authorization: T
) -> Self
[src]
self,
authorization: T
) -> Self
pub fn finish_for_create(self) -> Result<SubscriptionInput, Error>
[src]
pub fn finish_for_update(self) -> Result<SubscriptionInput, Error>
[src]
Trait Implementations
impl Clone for SubscriptionInputBuilder
[src]
fn clone(&self) -> SubscriptionInputBuilder
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for SubscriptionInputBuilder
[src]
impl Default for SubscriptionInputBuilder
[src]
fn default() -> SubscriptionInputBuilder
[src]
impl<'de> Deserialize<'de> for SubscriptionInputBuilder
[src]
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Serialize for SubscriptionInputBuilder
[src]
Auto Trait Implementations
impl RefUnwindSafe for SubscriptionInputBuilder
impl Send for SubscriptionInputBuilder
impl Sync for SubscriptionInputBuilder
impl Unpin for SubscriptionInputBuilder
impl UnwindSafe for SubscriptionInputBuilder
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<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
T: for<'de> Deserialize<'de>,
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
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, 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>,