Skip to main content

Runner

Struct Runner 

Source
pub struct Runner { /* private fields */ }

Implementations§

Source§

impl Runner

Source

pub fn builder() -> RunnerConfigBuilder<NoAppName, NoAgent, NoSessionService>

Create a typestate builder for constructing a Runner.

The builder enforces at compile time that the three required fields (app_name, agent, session_service) are set before build() is callable.

§Example
let runner = Runner::builder()
    .app_name("my-app")
    .agent(agent)
    .session_service(session_service)
    .build()?;
Source

pub fn new(config: RunnerConfig) -> Result<Self>

Source

pub fn with_skill_injector(self, injector: SkillInjector) -> Self

Enable skill injection using a pre-built injector.

Skill injection runs before plugin on_user_message callbacks.

Source

pub fn with_auto_skills( self, root: impl AsRef<Path>, config: SkillInjectorConfig, ) -> SkillResult<Self>

👎Deprecated:

Use with_auto_skills_mut instead

Enable skill injection by auto-loading .skills/ from the given root path.

Source

pub fn with_auto_skills_mut( &mut self, root: impl AsRef<Path>, config: SkillInjectorConfig, ) -> SkillResult<()>

Enable skill injection by auto-loading .skills/ from the given root path.

Unlike with_auto_skills, this method borrows the Runner mutably instead of consuming it. On error, the Runner remains valid with no skill injector configured.

Source

pub async fn run( &self, user_id: UserId, session_id: SessionId, user_content: Content, ) -> Result<EventStream>

Source

pub async fn run_str( &self, user_id: &str, session_id: &str, user_content: Content, ) -> Result<EventStream>

Convenience method that accepts string arguments.

Converts user_id and session_id to their typed equivalents and delegates to run().

§Errors

Returns an error if either string fails identity validation (empty, contains null bytes, or exceeds length limit).

Source

pub fn find_agent_to_run( root_agent: &Arc<dyn Agent>, session: &dyn Session, ) -> Arc<dyn Agent>

Find which agent should handle the request based on session history

Source

pub fn find_agent( current: &Arc<dyn Agent>, target_name: &str, ) -> Option<Arc<dyn Agent>>

Recursively search agent tree for agent with given name

Source

pub fn compute_transfer_context( root: &Arc<dyn Agent>, target_name: &str, ) -> (Option<String>, Vec<String>)

Compute the parent name and peer names for a given agent in the tree. Returns (parent_name, peer_names).

Walks the agent tree to find the parent of target_name, then collects the parent’s name and the sibling agent names (excluding the target itself).

Auto Trait Implementations§

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

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

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

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

fn in_current_span(self) -> Instrumented<Self>

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

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

Source§

fn into(self) -> U

Calls U::from(self).

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

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

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

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

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
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

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