pub struct FlowTimeoutHandlerOptions { /* private fields */ }Expand description
Configures execution and selective state loading for a Flow timeout handler.
Durations start when the soft Flow timeout fires. Omitted fields preserve the server’s Execute defaults. AttributeMap contents and pending Channel messages are loaded only when selected.
Implementations§
Source§impl FlowTimeoutHandlerOptions
impl FlowTimeoutHandlerOptions
Sourcepub fn method_timeout(self, value: Duration) -> Self
pub fn method_timeout(self, value: Duration) -> Self
Sets the maximum duration of one timeout-handler attempt.
Sourcepub fn heartbeat_timeout(self, value: Duration) -> Self
pub fn heartbeat_timeout(self, value: Duration) -> Self
Sets the timeout for progress heartbeats from the timeout handler.
Sourcepub fn retry(self, value: RetryPolicy) -> Self
pub fn retry(self, value: RetryPolicy) -> Self
Sets retry behavior for the timeout handler’s logical execution.
Sourcepub fn failure(self, value: FlowTimeoutHandlerFailure) -> Self
pub fn failure(self, value: FlowTimeoutHandlerFailure) -> Self
Sets routing after all timeout-handler attempts fail.
Sourcepub fn durability(self, value: StepDurability) -> Self
pub fn durability(self, value: StepDurability) -> Self
Overrides persistence durability for the timeout-handler response.
Sourcepub fn lock(self, value: AttributeLock) -> Self
pub fn lock(self, value: AttributeLock) -> Self
Adds an Attribute lock held for each timeout-handler attempt.
Sourcepub fn load_attribute_map<T>(self, attribute_map: &AttributeMap<T>) -> Self
pub fn load_attribute_map<T>(self, attribute_map: &AttributeMap<T>) -> Self
Loads every current instance of attribute_map for the timeout handler.
Sourcepub fn load_attribute_map_instance(self, load: AttributeMapLoad) -> Self
pub fn load_attribute_map_instance(self, load: AttributeMapLoad) -> Self
Loads one AttributeMap instance for the timeout handler.
Sourcepub fn load_channel<T>(self, channel: &Channel<T>) -> Self
pub fn load_channel<T>(self, channel: &Channel<T>) -> Self
Loads one Channel’s pending messages for the timeout handler.
Sourcepub fn load_channel_map<T>(self, channel_map: &ChannelMap<T>) -> Self
pub fn load_channel_map<T>(self, channel_map: &ChannelMap<T>) -> Self
Loads every current ChannelMap instance’s pending messages for the timeout handler.
Sourcepub fn load_channel_map_instance(self, load: ChannelMapLoad) -> Self
pub fn load_channel_map_instance(self, load: ChannelMapLoad) -> Self
Loads one ChannelMap instance’s pending messages for the timeout handler.
Trait Implementations§
Source§impl Clone for FlowTimeoutHandlerOptions
impl Clone for FlowTimeoutHandlerOptions
Auto Trait Implementations§
impl Freeze for FlowTimeoutHandlerOptions
impl RefUnwindSafe for FlowTimeoutHandlerOptions
impl Send for FlowTimeoutHandlerOptions
impl Sync for FlowTimeoutHandlerOptions
impl Unpin for FlowTimeoutHandlerOptions
impl UnsafeUnpin for FlowTimeoutHandlerOptions
impl UnwindSafe for FlowTimeoutHandlerOptions
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