pub struct AutoWorkerOutcome {
pub task_queue: String,
pub workflow_type: String,
pub decision: AutoWorkerDecision,
pub deployment: Option<String>,
pub detail: String,
}Expand description
One task queue’s auto-provision outcome, as reported to the deploy caller, the boot log, and the managed-worker status surface.
Fields§
§task_queue: StringThe task queue this is about.
workflow_type: StringThe workflow type whose document declared the queue.
Carried so a document-level failure — one where no queue name could be read out of the source at all — is still attributable to a document. Without it two unparseable documents are one indistinguishable entry.
decision: AutoWorkerDecisionWhat was decided.
deployment: Option<String>The deployment record’s name, when there is one to name — the auto
record on the minted arms, the operator’s own on AutoWorkerDecision::OperatorRecord.
detail: StringThe sentence an operator reads. ALWAYS present, on every arm: a decision token with no account of itself is a decision nobody can act on.
Implementations§
Source§impl AutoWorkerOutcome
impl AutoWorkerOutcome
Sourcepub fn new(
task_queue: impl Into<String>,
workflow_type: impl Into<String>,
decision: AutoWorkerDecision,
deployment: Option<String>,
detail: impl Into<String>,
) -> Self
pub fn new( task_queue: impl Into<String>, workflow_type: impl Into<String>, decision: AutoWorkerDecision, deployment: Option<String>, detail: impl Into<String>, ) -> Self
One outcome for a queue, with its account.
Sourcepub fn document_level(
workflow_type: impl Into<String>,
detail: impl Into<String>,
) -> Self
pub fn document_level( workflow_type: impl Into<String>, detail: impl Into<String>, ) -> Self
A refusal that could not be attributed to any one queue — the document itself did not parse, so no queue name was ever read out of it.
Sourcepub fn log_key(&self) -> String
pub fn log_key(&self) -> String
The key this outcome is kept under in the supervisor’s per-queue log.
The task queue, because the operator’s question is about a queue and one queue has one auto record however many documents declare it. A document-level failure has no queue, so it is keyed by the document instead — otherwise two unparseable documents overwrite each other under one blank name.
Trait Implementations§
Source§impl Clone for AutoWorkerOutcome
impl Clone for AutoWorkerOutcome
Source§fn clone(&self) -> AutoWorkerOutcome
fn clone(&self) -> AutoWorkerOutcome
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for AutoWorkerOutcome
impl Debug for AutoWorkerOutcome
Source§impl<'de> Deserialize<'de> for AutoWorkerOutcome
impl<'de> Deserialize<'de> for AutoWorkerOutcome
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
impl Eq for AutoWorkerOutcome
Source§impl PartialEq for AutoWorkerOutcome
impl PartialEq for AutoWorkerOutcome
Source§impl Serialize for AutoWorkerOutcome
impl Serialize for AutoWorkerOutcome
impl StructuralPartialEq for AutoWorkerOutcome
Auto Trait Implementations§
impl Freeze for AutoWorkerOutcome
impl RefUnwindSafe for AutoWorkerOutcome
impl Send for AutoWorkerOutcome
impl Sync for AutoWorkerOutcome
impl Unpin for AutoWorkerOutcome
impl UnsafeUnpin for AutoWorkerOutcome
impl UnwindSafe for AutoWorkerOutcome
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<M> EmbeddedConversationMessage for Mwhere
M: Serialize,
impl<M> EmbeddedConversationMessage for Mwhere
M: Serialize,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoMaybeUndefined<T> for T
impl<T> IntoMaybeUndefined<T> for T
Source§fn into_maybe_undefined(self) -> MaybeUndefined<T>
fn into_maybe_undefined(self) -> MaybeUndefined<T>
Source§impl<T> IntoOption<T> for T
impl<T> IntoOption<T> for T
Source§fn into_option(self) -> Option<T>
fn into_option(self) -> Option<T>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request