Struct Extract 

pub struct Extract { /* private fields */ }

Implementations

impl Extract

pub fn new() -> Self

Creates a new Extract

It exracts matched data parts (not nested)

pub fn set_export_path(self, export: bool) -> Self

Sets whether matched path should be exported with data Output data will be enriched with the path from were the data were extracted

if path is not exported extraction can be a bit faster

pub fn add_matcher( &mut self, matcher: Box<dyn Matcher>, handler: Option<Arc<Mutex<dyn Handler>>>, )

Adds new matcher for data extraction

Arguments

• matcher - matcher which matches the path
• handler - optinal handler to be used to process data

Example

use streamson_lib::{strategy, matcher};
use std::sync::{Arc, Mutex};

let mut extract = strategy::Extract::new();
let matcher = matcher::Simple::new(r#"{"list"}[]"#).unwrap();
let mut extract = strategy::Extract::new();
extract.add_matcher(
    Box::new(matcher),
    None,
);

Trait Implementations

impl Default for Extract

fn default() -> Self

Returns the “default value” for a type.

impl Strategy for Extract

fn process(&mut self, input: &[u8]) -> Result<Vec<Output>, General>

Processes input data

fn terminate(&mut self) -> Result<Vec<Output>, General>

Should be called when input data terminates