#[non_exhaustive]pub struct InitializeWorkflowInput { /* private fields */ }Expand description
Input passed to WorkflowInterceptor::initialize_workflow.
The decoded input provided to workflow’s #[init] method.
If a workflow has no #[init], inputs are instead passed to WorkflowInterceptor::execute.
Implementations§
Source§impl InitializeWorkflowInput
impl InitializeWorkflowInput
Sourcepub fn input_ref<T: Any>(&self) -> Option<&T>
pub fn input_ref<T: Any>(&self) -> Option<&T>
Attempt to access the decoded workflow input as a concrete type.
Sourcepub fn input_mut<T: Any>(&mut self) -> Option<&mut T>
pub fn input_mut<T: Any>(&mut self) -> Option<&mut T>
Attempt to mutably access the decoded workflow input as a concrete type.
Sourcepub fn headers_mut(&mut self) -> &mut HashMap<String, Payload>
pub fn headers_mut(&mut self) -> &mut HashMap<String, Payload>
Mutably access headers attached to the workflow execution.
Auto Trait Implementations§
impl !RefUnwindSafe for InitializeWorkflowInput
impl !Send for InitializeWorkflowInput
impl !Sync for InitializeWorkflowInput
impl !UnwindSafe for InitializeWorkflowInput
impl Freeze for InitializeWorkflowInput
impl Unpin for InitializeWorkflowInput
impl UnsafeUnpin for InitializeWorkflowInput
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
Mutably borrows from an owned value. Read more
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>
Wrap the input message
T in a tonic::Request