Struct streamson_lib::strategy::convert::Convert

pub struct Convert { /* fields omitted */ }

Processes data from input and triggers handlers

Implementations

impl Convert

pub fn new() -> Self

Creates a new Convert

It should replace a parts of the JSON using custom bytes data are read.

pub fn add_matcher(
    &mut self,
    matcher: Box<dyn MatchMaker>,
    convert_function: Box<dyn Fn(&Path, &[u8]) -> Vec<u8>>
)

Adds a mathcher and a handler to Convert

Arguments

• matcher - matcher which matches the path
• convert_function - funtions which performs the conversion

Example

use streamson_lib::{strategy, matcher, handler};

let mut convert = strategy::Convert::new();

let matcher = matcher::Simple::new(r#"{"list"}[]"#).unwrap();
convert.add_matcher(
    Box::new(matcher),
    Box::new(|_, _| vec![b'"', b'.', b'.', b'.', b'"'])
);

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

Processes input data

Arguments

• input - input data

Returns

• `Ok(_) processing passed, more data might be needed
• Err(_) when input is not correct json

Example

use streamson_lib::{strategy, matcher};

let mut convert = strategy::Convert::new();
let matcher = matcher::Simple::new(r#"{"password"}"#).unwrap();
convert.add_matcher(
    Box::new(matcher),
    Box::new(|_, _| vec![b'"', b'*', b'*', b'*', b'"'])
);

let data = convert.process(br#"{"password": "secret"}"#).unwrap();
for part in data {
    // Do something with converted data
}

Errors

If parsing logic finds that JSON is not valid, it returns error::General.

Trait Implementations

impl Default for Convert

fn default() -> Self

Returns the "default value" for a type.