Struct FlowConfig 

pub struct FlowConfig {
    pub active_step_search_mode: Option<i32>,
    pub continue_as_new_threshold: Option<i32>,
    pub continue_as_new_page_size_in_bytes: Option<i32>,
    pub step_durability: Option<i32>,
    pub worker_target: Option<WorkerTarget>,
    pub attribute_store_names: Option<AttributeStoreNames>,
    pub history_window_events: Option<i32>,
}

Fields

active_step_search_mode: Option<i32>

continue_as_new_threshold: Option<i32>

Deprecated: Dex does not continue Flows as new. Dex rejects a negative value, stores the value in the Flow configuration, and otherwise ignores it.

continue_as_new_page_size_in_bytes: Option<i32>

Deprecated: Dex does not continue Flows as new. Dex rejects a negative value, stores the value in the Flow configuration, and otherwise ignores it.

step_durability: Option<i32>

worker_target: Option<WorkerTarget>

attribute_store_names: Option<AttributeStoreNames>

Present empty disables future synchronization; non-empty selects Server-configured stores.

history_window_events: Option<i32>

Approximate number of the newest history events that the run keeps for history reads and Time Travel.

Use it to keep more history for a run that you inspect or travel back in often, or less history for a run that writes many events and needs less disk. Leave it unset to use the server’s history.windowEvents setting, which defaults to 10000.

The window counts history events. A command that changes the Flow but records no event counts as one event. When the run holds more than this many events plus one prune chunk, Dex prunes the oldest events until about this many remain. The prune chunk is the smaller of the server’s history.pruneChunkSize setting and one tenth of this window, and at least one. Pruning stops only between commands, so a run keeps slightly more or fewer events than the value. The first event of the run is always kept, and ResetFlow to the beginning of the run always works. GetHistoryEvents no longer returns pruned events, and Time Travel targets only commands inside the window.

Set it at start through FlowStartOptions.flow_config_override, or change it on a running Flow with UpdateFlowConfig. A smaller value takes effect at the run’s next pruning. A larger value keeps more of the events recorded afterwards; pruned events never come back. Once set, the value can be changed but not cleared back to the server default. A child Flow inherits it from its parent unless its own override sets it.

The value must be positive and at most the server’s history.maxWindowEvents setting, which defaults to 100000. StartFlow and UpdateFlowConfig reject other values with INVALID_ARGUMENT. A Step result that starts a SubFlow with such an override is an invalid Worker response: the Step attempt fails and is retried under the Step’s retry policy.

Since server-zd 0.1.21.

Implementations

impl FlowConfig

pub fn active_step_search_mode(&self) -> ActiveStepSearchMode

Returns the enum value of active_step_search_mode, or the default if the field is unset or set to an invalid enum value.

pub fn set_active_step_search_mode(&mut self, value: ActiveStepSearchMode)

Sets active_step_search_mode to the provided enum value.

pub fn continue_as_new_threshold(&self) -> i32

Returns the value of continue_as_new_threshold, or the default value if continue_as_new_threshold is unset.

pub fn continue_as_new_page_size_in_bytes(&self) -> i32

Returns the value of continue_as_new_page_size_in_bytes, or the default value if continue_as_new_page_size_in_bytes is unset.

pub fn step_durability(&self) -> StepDurability

Returns the enum value of step_durability, or the default if the field is unset or set to an invalid enum value.

pub fn set_step_durability(&mut self, value: StepDurability)

Sets step_durability to the provided enum value.

pub fn history_window_events(&self) -> i32

Returns the value of history_window_events, or the default value if history_window_events is unset.

Trait Implementations

impl Clone for FlowConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlowConfig

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

Formats the value using the given formatter.

impl Default for FlowConfig

fn default() -> Self

Returns the “default value” for a type.

impl Eq for FlowConfig

impl Hash for FlowConfig

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Message for FlowConfig

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for FlowConfig

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for FlowConfig