#[non_exhaustive]pub struct ParallelismConfigurationDescriptionBuilder { /* private fields */ }Expand description
A builder for ParallelismConfigurationDescription.
Implementations§
Source§impl ParallelismConfigurationDescriptionBuilder
impl ParallelismConfigurationDescriptionBuilder
Sourcepub fn configuration_type(self, input: ConfigurationType) -> Self
pub fn configuration_type(self, input: ConfigurationType) -> Self
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
Sourcepub fn set_configuration_type(self, input: Option<ConfigurationType>) -> Self
pub fn set_configuration_type(self, input: Option<ConfigurationType>) -> Self
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
Sourcepub fn get_configuration_type(&self) -> &Option<ConfigurationType>
pub fn get_configuration_type(&self) -> &Option<ConfigurationType>
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
Sourcepub fn parallelism(self, input: i32) -> Self
pub fn parallelism(self, input: i32) -> Self
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled is set to True, then Managed Service for Apache Flink can increase the CurrentParallelism value in response to application load. The service can increase CurrentParallelism up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 64 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism value down to the Parallelism setting.
Sourcepub fn set_parallelism(self, input: Option<i32>) -> Self
pub fn set_parallelism(self, input: Option<i32>) -> Self
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled is set to True, then Managed Service for Apache Flink can increase the CurrentParallelism value in response to application load. The service can increase CurrentParallelism up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 64 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism value down to the Parallelism setting.
Sourcepub fn get_parallelism(&self) -> &Option<i32>
pub fn get_parallelism(&self) -> &Option<i32>
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled is set to True, then Managed Service for Apache Flink can increase the CurrentParallelism value in response to application load. The service can increase CurrentParallelism up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 64 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism value down to the Parallelism setting.
Sourcepub fn parallelism_per_kpu(self, input: i32) -> Self
pub fn parallelism_per_kpu(self, input: i32) -> Self
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application.
Sourcepub fn set_parallelism_per_kpu(self, input: Option<i32>) -> Self
pub fn set_parallelism_per_kpu(self, input: Option<i32>) -> Self
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application.
Sourcepub fn get_parallelism_per_kpu(&self) -> &Option<i32>
pub fn get_parallelism_per_kpu(&self) -> &Option<i32>
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application.
Sourcepub fn current_parallelism(self, input: i32) -> Self
pub fn current_parallelism(self, input: i32) -> Self
Describes the current number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled is set to True, Managed Service for Apache Flink can increase this value in response to application load. The service can increase this value up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism value down to the Parallelism setting.
Sourcepub fn set_current_parallelism(self, input: Option<i32>) -> Self
pub fn set_current_parallelism(self, input: Option<i32>) -> Self
Describes the current number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled is set to True, Managed Service for Apache Flink can increase this value in response to application load. The service can increase this value up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism value down to the Parallelism setting.
Sourcepub fn get_current_parallelism(&self) -> &Option<i32>
pub fn get_current_parallelism(&self) -> &Option<i32>
Describes the current number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled is set to True, Managed Service for Apache Flink can increase this value in response to application load. The service can increase this value up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism value down to the Parallelism setting.
Sourcepub fn auto_scaling_enabled(self, input: bool) -> Self
pub fn auto_scaling_enabled(self, input: bool) -> Self
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.
Sourcepub fn set_auto_scaling_enabled(self, input: Option<bool>) -> Self
pub fn set_auto_scaling_enabled(self, input: Option<bool>) -> Self
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.
Sourcepub fn get_auto_scaling_enabled(&self) -> &Option<bool>
pub fn get_auto_scaling_enabled(&self) -> &Option<bool>
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.
Sourcepub fn build(self) -> ParallelismConfigurationDescription
pub fn build(self) -> ParallelismConfigurationDescription
Consumes the builder and constructs a ParallelismConfigurationDescription.
Trait Implementations§
Source§impl Clone for ParallelismConfigurationDescriptionBuilder
impl Clone for ParallelismConfigurationDescriptionBuilder
Source§fn clone(&self) -> ParallelismConfigurationDescriptionBuilder
fn clone(&self) -> ParallelismConfigurationDescriptionBuilder
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Default for ParallelismConfigurationDescriptionBuilder
impl Default for ParallelismConfigurationDescriptionBuilder
Source§fn default() -> ParallelismConfigurationDescriptionBuilder
fn default() -> ParallelismConfigurationDescriptionBuilder
Source§impl PartialEq for ParallelismConfigurationDescriptionBuilder
impl PartialEq for ParallelismConfigurationDescriptionBuilder
Source§fn eq(&self, other: &ParallelismConfigurationDescriptionBuilder) -> bool
fn eq(&self, other: &ParallelismConfigurationDescriptionBuilder) -> bool
self and other values to be equal, and is used by ==.impl StructuralPartialEq for ParallelismConfigurationDescriptionBuilder
Auto Trait Implementations§
impl Freeze for ParallelismConfigurationDescriptionBuilder
impl RefUnwindSafe for ParallelismConfigurationDescriptionBuilder
impl Send for ParallelismConfigurationDescriptionBuilder
impl Sync for ParallelismConfigurationDescriptionBuilder
impl Unpin for ParallelismConfigurationDescriptionBuilder
impl UnwindSafe for ParallelismConfigurationDescriptionBuilder
Blanket Implementations§
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§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>
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>
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 moreSource§impl<T> Paint for Twhere
T: ?Sized,
impl<T> Paint for Twhere
T: ?Sized,
Source§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();Source§fn bright_black(&self) -> Painted<&T>
fn bright_black(&self) -> Painted<&T>
Source§fn bright_red(&self) -> Painted<&T>
fn bright_red(&self) -> Painted<&T>
Source§fn bright_green(&self) -> Painted<&T>
fn bright_green(&self) -> Painted<&T>
Source§fn bright_yellow(&self) -> Painted<&T>
fn bright_yellow(&self) -> Painted<&T>
Source§fn bright_blue(&self) -> Painted<&T>
fn bright_blue(&self) -> Painted<&T>
Source§fn bright_magenta(&self) -> Painted<&T>
fn bright_magenta(&self) -> Painted<&T>
Source§fn bright_cyan(&self) -> Painted<&T>
fn bright_cyan(&self) -> Painted<&T>
Source§fn bright_white(&self) -> Painted<&T>
fn bright_white(&self) -> Painted<&T>
Source§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();Source§fn on_primary(&self) -> Painted<&T>
fn on_primary(&self) -> Painted<&T>
Source§fn on_magenta(&self) -> Painted<&T>
fn on_magenta(&self) -> Painted<&T>
Source§fn on_bright_black(&self) -> Painted<&T>
fn on_bright_black(&self) -> Painted<&T>
Source§fn on_bright_red(&self) -> Painted<&T>
fn on_bright_red(&self) -> Painted<&T>
Source§fn on_bright_green(&self) -> Painted<&T>
fn on_bright_green(&self) -> Painted<&T>
Source§fn on_bright_yellow(&self) -> Painted<&T>
fn on_bright_yellow(&self) -> Painted<&T>
Source§fn on_bright_blue(&self) -> Painted<&T>
fn on_bright_blue(&self) -> Painted<&T>
Source§fn on_bright_magenta(&self) -> Painted<&T>
fn on_bright_magenta(&self) -> Painted<&T>
Source§fn on_bright_cyan(&self) -> Painted<&T>
fn on_bright_cyan(&self) -> Painted<&T>
Source§fn on_bright_white(&self) -> Painted<&T>
fn on_bright_white(&self) -> Painted<&T>
Source§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();Source§fn rapid_blink(&self) -> Painted<&T>
fn rapid_blink(&self) -> Painted<&T>
Source§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();Source§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>
resetting() due to conflicts with Vec::clear().
The clear() method will be removed in a future release.Source§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);