Enum NamespaceOperation 

pub enum NamespaceOperation<'a> {
    StartWorkflow(&'a ProtoStartWorkflowRequest),
    Signal(&'a ProtoSignalRequest, WorkflowTarget<'a>),
    Query(&'a ProtoQueryRequest, WorkflowTarget<'a>),
    Cancel(&'a ProtoCancelRequest, WorkflowTarget<'a>),
    Reopen(&'a ProtoReopenRequest, WorkflowTarget<'a>),
    PauseWorkflow(&'a ProtoPauseRequest, WorkflowTarget<'a>),
    ResumeWorkflow(&'a ProtoResumeRequest, WorkflowTarget<'a>),
    RenameWorkflow(&'a ProtoRenameRequest, WorkflowTarget<'a>),
    ListWorkflows(&'a ProtoListWorkflowsRequest, &'a WorkflowFilter),
    CountWorkflows(&'a ProtoCountWorkflowsRequest),
    Describe(&'a ProtoDescribeWorkflowRequest, WorkflowTarget<'a>),
    CreateSchedule(&'a ProtoCreateScheduleRequest),
    UpdateSchedule(&'a ProtoUpdateScheduleRequest, ScheduleTarget<'a>),
    PauseSchedule(&'a ProtoScheduleIdRequest, ScheduleTarget<'a>),
    ResumeSchedule(&'a ProtoScheduleIdRequest, ScheduleTarget<'a>),
    DeleteSchedule(&'a ProtoScheduleIdRequest, ScheduleTarget<'a>),
    ListSchedules(&'a ProtoListSchedulesRequest),
    DescribeSchedule(&'a ProtoScheduleIdRequest, ScheduleTarget<'a>),
    Subscribe(SubscriptionScope<'a>, &'a EventFilter),
    RegisterWorker(&'a ProtoRegisterWorker),
    Intervene {
        namespace: &'a str,
        target: WorkflowTarget<'a>,
    },
}

Namespace-sensitive operation described at the adapter boundary.

Variants

StartWorkflow(&'a ProtoStartWorkflowRequest)

Start workflow request.

Signal(&'a ProtoSignalRequest, WorkflowTarget<'a>)

Signal workflow request.

Query(&'a ProtoQueryRequest, WorkflowTarget<'a>)

Query workflow request.

Cancel(&'a ProtoCancelRequest, WorkflowTarget<'a>)

Cancel workflow request.

Reopen(&'a ProtoReopenRequest, WorkflowTarget<'a>)

Reopen workflow request.

PauseWorkflow(&'a ProtoPauseRequest, WorkflowTarget<'a>)

Pause workflow request (#204).

ResumeWorkflow(&'a ProtoResumeRequest, WorkflowTarget<'a>)

Resume (paused) workflow request (#204).

RenameWorkflow(&'a ProtoRenameRequest, WorkflowTarget<'a>)

Rename workflow request (#211): namespace grant + durable ownership.

ListWorkflows(&'a ProtoListWorkflowsRequest, &'a WorkflowFilter)

List workflow request.

CountWorkflows(&'a ProtoCountWorkflowsRequest)

Count workflow request.

Describe(&'a ProtoDescribeWorkflowRequest, WorkflowTarget<'a>)

Describe workflow request.

CreateSchedule(&'a ProtoCreateScheduleRequest)

Create schedule request.

UpdateSchedule(&'a ProtoUpdateScheduleRequest, ScheduleTarget<'a>)

Update schedule request.

PauseSchedule(&'a ProtoScheduleIdRequest, ScheduleTarget<'a>)

Pause schedule request.

ResumeSchedule(&'a ProtoScheduleIdRequest, ScheduleTarget<'a>)

Resume schedule request.

DeleteSchedule(&'a ProtoScheduleIdRequest, ScheduleTarget<'a>)

Delete schedule request.

ListSchedules(&'a ProtoListSchedulesRequest)

List schedules request.

DescribeSchedule(&'a ProtoScheduleIdRequest, ScheduleTarget<'a>)

Describe schedule request.

Subscribe(SubscriptionScope<'a>, &'a EventFilter)

Event subscription request.

RegisterWorker(&'a ProtoRegisterWorker)

Worker registration request.

Intervene

Mid-run intervention on a running activity (NOI-6). Namespace-scoped like signal/cancel: the caller must hold a grant for namespace AND the target workflow must be visible in it (anti-leak not_found otherwise).

Fields

namespace: &'a str

The namespace the target workflow runs under.

target: WorkflowTarget<'a>

The target workflow whose durable ownership is verified.

Implementations

impl<'a> NamespaceOperation<'a>

pub const fn start(request: &'a ProtoStartWorkflowRequest) -> Self

Create a start-workflow operation descriptor.

pub const fn signal( request: &'a ProtoSignalRequest, target: WorkflowTarget<'a>, ) -> Self

Create a signal operation descriptor.

pub const fn query( request: &'a ProtoQueryRequest, target: WorkflowTarget<'a>, ) -> Self

Create a query operation descriptor.

pub const fn cancel( request: &'a ProtoCancelRequest, target: WorkflowTarget<'a>, ) -> Self

Create a cancel operation descriptor.

pub const fn reopen( request: &'a ProtoReopenRequest, target: WorkflowTarget<'a>, ) -> Self

Create a reopen operation descriptor.

pub const fn pause_workflow( request: &'a ProtoPauseRequest, target: WorkflowTarget<'a>, ) -> Self

Create a pause-workflow operation descriptor (#204).

pub const fn resume_workflow( request: &'a ProtoResumeRequest, target: WorkflowTarget<'a>, ) -> Self

Create a resume-workflow operation descriptor (#204).

pub const fn rename_workflow( request: &'a ProtoRenameRequest, target: WorkflowTarget<'a>, ) -> Self

Create a rename-workflow operation descriptor (#211).

pub const fn list( request: &'a ProtoListWorkflowsRequest, filter: &'a WorkflowFilter, ) -> Self

Create a list-workflows operation descriptor.

pub const fn count(request: &'a ProtoCountWorkflowsRequest) -> Self

Create a count-workflows operation descriptor.

pub const fn describe( request: &'a ProtoDescribeWorkflowRequest, target: WorkflowTarget<'a>, ) -> Self

Create a describe-workflow operation descriptor.

pub const fn create_schedule(request: &'a ProtoCreateScheduleRequest) -> Self

Create a create-schedule operation descriptor.

pub const fn update_schedule( request: &'a ProtoUpdateScheduleRequest, target: ScheduleTarget<'a>, ) -> Self

Create an update-schedule operation descriptor.

pub const fn pause_schedule( request: &'a ProtoScheduleIdRequest, target: ScheduleTarget<'a>, ) -> Self

Create a pause-schedule operation descriptor.

pub const fn resume_schedule( request: &'a ProtoScheduleIdRequest, target: ScheduleTarget<'a>, ) -> Self

Create a resume-schedule operation descriptor.

pub const fn delete_schedule( request: &'a ProtoScheduleIdRequest, target: ScheduleTarget<'a>, ) -> Self

Create a delete-schedule operation descriptor.

pub const fn list_schedules(request: &'a ProtoListSchedulesRequest) -> Self

Create a list-schedules operation descriptor.

pub const fn describe_schedule( request: &'a ProtoScheduleIdRequest, target: ScheduleTarget<'a>, ) -> Self

Create a describe-schedule operation descriptor.

pub const fn subscribe( scope: SubscriptionScope<'a>, filter: &'a EventFilter, ) -> Self

Create a subscribe operation descriptor.

pub const fn register_worker(request: &'a ProtoRegisterWorker) -> Self

Create a worker-registration operation descriptor.

pub const fn intervene(namespace: &'a str, target: WorkflowTarget<'a>) -> Self

Create a mid-run intervention operation descriptor (NOI-6).