Trait Callable 

pub trait Callable:
    Send
    + Sync
    + 'static {
    // Required method
    fn call<'life0, 'async_trait>(
        &'life0 self,
        input: Value,
        ctx: CallCtx,
    ) -> Pin<Box<dyn Future<Output = Result<Value, AgentError>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             Self: 'async_trait;

    // Provided method
    fn label(&self) -> &str { ... }
}

The shell exposes Callable from atomr-agents-callable. Anything an agent / workflow / harness can call. Implemented by every executable unit so they’re interchangeable as workflow steps, tool invocations, and team routing targets.

Required Methods

fn call<'life0, 'async_trait>( &'life0 self, input: Value, ctx: CallCtx, ) -> Pin<Box<dyn Future<Output = Result<Value, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Provided Methods

fn label(&self) -> &str

Human-readable label for telemetry. Default falls back to the type name.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl Callable for BoxedDeepResearchHarness

fn call<'life0, 'async_trait>( &'life0 self, input: Value, _ctx: CallCtx, ) -> Pin<Box<dyn Future<Output = Result<Value, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, BoxedDeepResearchHarness: 'async_trait,

fn label(&self) -> &str

impl Callable for DeepResearchHarnessRef

fn call<'life0, 'async_trait>( &'life0 self, input: Value, _ctx: CallCtx, ) -> Pin<Box<dyn Future<Output = Result<Value, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, DeepResearchHarnessRef: 'async_trait,

fn label(&self) -> &str

impl<L, T> Callable for DeepResearchHarness<L, T>

where L: DeepResearchLoopStrategy, T: DeepResearchTermination,

fn call<'life0, 'async_trait>( &'life0 self, input: Value, _ctx: CallCtx, ) -> Pin<Box<dyn Future<Output = Result<Value, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, DeepResearchHarness<L, T>: 'async_trait,

fn label(&self) -> &str

Implementors

impl Callable for Branch

impl Callable for DeepResearchShell

impl Callable for WithConfig

impl Callable for WithFallbacks

impl Callable for WithRetry

impl Callable for WithTimeout

impl<F, Fut> Callable for FnCallable<F>

where F: Fn(Value, CallCtx) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Value, AgentError>> + Send + 'static,