LlmAgent

Struct LlmAgent 

Source
pub struct LlmAgent { /* private fields */ }
Expand description

An agent that uses an LLM (Large Language Model) to process messages.

The LlmAgent integrates with the Ceylon Mesh agent system and delegates message processing to an LLM. It supports:

  • Configurable system prompts
  • Model parameters (temperature, max tokens, etc.)
  • Tool calling integration with existing ToolInvoker
  • Multiple LLM providers (OpenAI, Anthropic, Ollama, etc.)
  • Optional memory module integration

§Examples

use runtime::llm::{LlmAgent, LLMConfig};

// Create agent with Ollama (local, no API key needed)
let agent = LlmAgent::builder("my_agent", "ollama::llama2")
    .with_system_prompt("You are a helpful assistant.")
    .build()
    .expect("Failed to create agent");

// Create agent with OpenAI
let agent = LlmAgent::builder("gpt_agent", "openai::gpt-4")
    .with_api_key(std::env::var("OPENAI_API_KEY").unwrap())
    .with_temperature(0.7)
    .build()
    .expect("Failed to create agent");

Implementations§

Source§

impl LlmAgent

Source

pub fn builder( name: impl Into<String>, model: impl Into<String>, ) -> LlmAgentBuilder

Create a builder for constructing an LlmAgent.

§Arguments
  • name - The name of the agent
  • model - The model in “provider::model” format (e.g., “openai::gpt-4”, “ollama::llama2”)
§Examples
use runtime::llm::LlmAgent;

let agent = LlmAgent::builder("my_agent", "ollama::llama2")
    .build()
    .expect("Failed to create agent");
Source

pub fn new_with_config( name: impl Into<String>, config: LLMConfig, system_prompt: impl Into<String>, memory: Option<Arc<dyn Memory>>, ) -> Result<LlmAgent, Error>

Create an LlmAgent with comprehensive LLMConfig

Source

pub fn with_react(&mut self, config: ReActConfig)

Enable ReAct (Reason + Act) mode

Source

pub async fn send_message_react( &mut self, message: impl Into<String>, ctx: &mut AgentContext, ) -> Result<ReActResult, Error>

Send a message using ReAct reasoning mode

Source

pub async fn send_message_and_get_response( &mut self, message: impl Into<String>, ctx: &mut AgentContext, ) -> Result<String, Error>

Send a message and get the LLM’s response This is a convenience method for Python bindings and direct usage. It processes the message with the LLM and returns the response text.

Source

pub fn last_response(&self) -> Option<String>

Get the last assistant response from conversation history

Trait Implementations§

Source§

impl Agent for LlmAgent

Source§

fn name(&self) -> String

Returns the unique name of this agent. Read more
Source§

fn on_message<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: Message, ctx: &'life1 mut AgentContext, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, LlmAgent: 'async_trait,

Called when a binary message is received. Read more
Source§

fn on_generic_message<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: GenericMessage, ctx: &'life1 mut AgentContext, ) -> Pin<Box<dyn Future<Output = Result<GenericResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, LlmAgent: 'async_trait,

Handle a generic string message and return a response. Read more
Source§

fn tool_invoker(&self) -> Option<&ToolInvoker>

Get the tool invoker for this agent (if it has actions). Read more
Source§

fn tool_invoker_mut(&mut self) -> Option<&mut ToolInvoker>

Get mutable tool invoker for dynamic tool registration.
Source§

fn on_start<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut AgentContext, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Called when the agent starts. Read more
Source§

fn on_stop<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut AgentContext, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Called when the agent is stopping. Read more
Source§

impl LlmAgentFromConfig for LlmAgent

Source§

fn from_config(config: AgentConfig) -> Result<LlmAgent>

Create an LlmAgent from an AgentConfig.

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

Source§

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

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

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

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
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
Source§

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