pub struct PassthroughNode { /* private fields */ }Available on crate feature
graph only.Expand description
Passthrough node - just passes state through unchanged
Implementations§
Source§impl PassthroughNode
impl PassthroughNode
Sourcepub fn new(name: &str) -> PassthroughNode
pub fn new(name: &str) -> PassthroughNode
Create a new passthrough node
Trait Implementations§
Source§impl Node for PassthroughNode
impl Node for PassthroughNode
Source§fn execute<'life0, 'life1, 'async_trait>(
&'life0 self,
_ctx: &'life1 NodeContext,
) -> Pin<Box<dyn Future<Output = Result<NodeOutput, GraphError>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
PassthroughNode: 'async_trait,
fn execute<'life0, 'life1, 'async_trait>(
&'life0 self,
_ctx: &'life1 NodeContext,
) -> Pin<Box<dyn Future<Output = Result<NodeOutput, GraphError>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
PassthroughNode: 'async_trait,
Execute the node and return state updates
Auto Trait Implementations§
impl Freeze for PassthroughNode
impl RefUnwindSafe for PassthroughNode
impl Send for PassthroughNode
impl Sync for PassthroughNode
impl Unpin for PassthroughNode
impl UnwindSafe for PassthroughNode
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> 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::Request