pub trait ChunkerTransformer:
Send
+ Sync
+ DynClone {
// Required method
fn transform_node<'life0, 'async_trait>(
&'life0 self,
node: Node,
) -> Pin<Box<dyn Future<Output = IndexingStream> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
// Provided methods
fn concurrency(&self) -> Option<usize> { ... }
fn name(&self) -> &'static str { ... }
}
Expand description
Turns one node into many nodes
Required Methods§
fn transform_node<'life0, 'async_trait>(
&'life0 self,
node: Node,
) -> Pin<Box<dyn Future<Output = IndexingStream> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Provided Methods§
Sourcefn concurrency(&self) -> Option<usize>
fn concurrency(&self) -> Option<usize>
Overrides the default concurrency of the pipeline
fn name(&self) -> &'static str
Trait Implementations§
Source§impl ChunkerTransformer for &dyn ChunkerTransformer
impl ChunkerTransformer for &dyn ChunkerTransformer
fn transform_node<'life0, 'async_trait>(
&'life0 self,
node: Node,
) -> Pin<Box<dyn Future<Output = IndexingStream> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Source§fn concurrency(&self) -> Option<usize>
fn concurrency(&self) -> Option<usize>
Overrides the default concurrency of the pipeline
fn name(&self) -> &'static str
Source§impl ChunkerTransformer for Box<dyn ChunkerTransformer>
impl ChunkerTransformer for Box<dyn ChunkerTransformer>
fn transform_node<'life0, 'async_trait>(
&'life0 self,
node: Node,
) -> Pin<Box<dyn Future<Output = IndexingStream> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Source§fn concurrency(&self) -> Option<usize>
fn concurrency(&self) -> Option<usize>
Overrides the default concurrency of the pipeline