Struct Executor 

pub struct Executor {
    pub id: String,
    pub owner: String,
    pub current_supervisor: String,
    /* private fields */
}

An executor that processes tasks.

Fields

id: String

Unique identifier

owner: String

Owner supervisor

current_supervisor: String

Current controlling supervisor (may differ if borrowed)

Implementations

impl Executor

pub fn new(id: impl Into<String>, owner: impl Into<String>) -> ExecutorBuilder

Create a new executor with minimal config.

Example

let exe = Executor::new("exe-001", "sup-001")
    .llm(LLMConfig::gemini("gemini-2.0-flash"))
    .build();

pub fn from_config(config: ExecutorConfig) -> Self

Create from full config.

pub async fn state(&self) -> ExecutorState

Get current state.

pub async fn is_idle(&self) -> bool

Check if idle.

pub async fn is_borrowed(&self) -> bool

Check if borrowed.

pub async fn set_busy(&self, task_id: String)

Set state to busy.

pub async fn set_idle(&self)

Set state to idle.

pub async fn set_borrowed( &self, to_supervisor: String, lease_id: String, expires_at: DateTime<Utc>, )

Set state to borrowed.

pub async fn return_to_owner(&mut self)

Return to owner.

pub async fn increment_completed(&self)

Increment completed tasks.

pub async fn increment_failed(&self)

Increment failed tasks.

pub fn capabilities(&self) -> &HashSet<Capability>

Get capabilities.

pub fn has_capability(&self, cap: Capability) -> bool

Check if has capability.

pub fn llm_config(&self) -> &LLMConfig

Get LLM config.

pub async fn execute( &self, system_prompt: &str, user_prompt: &str, ) -> Result<ExecutionResult, ExecutionError>

Execute a task with the LLM.

This makes a real API call to the configured LLM provider.

Example

let result = executor.execute(
    "You are a Rust expert.",
    "Write a function to check if a number is prime."
).await?;

Trait Implementations

impl Debug for Executor

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

Formats the value using the given formatter.