pub struct GraphAgent { /* private fields */ }Available on crate feature
graph only.Expand description
GraphAgent wraps a CompiledGraph as an ADK Agent
Implementations§
Source§impl GraphAgent
impl GraphAgent
Sourcepub fn builder(name: &str) -> GraphAgentBuilder
pub fn builder(name: &str) -> GraphAgentBuilder
Create a new GraphAgent builder
Sourcepub fn from_graph(name: &str, graph: CompiledGraph) -> GraphAgent
pub fn from_graph(name: &str, graph: CompiledGraph) -> GraphAgent
Create directly from a compiled graph
Sourcepub fn graph(&self) -> &CompiledGraph
pub fn graph(&self) -> &CompiledGraph
Get the underlying compiled graph
Sourcepub async fn invoke(
&self,
input: HashMap<String, Value>,
config: ExecutionConfig,
) -> Result<HashMap<String, Value>, GraphError>
pub async fn invoke( &self, input: HashMap<String, Value>, config: ExecutionConfig, ) -> Result<HashMap<String, Value>, GraphError>
Execute the graph directly (bypassing Agent trait)
Sourcepub fn stream(
&self,
input: HashMap<String, Value>,
config: ExecutionConfig,
mode: StreamMode,
) -> impl Stream<Item = Result<StreamEvent, GraphError>>
pub fn stream( &self, input: HashMap<String, Value>, config: ExecutionConfig, mode: StreamMode, ) -> impl Stream<Item = Result<StreamEvent, GraphError>>
Stream execution
Trait Implementations§
Source§impl Agent for GraphAgent
impl Agent for GraphAgent
fn name(&self) -> &str
fn description(&self) -> &str
fn sub_agents(&self) -> &[Arc<dyn Agent>]
fn run<'life0, 'async_trait>(
&'life0 self,
ctx: Arc<dyn InvocationContext>,
) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<Event, AdkError>> + Send>>, AdkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
GraphAgent: 'async_trait,
Auto Trait Implementations§
impl Freeze for GraphAgent
impl !RefUnwindSafe for GraphAgent
impl Send for GraphAgent
impl Sync for GraphAgent
impl Unpin for GraphAgent
impl UnsafeUnpin for GraphAgent
impl !UnwindSafe for GraphAgent
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> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
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 moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::RequestCreates a shared type from an unshared type.