Struct JobOperator 

pub struct JobOperator<R> { /* private fields */ }

The portable guarded operator application service.

The service enforces lifecycle, version, definition, checkpoint, idempotency, and bounds. A deployment authenticates the caller and authorizes OperatorRequest::authorization_class before invoking it. Removing deployment authorization does not weaken a core guard.

Implementations

impl<R: JobRepository> JobOperator<R>

pub const fn new(repository: R, clock: Arc<dyn Clock>) -> Self

Binds one repository and one injected facade clock.

pub fn with_event_sink(self, sink: Arc<dyn TelemetryEventSink>) -> Self

Attaches a non-authoritative, panic-isolated telemetry sink.

pub const fn repository(&self) -> &R

Borrows the underlying repository.

pub async fn execute( &self, request: &OperatorRequest, ) -> Result<OperatorOutcome, OperatorError>

Applies one guarded, audited, idempotent operator action.

Errors

Returns OperatorError::OperationIdConflict for a reused identifier with a different canonical request, OperatorError::OperationOutcomeUnknown for an ambiguous commit, and OperatorError::Repository for an infrastructure failure. A guard rejection is an audited OperatorOutcomeClass::Rejected outcome rather than an error.

Trait Implementations

impl<R: Clone> Clone for JobOperator<R>

fn clone(&self) -> JobOperator<R>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<R> Debug for JobOperator<R>

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

Formats the value using the given formatter.