Struct nakadi_types::subscription::SubscriptionInputBuilder

pub struct SubscriptionInputBuilder {
    pub id: Option<SubscriptionId>,
    pub owning_application: Option<OwningApplication>,
    pub event_types: Option<EventTypeNames>,
    pub consumer_group: Option<ConsumerGroup>,
    pub read_from: Option<ReadFrom>,
    pub initial_cursors: Option<Vec<EventTypeCursor>>,
    pub authorization: Option<SubscriptionAuthorization>,
}

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>>

authorization: Option<SubscriptionAuthorization>

Implementations

impl SubscriptionInputBuilder

pub fn id<T: Into<SubscriptionId>>(self, id: T) -> Self

pub fn owning_application<T: Into<OwningApplication>>(
    self,
    owning_application: T
) -> Self

pub fn event_types<T: Into<EventTypeNames>>(self, event_types: T) -> Self

pub fn consumer_group<T: Into<ConsumerGroup>>(self, consumer_group: T) -> Self

pub fn read_from(self, read_from: ReadFrom) -> Self

pub fn initial_cursors(self, initial_cursors: Vec<EventTypeCursor>) -> Self

pub fn authorization<T: Into<SubscriptionAuthorization>>(
    self,
    authorization: T
) -> Self

pub fn finish_for_create(self) -> Result<SubscriptionInput, Error>

pub fn finish_for_update(self) -> Result<SubscriptionInput, Error>

Trait Implementations

impl Clone for SubscriptionInputBuilder

pub fn clone(&self) -> SubscriptionInputBuilder

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SubscriptionInputBuilder

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SubscriptionInputBuilder

pub fn default() -> SubscriptionInputBuilder

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for SubscriptionInputBuilder

pub fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Serialize for SubscriptionInputBuilder

pub fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.