Skip to main content

WorkflowReplayerOptionsBuilder

temporalio_sdk::workflow_replayer

Struct WorkflowReplayerOptionsBuilder 

Source 
pub struct WorkflowReplayerOptionsBuilder<S: State = Empty> { /* private fields */ }
Expand description

Use builder syntax to set the inputs and finish with build().

Implementations§

Source§

impl<S: State> WorkflowReplayerOptionsBuilder<S>

Source

pub fn build(self) -> WorkflowReplayerOptions
where S: IsComplete,

Finish building and return the requested object

Source

pub fn namespace( self, value: impl Into<String>, ) -> WorkflowReplayerOptionsBuilder<SetNamespace<S>>
where S::Namespace: IsUnset,

Optional (Some / Option setters). Default: DEFAULT_REPLAY_NAMESPACE.to_owned().

Namespace exposed to workflow code during replay.

Source

pub fn maybe_namespace( self, value: Option<impl Into<String>>, ) -> WorkflowReplayerOptionsBuilder<SetNamespace<S>>
where S::Namespace: IsUnset,

Optional (Some / Option setters). Default: DEFAULT_REPLAY_NAMESPACE.to_owned().

Namespace exposed to workflow code during replay.

Source

pub fn task_queue( self, value: impl Into<String>, ) -> WorkflowReplayerOptionsBuilder<SetTaskQueue<S>>
where S::TaskQueue: IsUnset,

Optional (Some / Option setters). Default: DEFAULT_REPLAY_TASK_QUEUE.to_owned().

Task queue exposed to workflow code during replay.

Source

pub fn maybe_task_queue( self, value: Option<impl Into<String>>, ) -> WorkflowReplayerOptionsBuilder<SetTaskQueue<S>>
where S::TaskQueue: IsUnset,

Optional (Some / Option setters). Default: DEFAULT_REPLAY_TASK_QUEUE.to_owned().

Task queue exposed to workflow code during replay.

Source

pub fn data_converter( self, value: DataConverter, ) -> WorkflowReplayerOptionsBuilder<SetDataConverter<S>>
where S::DataConverter: IsUnset,

Optional (Some / Option setters). Default: <DataConverter as Default>::default().

Data converter used for workflow payloads.

Source

pub fn maybe_data_converter( self, value: Option<DataConverter>, ) -> WorkflowReplayerOptionsBuilder<SetDataConverter<S>>
where S::DataConverter: IsUnset,

Optional (Some / Option setters). Default: <DataConverter as Default>::default().

Data converter used for workflow payloads.

Source

pub fn workflow_failure_errors( self, value: HashSet<WorkflowErrorType>, ) -> WorkflowReplayerOptionsBuilder<SetWorkflowFailureErrors<S>>
where S::WorkflowFailureErrors: IsUnset,

Optional (Some / Option setters). Default: <HashSet<WorkflowErrorType> as Default>::default().

Worker-level workflow errors that should fail workflow executions.

Source

pub fn maybe_workflow_failure_errors( self, value: Option<HashSet<WorkflowErrorType>>, ) -> WorkflowReplayerOptionsBuilder<SetWorkflowFailureErrors<S>>
where S::WorkflowFailureErrors: IsUnset,

Optional (Some / Option setters). Default: <HashSet<WorkflowErrorType> as Default>::default().

Worker-level workflow errors that should fail workflow executions.

Source

pub fn workflow_types_to_failure_errors( self, value: HashMap<String, HashSet<WorkflowErrorType>>, ) -> WorkflowReplayerOptionsBuilder<SetWorkflowTypesToFailureErrors<S>>
where S::WorkflowTypesToFailureErrors: IsUnset,

Optional (Some / Option setters). Default: <HashMap<String, HashSet<WorkflowErrorType>> as Default>::default().

Per-workflow-type errors that should fail workflow executions.

Source

