pub struct StatefulTool<S: Send + Sync + 'static> { /* private fields */ }Expand description
A generic tool wrapper that manages shared state for stateful closures.
StatefulTool<S> accepts an Arc<S> and a handler closure that receives
the state alongside the tool context and arguments. The Arc<S> is cloned
(cheap reference count bump) on each invocation, so all executions share
the same underlying state.
§Example
use adk_tool::StatefulTool;
use adk_core::{ToolContext, Result};
use serde_json::{json, Value};
use std::sync::Arc;
use tokio::sync::RwLock;
struct Counter { count: RwLock<u64> }
let state = Arc::new(Counter { count: RwLock::new(0) });
let tool = StatefulTool::new(
"increment",
"Increment a counter",
state,
|s, _ctx, _args| async move {
let mut count = s.count.write().await;
*count += 1;
Ok(json!({ "count": *count }))
},
);Implementations§
Source§impl<S: Send + Sync + 'static> StatefulTool<S>
impl<S: Send + Sync + 'static> StatefulTool<S>
Sourcepub fn new<F, Fut>(
name: impl Into<String>,
description: impl Into<String>,
state: Arc<S>,
handler: F,
) -> Self
pub fn new<F, Fut>( name: impl Into<String>, description: impl Into<String>, state: Arc<S>, handler: F, ) -> Self
Create a new stateful tool.
§Arguments
name- Tool name exposed to the LLMdescription- Human-readable description of what the tool doesstate- Shared state wrapped inArc<S>handler- Async closure receiving(Arc<S>, Arc<dyn ToolContext>, Value)
Sourcepub fn with_long_running(self, long_running: bool) -> Self
pub fn with_long_running(self, long_running: bool) -> Self
Mark this tool as long-running (prevents duplicate invocations).
Sourcepub fn with_read_only(self, read_only: bool) -> Self
pub fn with_read_only(self, read_only: bool) -> Self
Mark this tool as read-only (safe for parallel dispatch).
Sourcepub fn with_concurrency_safe(self, concurrency_safe: bool) -> Self
pub fn with_concurrency_safe(self, concurrency_safe: bool) -> Self
Mark this tool as concurrency-safe (can run in parallel with other tools).
Sourcepub fn with_parameters_schema<T>(self) -> Selfwhere
T: JsonSchema + Serialize,
pub fn with_parameters_schema<T>(self) -> Selfwhere
T: JsonSchema + Serialize,
Derive the parameters JSON Schema from a type implementing JsonSchema.
Sourcepub fn with_response_schema<T>(self) -> Selfwhere
T: JsonSchema + Serialize,
pub fn with_response_schema<T>(self) -> Selfwhere
T: JsonSchema + Serialize,
Derive the response JSON Schema from a type implementing JsonSchema.
Sourcepub fn with_scopes(self, scopes: &[&'static str]) -> Self
pub fn with_scopes(self, scopes: &[&'static str]) -> Self
Declare the scopes required to execute this tool.
When set, the framework will enforce that the calling user possesses
all listed scopes before dispatching execute().
Sourcepub fn parameters_schema(&self) -> Option<&Value>
pub fn parameters_schema(&self) -> Option<&Value>
Get the parameters schema, if set.
Sourcepub fn response_schema(&self) -> Option<&Value>
pub fn response_schema(&self) -> Option<&Value>
Get the response schema, if set.
Trait Implementations§
Source§impl<S: Send + Sync + 'static> Tool for StatefulTool<S>
impl<S: Send + Sync + 'static> Tool for StatefulTool<S>
Source§fn description(&self) -> &str
fn description(&self) -> &str
Source§fn enhanced_description(&self) -> String
fn enhanced_description(&self) -> String
Source§fn is_long_running(&self) -> bool
fn is_long_running(&self) -> bool
Source§fn is_read_only(&self) -> bool
fn is_read_only(&self) -> bool
Source§fn is_concurrency_safe(&self) -> bool
fn is_concurrency_safe(&self) -> bool
Source§fn parameters_schema(&self) -> Option<Value>
fn parameters_schema(&self) -> Option<Value>
Source§fn response_schema(&self) -> Option<Value>
fn response_schema(&self) -> Option<Value>
Source§fn required_scopes(&self) -> &[&str]
fn required_scopes(&self) -> &[&str]
Source§fn execute<'life0, 'async_trait>(
&'life0 self,
ctx: Arc<dyn ToolContext>,
args: Value,
) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn execute<'life0, 'async_trait>(
&'life0 self,
ctx: Arc<dyn ToolContext>,
args: Value,
) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Source§fn declaration(&self) -> Value
fn declaration(&self) -> Value
Source§fn is_builtin(&self) -> bool
fn is_builtin(&self) -> bool
google_search, url_context). Read more