Struct OperatorRequest 

pub struct OperatorRequest { /* private fields */ }

One validated mutating operator request.

The request digest covers the action, target identity, expected version, and bounded arguments. Replaying an operation identifier with a different digest is a conflict rather than a repeat.

Implementations

impl OperatorRequest

pub fn launch( operation_id: OperationId, actor: ActorRef, key: JobInstanceKey, definition: DefinitionIdentity, ) -> OperatorRequest

Requests one launch of the instance selected by an identifying key.

pub fn restart( operation_id: OperationId, actor: ActorRef, job_instance_id: JobInstanceId, definition: DefinitionIdentity, ) -> OperatorRequest

Requests one restart attempt for an existing logical instance.

pub fn stop( operation_id: OperationId, actor: ActorRef, job_execution_id: JobExecutionId, expected_version: ExecutionVersion, ) -> OperatorRequest

Requests one durable cooperative stop.

pub fn abandon( operation_id: OperationId, actor: ActorRef, reason: ReasonCode, job_execution_id: JobExecutionId, expected_version: ExecutionVersion, ) -> OperatorRequest

Requests that one finished or recovered execution become ABANDONED.

pub fn recover( operation_id: OperationId, actor: ActorRef, reason: ReasonCode, directive: RecoveryDirective, proposal: &RecoveryProposal, ) -> OperatorRequest

Requests one evidence-bound recovery decision.

pub const fn action(&self) -> OperatorAction

Returns the requested action.

pub const fn authorization_class(&self) -> AuthorizationClass

Returns the class a deployment authorizes before this call.

pub const fn operation_id(&self) -> &OperationId

Borrows the caller-supplied idempotency key.

pub const fn actor(&self) -> &ActorRef

Borrows the opaque actor reference.

pub const fn reason(&self) -> Option<&ReasonCode>

Borrows the closed-set reason code, when the action requires one.

pub const fn expected_version(&self) -> Option<ExecutionVersion>

Returns the observed optimistic version for a lifecycle mutation.

pub const fn digest(&self) -> &RequestDigest

Returns the framework-computed canonical request digest.

pub const fn job_execution_id(&self) -> Option<JobExecutionId>

Returns the targeted execution, when the action names one.

pub const fn job_instance_id(&self) -> Option<JobInstanceId>

Returns the targeted logical instance, when the action names one.

pub fn job_instance_key(&self) -> Option<&JobInstanceKey>

Borrows the identifying key, when the action selects by key.

Only OperatorAction::Launch names one; every other action names an instance or an execution.

Trait Implementations

impl Clone for OperatorRequest

fn clone(&self) -> OperatorRequest

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OperatorRequest

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Eq for OperatorRequest

impl PartialEq for OperatorRequest

fn eq(&self, other: &OperatorRequest) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for OperatorRequest