Skip to main content

AgentService

tinytown::app::services::agents

Struct AgentService

pub struct AgentService;

Expand description

Service for agent-related operations.

Implementations§

impl AgentService

pub async fn spawn( town: &Town, name: &str, cli: Option<&str>, ) -> Result<SpawnResult>

Spawn a new agent.

pub async fn spawn_with_metadata( town: &Town, name: &str, cli: Option<&str>, role_id: Option<&str>, nickname: Option<&str>, parent_agent_id: Option<AgentId>, spawn_mode: Option<SpawnMode>, ) -> Result<SpawnResult>

Spawn a new agent with extended metadata (role, nickname, parent).

pub async fn list(town: &Town) -> Result<Vec<AgentInfo>>

List all agents with their current status.

pub async fn status(town: &Town) -> Result<TownStatus>

Get town status including all agents.

pub async fn kill(channel: &Channel, agent_id: AgentId) -> Result<()>

Kill (stop) an agent gracefully.

pub async fn stop_all(town: &Town) -> Result<Vec<Agent>>

Request all non-terminal agents in a town to stop gracefully.

pub async fn restart(channel: &Channel, agent_id: AgentId) -> Result<()>

Restart a stopped agent.

pub async fn prune(town: &Town, all: bool) -> Result<Vec<Agent>>

Prune stopped/stale agents.

pub async fn interrupt(channel: &Channel, agent_id: AgentId) -> Result<()>

Interrupt (pause) a running agent.

Sets the agent’s state to Paused. The agent will not pick up new work until resumed.

pub async fn wait( channel: &Channel, agent_id: AgentId, timeout: Option<Duration>, ) -> Result<Agent>

Wait for an agent to reach a terminal state.

Polls the agent state at 1-second intervals until the agent is in a terminal state or the timeout expires. Returns the final agent state.

pub async fn resume(channel: &Channel, agent_id: AgentId) -> Result<()>

Resume a paused agent.

Sets the agent’s state back to Idle so it can accept new work.

pub async fn close(channel: &Channel, agent_id: AgentId) -> Result<()>

Close an agent: drain its current work and then stop.

Sets the agent to Draining state, which means it will finish its current task but won’t accept new work. Then requests a stop.

pub async fn list_open(town: &Town) -> Result<Vec<AgentInfo>>

List all agents that are not in a terminal state.

pub async fn get_result( channel: &Channel, agent_id: AgentId, ) -> Result<Option<Task>>

Get the result of an agent’s most recently completed task.

Auto Trait Implementations§

impl Freeze for AgentService

impl RefUnwindSafe for AgentService

impl Send for AgentService

impl Sync for AgentService

impl Unpin for AgentService

impl UnsafeUnpin for AgentService

impl UnwindSafe for AgentService

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> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

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

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,