pub struct ExternalWorkflow {
pub continuation: Arc<WorkflowContinuation>,
pub task_index: Arc<TaskIndex>,
pub workflow_id: Arc<str>,
pub metadata_json: Option<Arc<str>>,
}Expand description
Workflow definition for binding-friendly worker API.
Contains only the structural information (definition hash + continuation tree)
needed by PooledWorker for position tracking, completion detection, retry
policies, and timeouts. Task execution is delegated to an external executor.
Fields§
§continuation: Arc<WorkflowContinuation>The continuation tree describing the workflow structure.
task_index: Arc<TaskIndex>Per-workflow TaskId → metadata index. Built once when the workflow
is registered; replaces the O(N) tree walk + per-node SHA-256 that
the worker would otherwise do for every task dispatch.
workflow_id: Arc<str>Human-readable workflow name (for log/error display and FFI task executor).
metadata_json: Option<Arc<str>>Optional JSON-encoded workflow-level metadata.
Auto Trait Implementations§
impl !RefUnwindSafe for ExternalWorkflow
impl !UnwindSafe for ExternalWorkflow
impl Freeze for ExternalWorkflow
impl Send for ExternalWorkflow
impl Sync for ExternalWorkflow
impl Unpin for ExternalWorkflow
impl UnsafeUnpin for ExternalWorkflow
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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::RequestSource§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.
Source§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
Source§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Returns whether the given value has been niched. Read more
Source§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
Writes data to
out indicating that a T is niched.