pub struct BooleanParser;Expand description
Parses common yes/no representations into bool. Case-insensitive,
whitespace tolerant. Anything else errors with
CognisError::Serialization.
Implementations§
Source§impl BooleanParser
impl BooleanParser
Trait Implementations§
Source§impl Clone for BooleanParser
impl Clone for BooleanParser
Source§fn clone(&self) -> BooleanParser
fn clone(&self) -> BooleanParser
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for BooleanParser
impl Debug for BooleanParser
Source§impl Default for BooleanParser
impl Default for BooleanParser
Source§fn default() -> BooleanParser
fn default() -> BooleanParser
Returns the “default value” for a type. Read more
Source§impl OutputParser<bool> for BooleanParser
impl OutputParser<bool> for BooleanParser
Source§impl Runnable<String, bool> for BooleanParser
impl Runnable<String, bool> for BooleanParser
Source§fn invoke<'life0, 'async_trait>(
&'life0 self,
input: String,
__arg2: RunnableConfig,
) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn invoke<'life0, 'async_trait>(
&'life0 self,
input: String,
__arg2: RunnableConfig,
) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
One-shot invocation. The hot path.
Source§fn batch<'life0, 'async_trait>(
&'life0 self,
inputs: Vec<I>,
config: RunnableConfig,
) -> Pin<Box<dyn Future<Output = Result<Vec<O>>> + Send + 'async_trait>>
fn batch<'life0, 'async_trait>( &'life0 self, inputs: Vec<I>, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Vec<O>>> + Send + 'async_trait>>
Run multiple inputs in parallel. Defaults to
buffer_unordered
honouring config.max_concurrency.Source§fn stream<'life0, 'async_trait>(
&'life0 self,
input: I,
config: RunnableConfig,
) -> Pin<Box<dyn Future<Output = Result<RunnableStream<O>>> + Send + 'async_trait>>
fn stream<'life0, 'async_trait>( &'life0 self, input: I, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<RunnableStream<O>>> + Send + 'async_trait>>
Stream the final output (chunks of
O). Default emits one item via
invoke — non-streaming runnables are correct without override.Source§fn stream_events<'life0, 'async_trait>(
&'life0 self,
input: I,
config: RunnableConfig,
) -> Pin<Box<dyn Future<Output = Result<EventStream>> + Send + 'async_trait>>
fn stream_events<'life0, 'async_trait>( &'life0 self, input: I, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<EventStream>> + Send + 'async_trait>>
Stream structured events. Default emits OnStart + OnEnd around an
invoke call. Graph engines override to surface per-node events.Source§fn input_schema(&self) -> Option<Value>
fn input_schema(&self) -> Option<Value>
JSON Schema for the input type, if known.
Source§fn output_schema(&self) -> Option<Value>
fn output_schema(&self) -> Option<Value>
JSON Schema for the output type, if known.
impl Copy for BooleanParser
Auto Trait Implementations§
impl Freeze for BooleanParser
impl RefUnwindSafe for BooleanParser
impl Send for BooleanParser
impl Sync for BooleanParser
impl Unpin for BooleanParser
impl UnsafeUnpin for BooleanParser
impl UnwindSafe for BooleanParser
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<R, I, O> RunnableExt<I, O> for R
impl<R, I, O> RunnableExt<I, O> for R
Source§fn pipe<R2, O2>(self, next: R2) -> Pipe<Self, R2, I, O, O2>
fn pipe<R2, O2>(self, next: R2) -> Pipe<Self, R2, I, O, O2>
Pipe this runnable into another, building a
Pipe<Self, Next>.Source§fn with_retry(self, policy: RetryPolicy) -> Retry<Self, I, O>where
I: Clone,
fn with_retry(self, policy: RetryPolicy) -> Retry<Self, I, O>where
I: Clone,
Wrap with a retry policy.
Source§fn with_max_retries(self, attempts: u32) -> Retry<Self, I, O>where
I: Clone,
fn with_max_retries(self, attempts: u32) -> Retry<Self, I, O>where
I: Clone,
Shortcut: retry with default policy and N attempts.
Source§fn with_timeout(self, duration: Duration) -> Timeout<Self, I, O>
fn with_timeout(self, duration: Duration) -> Timeout<Self, I, O>
Wrap with a per-call timeout.
Source§fn with_fallback<F>(self, fallback: F) -> Fallback<Self, F, I, O>
fn with_fallback<F>(self, fallback: F) -> Fallback<Self, F, I, O>
Wrap with a fallback runnable.
Source§fn with_memory_cache<K, F>(
self,
key_fn: F,
) -> Cache<Self, I, O, K, MemoryCache<K, O>>
fn with_memory_cache<K, F>( self, key_fn: F, ) -> Cache<Self, I, O, K, MemoryCache<K, O>>
Wrap with an in-memory cache keyed by
key_fn(&I).