Skip to main content

JobEntry

arcp_runtime::runtime::job

Struct JobEntry

pub struct JobEntry {
    pub job_id: JobId,
    pub session_id: SessionId,
    pub correlation_id: MessageId,
    pub cancel: CancellationToken,
    pub state: JobState,
    pub agent: String,
    pub created_at: DateTime<Utc>,
    pub last_event_seq: u64,
    pub parent_job_id: Option<JobId>,
    pub credential_ids: Vec<CredentialId>,
    pub lease: Option<LeaseRequest>,
}

Expand description

Per-job runtime bookkeeping.

Fields§

§job_id: JobId

Job identifier.

§session_id: SessionId

Owning session.

§correlation_id: MessageId

Correlation back to the originating tool.invoke envelope.

§cancel: CancellationToken

Cancellation token; child of the session token.

§state: JobState

Current state.

§agent: String

Agent reference (name or name@version) the job is running. For v1.0-style tool.invoke submissions this is the tool name.

§created_at: DateTime<Utc>

Submission timestamp.

§last_event_seq: u64

Highest event sequence emitted for this job (ARCP v1.1 §6.6).

§parent_job_id: Option<JobId>

Parent job id for delegated / child jobs.

§credential_ids: Vec<CredentialId>

Provisioned credential ids issued for this job.

§lease: Option<LeaseRequest>

Accepted lease constraints for this job.

Trait Implementations§

impl Debug for JobEntry

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

impl Freeze for JobEntry

impl RefUnwindSafe for JobEntry

impl Send for JobEntry

impl Sync for JobEntry

impl Unpin for JobEntry

impl UnsafeUnpin for JobEntry

impl UnwindSafe for JobEntry

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Same for T

type Output = T

Should always be Self

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more