pub struct StreamsAppBuilder<S: State = Empty> { /* private fields */ }Expand description
Use builder syntax to set the inputs and finish with build().
Implementations§
Source§impl<S: State> StreamsAppBuilder<S>
impl<S: State> StreamsAppBuilder<S>
Sourcepub fn build(self) -> StreamsAppwhere
S: IsComplete,
pub fn build(self) -> StreamsAppwhere
S: IsComplete,
Finishes building and performs the requested action.
Sourcepub fn bootstrap(
self,
value: impl Into<String>,
) -> StreamsAppBuilder<SetBootstrap<S>>where
S::Bootstrap: IsUnset,
pub fn bootstrap(
self,
value: impl Into<String>,
) -> StreamsAppBuilder<SetBootstrap<S>>where
S::Bootstrap: IsUnset,
Required.
Sourcepub fn application_id(
self,
value: impl Into<String>,
) -> StreamsAppBuilder<SetApplicationId<S>>where
S::ApplicationId: IsUnset,
pub fn application_id(
self,
value: impl Into<String>,
) -> StreamsAppBuilder<SetApplicationId<S>>where
S::ApplicationId: IsUnset,
Required.
Sourcepub fn schema_registry(
self,
value: impl Into<String>,
) -> StreamsAppBuilder<SetSchemaRegistry<S>>where
S::SchemaRegistry: IsUnset,
pub fn schema_registry(
self,
value: impl Into<String>,
) -> StreamsAppBuilder<SetSchemaRegistry<S>>where
S::SchemaRegistry: IsUnset,
Required.
Schema Registry base URL, e.g. http://localhost:8081.
Sourcepub fn cache_config(
self,
value: CacheConfig,
) -> StreamsAppBuilder<SetCacheConfig<S>>where
S::CacheConfig: IsUnset,
pub fn cache_config(
self,
value: CacheConfig,
) -> StreamsAppBuilder<SetCacheConfig<S>>where
S::CacheConfig: IsUnset,
Sourcepub fn maybe_cache_config(
self,
value: Option<CacheConfig>,
) -> StreamsAppBuilder<SetCacheConfig<S>>where
S::CacheConfig: IsUnset,
pub fn maybe_cache_config(
self,
value: Option<CacheConfig>,
) -> StreamsAppBuilder<SetCacheConfig<S>>where
S::CacheConfig: IsUnset,
Sourcepub fn store_backend(
self,
value: StoreBackend,
) -> StreamsAppBuilder<SetStoreBackend<S>>where
S::StoreBackend: IsUnset,
pub fn store_backend(
self,
value: StoreBackend,
) -> StreamsAppBuilder<SetStoreBackend<S>>where
S::StoreBackend: IsUnset,
Sourcepub fn maybe_store_backend(
self,
value: Option<StoreBackend>,
) -> StreamsAppBuilder<SetStoreBackend<S>>where
S::StoreBackend: IsUnset,
pub fn maybe_store_backend(
self,
value: Option<StoreBackend>,
) -> StreamsAppBuilder<SetStoreBackend<S>>where
S::StoreBackend: IsUnset,
Sourcepub fn processing_guarantee(
self,
value: ProcessingGuarantee,
) -> StreamsAppBuilder<SetProcessingGuarantee<S>>where
S::ProcessingGuarantee: IsUnset,
pub fn processing_guarantee(
self,
value: ProcessingGuarantee,
) -> StreamsAppBuilder<SetProcessingGuarantee<S>>where
S::ProcessingGuarantee: IsUnset,
Sourcepub fn maybe_processing_guarantee(
self,
value: Option<ProcessingGuarantee>,
) -> StreamsAppBuilder<SetProcessingGuarantee<S>>where
S::ProcessingGuarantee: IsUnset,
pub fn maybe_processing_guarantee(
self,
value: Option<ProcessingGuarantee>,
) -> StreamsAppBuilder<SetProcessingGuarantee<S>>where
S::ProcessingGuarantee: IsUnset,
Sourcepub fn poll_interval(
self,
value: StreamsPollInterval,
) -> StreamsAppBuilder<SetPollInterval<S>>where
S::PollInterval: IsUnset,
pub fn poll_interval(
self,
value: StreamsPollInterval,
) -> StreamsAppBuilder<SetPollInterval<S>>where
S::PollInterval: IsUnset,
Sourcepub fn maybe_poll_interval(
self,
value: Option<StreamsPollInterval>,
) -> StreamsAppBuilder<SetPollInterval<S>>where
S::PollInterval: IsUnset,
pub fn maybe_poll_interval(
self,
value: Option<StreamsPollInterval>,
) -> StreamsAppBuilder<SetPollInterval<S>>where
S::PollInterval: IsUnset,
Sourcepub fn commit_interval(
self,
value: StreamsCommitInterval,
) -> StreamsAppBuilder<SetCommitInterval<S>>where
S::CommitInterval: IsUnset,
pub fn commit_interval(
self,
value: StreamsCommitInterval,
) -> StreamsAppBuilder<SetCommitInterval<S>>where
S::CommitInterval: IsUnset,
Sourcepub fn maybe_commit_interval(
self,
value: Option<StreamsCommitInterval>,
) -> StreamsAppBuilder<SetCommitInterval<S>>where
S::CommitInterval: IsUnset,
pub fn maybe_commit_interval(
self,
value: Option<StreamsCommitInterval>,
) -> StreamsAppBuilder<SetCommitInterval<S>>where
S::CommitInterval: IsUnset,
Sourcepub fn rebalance_timeout(
self,
value: StreamsRebalanceTimeout,
) -> StreamsAppBuilder<SetRebalanceTimeout<S>>where
S::RebalanceTimeout: IsUnset,
pub fn rebalance_timeout(
self,
value: StreamsRebalanceTimeout,
) -> StreamsAppBuilder<SetRebalanceTimeout<S>>where
S::RebalanceTimeout: IsUnset,
Sourcepub fn maybe_rebalance_timeout(
self,
value: Option<StreamsRebalanceTimeout>,
) -> StreamsAppBuilder<SetRebalanceTimeout<S>>where
S::RebalanceTimeout: IsUnset,
pub fn maybe_rebalance_timeout(
self,
value: Option<StreamsRebalanceTimeout>,
) -> StreamsAppBuilder<SetRebalanceTimeout<S>>where
S::RebalanceTimeout: IsUnset,
Sourcepub fn join_retry_backoff(
self,
value: StreamsJoinRetryBackoff,
) -> StreamsAppBuilder<SetJoinRetryBackoff<S>>where
S::JoinRetryBackoff: IsUnset,
pub fn join_retry_backoff(
self,
value: StreamsJoinRetryBackoff,
) -> StreamsAppBuilder<SetJoinRetryBackoff<S>>where
S::JoinRetryBackoff: IsUnset,
Sourcepub fn maybe_join_retry_backoff(
self,
value: Option<StreamsJoinRetryBackoff>,
) -> StreamsAppBuilder<SetJoinRetryBackoff<S>>where
S::JoinRetryBackoff: IsUnset,
pub fn maybe_join_retry_backoff(
self,
value: Option<StreamsJoinRetryBackoff>,
) -> StreamsAppBuilder<SetJoinRetryBackoff<S>>where
S::JoinRetryBackoff: IsUnset,
Sourcepub fn leave_heartbeat_timeout(
self,
value: StreamsLeaveHeartbeatTimeout,
) -> StreamsAppBuilder<SetLeaveHeartbeatTimeout<S>>where
S::LeaveHeartbeatTimeout: IsUnset,
pub fn leave_heartbeat_timeout(
self,
value: StreamsLeaveHeartbeatTimeout,
) -> StreamsAppBuilder<SetLeaveHeartbeatTimeout<S>>where
S::LeaveHeartbeatTimeout: IsUnset,
Sourcepub fn maybe_leave_heartbeat_timeout(
self,
value: Option<StreamsLeaveHeartbeatTimeout>,
) -> StreamsAppBuilder<SetLeaveHeartbeatTimeout<S>>where
S::LeaveHeartbeatTimeout: IsUnset,
pub fn maybe_leave_heartbeat_timeout(
self,
value: Option<StreamsLeaveHeartbeatTimeout>,
) -> StreamsAppBuilder<SetLeaveHeartbeatTimeout<S>>where
S::LeaveHeartbeatTimeout: IsUnset,
Sourcepub fn broker_dns_timeout(
self,
value: ClientDnsTimeout,
) -> StreamsAppBuilder<SetBrokerDnsTimeout<S>>where
S::BrokerDnsTimeout: IsUnset,
pub fn broker_dns_timeout(
self,
value: ClientDnsTimeout,
) -> StreamsAppBuilder<SetBrokerDnsTimeout<S>>where
S::BrokerDnsTimeout: IsUnset,
Sourcepub fn maybe_broker_dns_timeout(
self,
value: Option<ClientDnsTimeout>,
) -> StreamsAppBuilder<SetBrokerDnsTimeout<S>>where
S::BrokerDnsTimeout: IsUnset,
pub fn maybe_broker_dns_timeout(
self,
value: Option<ClientDnsTimeout>,
) -> StreamsAppBuilder<SetBrokerDnsTimeout<S>>where
S::BrokerDnsTimeout: IsUnset,
Sourcepub fn client_dispatch_queue_capacity(
self,
value: ConnectionDispatchQueueCapacity,
) -> StreamsAppBuilder<SetClientDispatchQueueCapacity<S>>where
S::ClientDispatchQueueCapacity: IsUnset,
pub fn client_dispatch_queue_capacity(
self,
value: ConnectionDispatchQueueCapacity,
) -> StreamsAppBuilder<SetClientDispatchQueueCapacity<S>>where
S::ClientDispatchQueueCapacity: IsUnset,
Sourcepub fn maybe_client_dispatch_queue_capacity(
self,
value: Option<ConnectionDispatchQueueCapacity>,
) -> StreamsAppBuilder<SetClientDispatchQueueCapacity<S>>where
S::ClientDispatchQueueCapacity: IsUnset,
pub fn maybe_client_dispatch_queue_capacity(
self,
value: Option<ConnectionDispatchQueueCapacity>,
) -> StreamsAppBuilder<SetClientDispatchQueueCapacity<S>>where
S::ClientDispatchQueueCapacity: IsUnset,
Sourcepub fn client_frame_max(
self,
value: ClientFrameMax,
) -> StreamsAppBuilder<SetClientFrameMax<S>>where
S::ClientFrameMax: IsUnset,
pub fn client_frame_max(
self,
value: ClientFrameMax,
) -> StreamsAppBuilder<SetClientFrameMax<S>>where
S::ClientFrameMax: IsUnset,
Sourcepub fn maybe_client_frame_max(
self,
value: Option<ClientFrameMax>,
) -> StreamsAppBuilder<SetClientFrameMax<S>>where
S::ClientFrameMax: IsUnset,
pub fn maybe_client_frame_max(
self,
value: Option<ClientFrameMax>,
) -> StreamsAppBuilder<SetClientFrameMax<S>>where
S::ClientFrameMax: IsUnset,
Sourcepub fn fetch_min(
self,
value: FetchMinBytes,
) -> StreamsAppBuilder<SetFetchMin<S>>where
S::FetchMin: IsUnset,
pub fn fetch_min(
self,
value: FetchMinBytes,
) -> StreamsAppBuilder<SetFetchMin<S>>where
S::FetchMin: IsUnset,
Sourcepub fn maybe_fetch_min(
self,
value: Option<FetchMinBytes>,
) -> StreamsAppBuilder<SetFetchMin<S>>where
S::FetchMin: IsUnset,
pub fn maybe_fetch_min(
self,
value: Option<FetchMinBytes>,
) -> StreamsAppBuilder<SetFetchMin<S>>where
S::FetchMin: IsUnset,
Sourcepub fn cache_max_bytes(
self,
value: ByteSize,
) -> StreamsAppBuilder<SetCacheMaxBytes<S>>where
S::CacheMaxBytes: IsUnset,
pub fn cache_max_bytes(
self,
value: ByteSize,
) -> StreamsAppBuilder<SetCacheMaxBytes<S>>where
S::CacheMaxBytes: IsUnset,
Sourcepub fn maybe_cache_max_bytes(
self,
value: Option<ByteSize>,
) -> StreamsAppBuilder<SetCacheMaxBytes<S>>where
S::CacheMaxBytes: IsUnset,
pub fn maybe_cache_max_bytes(
self,
value: Option<ByteSize>,
) -> StreamsAppBuilder<SetCacheMaxBytes<S>>where
S::CacheMaxBytes: IsUnset,
Sourcepub fn interactive_query_queue_capacity(
self,
value: StreamsInteractiveQueryQueueCapacity,
) -> StreamsAppBuilder<SetInteractiveQueryQueueCapacity<S>>where
S::InteractiveQueryQueueCapacity: IsUnset,
pub fn interactive_query_queue_capacity(
self,
value: StreamsInteractiveQueryQueueCapacity,
) -> StreamsAppBuilder<SetInteractiveQueryQueueCapacity<S>>where
S::InteractiveQueryQueueCapacity: IsUnset,
Sourcepub fn maybe_interactive_query_queue_capacity(
self,
value: Option<StreamsInteractiveQueryQueueCapacity>,
) -> StreamsAppBuilder<SetInteractiveQueryQueueCapacity<S>>where
S::InteractiveQueryQueueCapacity: IsUnset,
pub fn maybe_interactive_query_queue_capacity(
self,
value: Option<StreamsInteractiveQueryQueueCapacity>,
) -> StreamsAppBuilder<SetInteractiveQueryQueueCapacity<S>>where
S::InteractiveQueryQueueCapacity: IsUnset,
Sourcepub fn barrier(
self,
value: BarrierAlignment,
) -> StreamsAppBuilder<SetBarrier<S>>where
S::Barrier: IsUnset,
pub fn barrier(
self,
value: BarrierAlignment,
) -> StreamsAppBuilder<SetBarrier<S>>where
S::Barrier: IsUnset,
Sourcepub fn maybe_barrier(
self,
value: Option<BarrierAlignment>,
) -> StreamsAppBuilder<SetBarrier<S>>where
S::Barrier: IsUnset,
pub fn maybe_barrier(
self,
value: Option<BarrierAlignment>,
) -> StreamsAppBuilder<SetBarrier<S>>where
S::Barrier: IsUnset,
Auto Trait Implementations§
impl<S = Empty> !RefUnwindSafe for StreamsAppBuilder<S>
impl<S = Empty> !UnwindSafe for StreamsAppBuilder<S>
impl<S> Freeze for StreamsAppBuilder<S>
impl<S> Send for StreamsAppBuilder<S>
impl<S> Sync for StreamsAppBuilder<S>
impl<S> Unpin for StreamsAppBuilder<S>
impl<S> UnsafeUnpin for StreamsAppBuilder<S>
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§impl<K, Q> Comparable<Q> for K
impl<K, Q> Comparable<Q> for K
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Converts
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be
downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Converts
Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further
downcast into Rc<ConcreteType> where ConcreteType implements Trait.§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Converts
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Converts
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.§impl<T> DowncastSend for T
impl<T> DowncastSend for T
§impl<T> DowncastSync for T
impl<T> DowncastSync for T
§impl<K, Q> Equivalent<Q> for K
impl<K, Q> Equivalent<Q> for K
§fn equivalent(&self, key: &Q) -> bool
fn equivalent(&self, key: &Q) -> bool
Compare self to
key and return true if they are equal.impl<T> ErasedDestructor for Twhere
T: 'static,
impl<T> Fruit for Twhere
T: Send + Downcast,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> Paint for Twhere
T: ?Sized,
impl<T> Paint for Twhere
T: ?Sized,
§fn fg(&self, value: Color) -> Painted<&T>
fn fg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self with the foreground set to
value.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like red() and
green(), which have the same functionality but are
pithier.
§Example
Set foreground color to white using fg():
use yansi::{Paint, Color};
painted.fg(Color::White);Set foreground color to white using white().
use yansi::Paint;
painted.white();§fn bright_black(&self) -> Painted<&T>
fn bright_black(&self) -> Painted<&T>
§fn bright_red(&self) -> Painted<&T>
fn bright_red(&self) -> Painted<&T>
§fn bright_green(&self) -> Painted<&T>
fn bright_green(&self) -> Painted<&T>
§fn bright_yellow(&self) -> Painted<&T>
fn bright_yellow(&self) -> Painted<&T>
§fn bright_blue(&self) -> Painted<&T>
fn bright_blue(&self) -> Painted<&T>
§fn bright_magenta(&self) -> Painted<&T>
fn bright_magenta(&self) -> Painted<&T>
§fn bright_cyan(&self) -> Painted<&T>
fn bright_cyan(&self) -> Painted<&T>
§fn bright_white(&self) -> Painted<&T>
fn bright_white(&self) -> Painted<&T>
§fn bg(&self, value: Color) -> Painted<&T>
fn bg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self with the background set to
value.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like on_red() and
on_green(), which have the same functionality but
are pithier.
§Example
Set background color to red using fg():
use yansi::{Paint, Color};
painted.bg(Color::Red);Set background color to red using on_red().
use yansi::Paint;
painted.on_red();§fn on_primary(&self) -> Painted<&T>
fn on_primary(&self) -> Painted<&T>
§fn on_magenta(&self) -> Painted<&T>
fn on_magenta(&self) -> Painted<&T>
§fn on_bright_black(&self) -> Painted<&T>
fn on_bright_black(&self) -> Painted<&T>
§fn on_bright_red(&self) -> Painted<&T>
fn on_bright_red(&self) -> Painted<&T>
§fn on_bright_green(&self) -> Painted<&T>
fn on_bright_green(&self) -> Painted<&T>
§fn on_bright_yellow(&self) -> Painted<&T>
fn on_bright_yellow(&self) -> Painted<&T>
§fn on_bright_blue(&self) -> Painted<&T>
fn on_bright_blue(&self) -> Painted<&T>
§fn on_bright_magenta(&self) -> Painted<&T>
fn on_bright_magenta(&self) -> Painted<&T>
§fn on_bright_cyan(&self) -> Painted<&T>
fn on_bright_cyan(&self) -> Painted<&T>
§fn on_bright_white(&self) -> Painted<&T>
fn on_bright_white(&self) -> Painted<&T>
§fn attr(&self, value: Attribute) -> Painted<&T>
fn attr(&self, value: Attribute) -> Painted<&T>
Enables the styling [Attribute] value.
This method should be used rarely. Instead, prefer to use
attribute-specific builder methods like bold() and
underline(), which have the same functionality
but are pithier.
§Example
Make text bold using attr():
use yansi::{Paint, Attribute};
painted.attr(Attribute::Bold);Make text bold using using bold().
use yansi::Paint;
painted.bold();§fn rapid_blink(&self) -> Painted<&T>
fn rapid_blink(&self) -> Painted<&T>
§fn quirk(&self, value: Quirk) -> Painted<&T>
fn quirk(&self, value: Quirk) -> Painted<&T>
Enables the yansi [Quirk] value.
This method should be used rarely. Instead, prefer to use quirk-specific
builder methods like mask() and
wrap(), which have the same functionality but are
pithier.
§Example
Enable wrapping using .quirk():
use yansi::{Paint, Quirk};
painted.quirk(Quirk::Wrap);Enable wrapping using wrap().
use yansi::Paint;
painted.wrap();§fn clear(&self) -> Painted<&T>
👎Deprecated since 1.0.1: renamed to resetting() due to conflicts with Vec::clear().
The clear() method will be removed in a future release.
fn clear(&self) -> Painted<&T>
renamed to resetting() due to conflicts with Vec::clear().
The clear() method will be removed in a future release.
§fn whenever(&self, value: Condition) -> Painted<&T>
fn whenever(&self, value: Condition) -> Painted<&T>
Conditionally enable styling based on whether the [Condition] value
applies. Replaces any previous condition.
See the crate level docs for more details.
§Example
Enable styling painted only when both stdout and stderr are TTYs:
use yansi::{Paint, Condition};
painted.red().on_yellow().whenever(Condition::STDOUTERR_ARE_TTY);