pub fn maybe_workflow_types_to_failure_errors( self, value: Option<HashMap<String, HashSet<WorkflowErrorType>>>, ) -> WorkflowReplayerOptionsBuilder<SetWorkflowTypesToFailureErrors<S>>
where S::WorkflowTypesToFailureErrors: IsUnset,

Optional (Some / Option setters). Default: <HashMap<String, HashSet<WorkflowErrorType>> as Default>::default().

Per-workflow-type errors that should fail workflow executions.

Source

pub fn detect_nondeterministic_futures( self, value: bool, ) -> WorkflowReplayerOptionsBuilder<SetDetectNondeterministicFutures<S>>
where S::DetectNondeterministicFutures: IsUnset,

Optional (Some / Option setters). Default: true.

Whether to detect nondeterministic future usage in workflow code.

Source

pub fn maybe_detect_nondeterministic_futures( self, value: Option<bool>, ) -> WorkflowReplayerOptionsBuilder<SetDetectNondeterministicFutures<S>>
where S::DetectNondeterministicFutures: IsUnset,

Optional (Some / Option setters). Default: true.

Whether to detect nondeterministic future usage in workflow code.

Source

pub fn patch_activation_callback( self, value: PatchActivationCallback, ) -> WorkflowReplayerOptionsBuilder<SetPatchActivationCallback<S>>
where S::PatchActivationCallback: IsUnset,

Optional (Some / Option setters). Callback controlling first non-replay patch decisions.

Source

pub fn maybe_patch_activation_callback( self, value: Option<PatchActivationCallback>, ) -> WorkflowReplayerOptionsBuilder<SetPatchActivationCallback<S>>
where S::PatchActivationCallback: IsUnset,

Optional (Some / Option setters). Callback controlling first non-replay patch decisions.

Source§

impl<S: State> WorkflowReplayerOptionsBuilder<S>

Source

pub fn worker_plugin<P: WorkerPlugin>(self, plugin: P) -> Self

Register a worker plugin with this replayer.

Experimental: This API may change or be removed.

Source

pub fn worker_interceptor<I: WorkerInterceptor + 'static>( self, interceptor: I, ) -> Self

Append a worker interceptor used during replay.

Source

pub fn workflow_interceptor( self, constructor: WorkflowInterceptorConstructor, ) -> Self

Append a workflow interceptor constructor used during replay.

Source

pub fn register_workflow<W>(self) -> Result<Self, WorkflowRegistrationError>
where W: WorkflowImplementation, <W::Run as WorkflowDefinition>::Input: Send,

Register a workflow implementation for replay.

Source

pub fn register_workflow_with_factory<W, F>( self, factory: F, ) -> Result<Self, WorkflowRegistrationError>
where W: WorkflowImplementation, <W::Run as WorkflowDefinition>::Input: Send, F: Fn() -> W + Send + Sync + 'static,

Register a workflow using a custom instance factory.

Source

pub fn register_workflow_interceptors( self, constructors: Vec<WorkflowInterceptorConstructor>, ) -> Self

Set the ordered constructors used to create workflow interceptors for each workflow instance.

This replaces any previously configured workflow interceptor constructors.

Source

pub fn workflow_interceptor_constructors_mut( &mut self, ) -> &mut Vec<WorkflowInterceptorConstructor>

Get a mutable reference to the workflow interceptor constructors list.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Any for T
where T: Any,

Source§

fn into_any(self: Box<T>) -> Box<dyn Any>

Source§

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Source§

fn type_name(&self) -> &'static str

Source§

impl<T> AnySync for T
where T: Any + Send + Sync,

Source§

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync> ⓘ

Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

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 more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

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
Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<L> LayerExt<L> for L

Source§

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

Applies the layer to a service and wraps it in Layered.
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> WorkflowOutboundValue for T
where T: Any,

Source§

fn as_any(&self) -> &(dyn Any + 'static)

Access the concrete value through Any.
Source§

fn into_any(self: Box<T>) -> Box<dyn Any>

Convert this value into Any for a consuming downcast.