Enum AssistantInstall 

pub enum AssistantInstall {
    Installed {
        workflow_type: String,
        content_hash: String,
        task_queue: String,
    },
    AlreadyCurrent {
        workflow_type: String,
        content_hash: String,
        task_queue: String,
    },
    Deferred {
        workflow_type: String,
        embedded_hash: String,
        routed_hash: Option<String>,
        embedded_queue: String,
        routed_queues: RoutedQueues,
    },
    Failed {
        reason: String,
    },
}

What the boot install did, and to what.

Variants

Installed

The engine held no version of the assistant type, so the embedded document was loaded and routed.

Fields

workflow_type: String

The workflow type now routed.

content_hash: String

The embedded content hash that took the route.

task_queue: String

The private queue this install just claimed. Never default.

AlreadyCurrent

A version was already resident AND routed, and it is the embedded one.

Fields

workflow_type: String

The workflow type.

content_hash: String

The routed content hash, equal to the embedded one.

task_queue: String

The private queue the routed version serves. Never default.

Deferred

Versions are resident but the embedded one does not hold the route. The cut is the operator’s to make.

Fields

workflow_type: String

The workflow type.

embedded_hash: String

The embedded document’s content hash.

routed_hash: Option<String>

The routed hash, or None when no resident version holds the route.

embedded_queue: String

The queue the embedded document would claim on deploy.

routed_queues: RoutedQueues

The queue(s) the routed version actually serves right now.

Failed

The install could not be attempted or did not complete. The server keeps serving; the assistant is simply not installed by this boot.

Fields

reason: String

What refused, verbatim.

Implementations

impl AssistantInstall

pub const fn outcome(&self) -> &'static str

A stable label for logs and metrics.

pub fn defers_a_queue_move(&self) -> bool

Whether this outcome is a deferred install that ALSO holds the assistant on a different queue from the one the embedded document declares.

The queue migration #200 refuses to perform silently: this is the condition the boot log announces at WARN, and the condition a test can pin without reading log text.

Trait Implementations

impl Clone for AssistantInstall

fn clone(&self) -> AssistantInstall

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AssistantInstall

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

Formats the value using the given formatter.

impl Eq for AssistantInstall

impl PartialEq for AssistantInstall

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for AssistantInstall