Struct streamson_lib::strategy::extract::Extract

pub struct Extract { /* fields omitted */ }

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 path should be exported with data

if path is not exported extraction can be a bit faster

pub fn add_matcher(&mut self, matcher: Box<dyn MatchMaker>)

Adds new matcher for data extraction

Arguments

• matcher - matcher which matches the path

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),
);

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

Processes input data

Returns

• Ok(Vec<(Some(r#"{"users"}[0]"#), Vec<u8>)>) vector containing path and data
• Ok(Vec<(None, Vec<u8>)>) vector data only
• Err(_) when input is not correct json

Example

use streamson_lib::strategy;

let mut extract = strategy::Extract::new();
extract.process(br#"{}"#);

Errors

• Error is triggered when incorrect json is detected Note that not all json errors are detected

Trait Implementations

impl Default for Extract

pub fn default() -> Self

Returns the "default value" for a type.