pub struct ToolToRunnableAdapter { /* private fields */ }Expand description
Wraps any Tool as Runnable<serde_json::Value, serde_json::Value>.
Cheap to clone (internal Arc).
Implementations§
Trait Implementations§
Source§impl Clone for ToolToRunnableAdapter
impl Clone for ToolToRunnableAdapter
Source§impl Runnable<Value, Value> for ToolToRunnableAdapter
impl Runnable<Value, Value> for ToolToRunnableAdapter
Source§fn invoke<'life0, 'life1, 'async_trait>(
&'life0 self,
input: Value,
ctx: &'life1 ExecutionContext,
) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn invoke<'life0, 'life1, 'async_trait>(
&'life0 self,
input: Value,
ctx: &'life1 ExecutionContext,
) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Single-shot invocation.
Source§fn name(&self) -> Cow<'_, str>
fn name(&self) -> Cow<'_, str>
Human-readable identifier used by tracing and debug output. Default is
the Rust type name — implementors may override with a domain label
(e.g.
"anthropic-messages", "json-parser").Source§fn batch<'life0, 'life1, 'async_trait>(
&'life0 self,
inputs: Vec<I>,
ctx: &'life1 ExecutionContext,
) -> Pin<Box<dyn Future<Output = Result<Vec<O>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn batch<'life0, 'life1, 'async_trait>(
&'life0 self,
inputs: Vec<I>,
ctx: &'life1 ExecutionContext,
) -> Pin<Box<dyn Future<Output = Result<Vec<O>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Batch invocation. The default runs
invoke sequentially over the input
vector. Implementors that can parallelize (e.g. independent provider
calls) override this.Source§fn stream<'life0, 'life1, 'async_trait>(
&'life0 self,
input: I,
mode: StreamMode,
ctx: &'life1 ExecutionContext,
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'_, Result<StreamChunk<O>>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn stream<'life0, 'life1, 'async_trait>(
&'life0 self,
input: I,
mode: StreamMode,
ctx: &'life1 ExecutionContext,
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'_, Result<StreamChunk<O>>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Auto Trait Implementations§
impl Freeze for ToolToRunnableAdapter
impl !RefUnwindSafe for ToolToRunnableAdapter
impl Send for ToolToRunnableAdapter
impl Sync for ToolToRunnableAdapter
impl Unpin for ToolToRunnableAdapter
impl UnsafeUnpin for ToolToRunnableAdapter
impl !UnwindSafe for ToolToRunnableAdapter
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T, I, O> RunnableExt<I, O> for T
impl<T, I, O> RunnableExt<I, O> for T
Source§fn pipe<P, R>(self, next: R) -> RunnableSequence<I, O, P>
fn pipe<P, R>(self, next: R) -> RunnableSequence<I, O, P>
Chain this runnable into
next. The output O of self
becomes the input of next, producing a Runnable<I, P>. Read moreSource§fn with_retry(self, policy: RetryPolicy) -> Retrying<Self, I, O>where
I: Clone,
fn with_retry(self, policy: RetryPolicy) -> Retrying<Self, I, O>where
I: Clone,
Wrap
self with retry semantics. The returned runnable
re-invokes the inner on transient errors per the policy.
The input must be Clone because each retry receives a
fresh copy. Read moreSource§fn with_fallbacks<F>(self, fallbacks: Vec<F>) -> Fallback<Self, F, I, O>
fn with_fallbacks<F>(self, fallbacks: Vec<F>) -> Fallback<Self, F, I, O>
Wrap
self with an ordered fallback chain. On a transient
error from the primary, the adapter tries each fallback in
turn. Permanent errors surface immediately. The classifier
is the same trait used by Self::with_retry —
entelix_core::transports::DefaultRetryClassifier by default. Read moreSource§fn map<F, P>(self, f: F) -> Mapping<Self, F, I, O, P>
fn map<F, P>(self, f: F) -> Mapping<Self, F, I, O, P>
Map the inner’s output through a pure synchronous function.
Equivalent to piping into a
RunnableLambda but skipping the
async wrapper. Read moreSource§fn with_config<F>(self, configurer: F) -> Configured<Self, F, I, O>
fn with_config<F>(self, configurer: F) -> Configured<Self, F, I, O>
Run
configurer on a cloned ExecutionContext before
delegating to the inner. The caller’s ctx is not mutated. Read moreSource§fn with_timeout(self, timeout: Duration) -> Timed<Self, I, O>
fn with_timeout(self, timeout: Duration) -> Timed<Self, I, O>
Race the inner against a wall-clock timeout. On expiry the
adapter returns
Error::DeadlineExceeded;
caller cancellation still wins. Read moreSource§fn stream_with<'life0, 'life1, 'async_trait>(
&'life0 self,
input: I,
mode: StreamMode,
ctx: &'life1 ExecutionContext,
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'_, Result<StreamChunk<O>>>>> + Send + 'async_trait>>where
Self: Sync + 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn stream_with<'life0, 'life1, 'async_trait>(
&'life0 self,
input: I,
mode: StreamMode,
ctx: &'life1 ExecutionContext,
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'_, Result<StreamChunk<O>>>>> + Send + 'async_trait>>where
Self: Sync + 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Convenience wrapper around
Runnable::stream — same
arguments, no trait import needed at the call site.