pub struct FlowConfig { /* private fields */ }Expand description
Overrides runtime behavior for one Flow.
StartFlow and SubFlow always select pull Workers, even when no override is supplied.
crate::Client::update_flow_config leaves the Worker target unset, preserving the active Flow
target. Other omitted fields use server defaults for StartFlow, inherit the parent configuration
for SubFlow, and retain the active Flow setting for updates.
Pass a value to crate::StartFlowOptions::config_override for one execution or to
crate::Client::update_flow_config for an active Flow.
Implementations§
Source§impl FlowConfig
impl FlowConfig
Sourcepub fn active_step_search_mode(self, value: ActiveStepSearchMode) -> Self
pub fn active_step_search_mode(self, value: ActiveStepSearchMode) -> Self
Controls which active Step types Dex places in the search index.
Sourcepub fn attribute_store_names(self, values: Vec<String>) -> Self
pub fn attribute_store_names(self, values: Vec<String>) -> Self
Selects server-configured Attribute Stores for opted-in Attribute writes.
Omitting this builder preserves the existing Flow setting. Passing an empty vector retains protocol presence and disables later synchronization. Each enabled Attribute write is projected to every selected store; an external store failure does not roll back the Flow Attribute write.
Sourcepub fn continue_as_new_threshold(self, value: u32) -> Self
pub fn continue_as_new_threshold(self, value: u32) -> Self
Sets the event-count threshold that triggers Continue-As-New.
Sourcepub fn continue_as_new_page_size_bytes(self, value: u32) -> Self
pub fn continue_as_new_page_size_bytes(self, value: u32) -> Self
Sets the maximum history page size, in bytes, carried into Continue-As-New.
Sourcepub fn step_durability(self, value: StepDurability) -> Self
pub fn step_durability(self, value: StepDurability) -> Self
Sets the default persistence durability for Step handler writes.
Trait Implementations§
Source§impl Clone for FlowConfig
impl Clone for FlowConfig
Source§impl Debug for FlowConfig
impl Debug for FlowConfig
Auto Trait Implementations§
impl Freeze for FlowConfig
impl RefUnwindSafe for FlowConfig
impl Send for FlowConfig
impl Sync for FlowConfig
impl Unpin for FlowConfig
impl UnsafeUnpin for FlowConfig
impl UnwindSafe for FlowConfig
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request