Struct nakadi_types::model::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<SubscriptionCursorWithoutToken>>,
    pub authorization: Option<SubscriptionAuthorization>,
}

Fields

id: Option<SubscriptionId>

owning_application: Option<OwningApplication>

event_types: Option<EventTypeNames>

consumer_group: Option<ConsumerGroup>

read_from: Option<ReadFrom>

initial_cursors: Option<Vec<SubscriptionCursorWithoutToken>>

authorization: Option<SubscriptionAuthorization>

Methods

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

fn clone(&self) -> SubscriptionInputBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionInputBuilder

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Default for SubscriptionInputBuilder

fn default() -> SubscriptionInputBuilder

Returns the "default value" for a type.

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

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

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

Serialize this value into the given Serde serializer.