pub struct MapOver {
pub agent: AgentBuilder,
pub list_key: String,
pub item_key: String,
pub output_key: String,
pub name: Option<String>,
}Expand description
A map-over workflow node — applies one agent to many items. Build with
map_over; compiles to MapOverTextAgent.
Fields§
§agent: AgentBuilderThe agent template applied to each item.
list_key: StringState key holding the JSON array to iterate.
item_key: StringState key the current item is written to (default "_item").
output_key: StringState key the collected outputs are written to (default "_results").
name: Option<String>Name given to the compiled agent (default "map_over").
Implementations§
Source§impl MapOver
impl MapOver
Sourcepub fn new(agent: AgentBuilder, list_key: impl Into<String>) -> Self
pub fn new(agent: AgentBuilder, list_key: impl Into<String>) -> Self
Create a map-over node for agent over the list at list_key.
Sourcepub fn item_key(self, key: impl Into<String>) -> Self
pub fn item_key(self, key: impl Into<String>) -> Self
State key the current item is written to for each run.
Sourcepub fn output_key(self, key: impl Into<String>) -> Self
pub fn output_key(self, key: impl Into<String>) -> Self
State key the collected outputs are written to.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for MapOver
impl !RefUnwindSafe for MapOver
impl Send for MapOver
impl Sync for MapOver
impl Unpin for MapOver
impl !UnwindSafe for MapOver
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,
§impl<S> FromSample<S> for S
impl<S> FromSample<S> for S
fn from_sample_(s: S) -> S
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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 more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].