[−][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]
pub fn clone(&self) -> SubscriptionInputBuilder
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for SubscriptionInputBuilder
[src]
impl Default for SubscriptionInputBuilder
[src]
pub fn default() -> SubscriptionInputBuilder
[src]
impl<'de> Deserialize<'de> for SubscriptionInputBuilder
[src]
pub 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,
pub 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.
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>,