[−][src]Struct nakadi_types::subscription::SubscriptionInput
A struct to create a Subscription
.
This struct is intended for creating Subscription
s. Since the interface
for creating Subscription
s is slightly different from the actual entity this
special struct exists.
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>
Must be set if and only if an updating operation is performed(e.g. Auth)
owning_application: OwningApplication
event_types: EventTypeNames
consumer_group: Option<ConsumerGroup>
read_from: ReadFrom
Position to start reading events from.
Currently supported values:
- Begin - read from the oldest available event.
- End - read from the most recent offset.
- Cursors - read from cursors provided in initial_cursors property. Applied when the client starts reading from a subscription.
initial_cursors: Option<Vec<EventTypeCursor>>
List of cursors to start reading from.
This property is required when read_from
= ReadFrom::Cursors
.
The initial cursors should cover all partitions of subscription.
Clients will get events starting from next offset positions.
Implementations
impl SubscriptionInput
[src]
pub fn builder() -> SubscriptionInputBuilder
[src]
Trait Implementations
impl Clone for SubscriptionInput
[src]
pub fn clone(&self) -> SubscriptionInput
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for SubscriptionInput
[src]
impl Serialize for SubscriptionInput
[src]
Auto Trait Implementations
impl RefUnwindSafe for SubscriptionInput
impl Send for SubscriptionInput
impl Sync for SubscriptionInput
impl Unpin for SubscriptionInput
impl UnwindSafe for SubscriptionInput
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, 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>,