Enum ControlOp

Source

pub enum ControlOp {
    Spawn {
        args: Box<SpawnArgs>,
        reply: Sender<Result<String, String>>,
    },
    Status {
        run_id: String,
        reply: Sender<Option<AgentStatus>>,
    },
    Pause {
        run_id: String,
        reply: Sender<bool>,
    },
    Resume {
        run_id: String,
        reply: Sender<bool>,
    },
    Cancel {
        run_id: String,
        reply: Sender<bool>,
    },
    List {
        reply: Sender<Vec<(String, AgentStatus)>>,
    },
    Message {
        agent_id: String,
        content: String,
        target_region: Option<String>,
        reply: Sender<bool>,
    },
    ListInteractions {
        reply: Sender<Vec<(String, InteractionRequest)>>,
    },
    AnswerInteraction {
        response: InteractionResponse,
        reply: Sender<bool>,
    },
    CancelInteraction {
        request_id: String,
        reply: Sender<bool>,
    },
    Shutdown {
        reply: Sender<bool>,
    },
}

Expand description

A control operation addressed to the host, each carrying a oneshot channel the host replies on. Agents are addressed by run id.

Variants§

§

Spawn

Spawn a new agent. Reply is the run id on success, or an error message.

Fields

§args: Box<SpawnArgs>

The spawn request. Boxed because it is much larger than the other variants’ payloads.

§reply: Sender<Result<String, String>>

Reply channel.

§

Status

The status of a run, or None if there is no such run.

Fields

§run_id: String

The run to query.

§reply: Sender<Option<AgentStatus>>

Reply channel.

§

Pause

Pause a run. Reply is false if there is no such (live) run.

Fields

§run_id: String

The run to pause.

§reply: Sender<bool>

Reply channel.

§

Resume

Resume a paused run. Reply is false if there is no such (live) run.

Fields

§run_id: String

The run to resume.

§reply: Sender<bool>

Reply channel.

§

Cancel

Cancel a run. Reply is false if there is no such (live) run.

Fields

§run_id: String

The run to cancel.

§reply: Sender<bool>

Reply channel.

§

List

List every known live run and its status.

Fields

§reply: Sender<Vec<(String, AgentStatus)>>

Reply channel.

§

Message

Deliver a message to a running agent (by agent id). Reply is false if the world’s message channel is closed.

Fields

§agent_id: String

Target agent id.

§content: String

Message body.

§target_region: Option<String>

Optional target region (defaults to the conversation region).

§reply: Sender<bool>

Reply channel.

§

ListInteractions

List every open interaction awaiting an answer, as (agent_id, request).

Fields

§reply: Sender<Vec<(String, InteractionRequest)>>

Reply channel.

§

AnswerInteraction

Answer an open interaction. Reply is false if no such request is open.

Fields

§response: InteractionResponse

The answer (its request_id selects the interaction).

§reply: Sender<bool>

Reply channel.

§

CancelInteraction

Cancel an open interaction (its asker wakes with a neutral response). Reply is false if no such request is open.

Fields

§request_id: String

The interaction id to cancel.

§reply: Sender<bool>

Reply channel.

§

Shutdown

Shut the daemon down: signal the world’s shutdown so the serve loop returns. Reply is sent (true) before the shutdown is triggered.

Fields

§reply: Sender<bool>

Reply channel.

Auto Trait Implementations§

§

impl UnsafeUnpin for ControlOp

Blanket Implementations§

Source §

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

Source §

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

Source §

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

Source §

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

Source §

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

Source §

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

Mutably borrows from an owned value. Read more

Source §

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source §

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source §

impl<T> ConditionalSend for T
where T: Send,

Source §

impl<T> Downcast for T
where T: Any,

Source §

fn into_any(self: Box<T>) -> Box<dyn Any>

Converts Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.

Source §

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Converts Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.

Source §

fn as_any(&self) -> &(dyn Any + 'static)

Converts &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.

Source §

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Converts &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.

Source §

impl<T> DowncastSend for T
where T: Any + Send,

Source §

fn into_any_send(self: Box<T>) -> Box<dyn Any + Send>

Converts Box<Trait> (where Trait: DowncastSend) to Box<dyn Any + Send>, which can then be downcast into Box<ConcreteType> where ConcreteType implements Trait.

Source §