Enum ParallelOperation

pub enum ParallelOperation {
    Activity {
        activity_type: String,
        options: ActivityOptions,
        arguments: Result<AvroValue>,
    },
    ChildWorkflow {
        workflow_type: String,
        options: ChildWorkflowOptions,
        arguments: Result<AvroValue>,
    },
    Timer(Duration),
    Group(Vec<ParallelOperation>),
}

A deferred durable leaf or nested group for WorkflowContext::parallel.

Constructors capture arguments but perform no I/O. The join validates the complete tree, attaches the existing parallel-group metadata to every ordinary command, schedules all leaves, and then suspends.

Variants

Activity

Fields

activity_type: String

options: ActivityOptions

arguments: Result<AvroValue>

ChildWorkflow

Fields

workflow_type: String

options: ChildWorkflowOptions

arguments: Result<AvroValue>

Timer(Duration)

Group(Vec<ParallelOperation>)

Implementations

impl ParallelOperation

pub fn activity<T: Serialize>(activity_type: impl Into<String>, args: T) -> Self

pub fn activity_with_options<T: Serialize>( activity_type: impl Into<String>, options: ActivityOptions, args: T, ) -> Self

pub fn child_workflow<T: Serialize>( workflow_type: impl Into<String>, options: ChildWorkflowOptions, args: T, ) -> Self

pub fn timer(duration: Duration) -> Self

pub fn group(operations: Vec<ParallelOperation>) -> Self