Struct streamson_lib::handler::indexer::Indexer

pub struct Indexer { /* fields omitted */ }

Indexer handler responsible for storing index of the matches

Implementations

impl Indexer

pub fn new() -> Self

Creates a new handler which stores indexes within itself

pub fn set_use_path(self, use_path: bool) -> Self

Set whether to show path

Arguments

• use_path - should path be store with data

Example

use streamson_lib::handler;
let file = handler::Indexer::new().set_use_path(true);

pub fn pop(&mut self) -> Option<(Option<String>, Output)>

Pops the oldest value in the buffer

Returns

• None - queue is empty
• Some((path, output)) - stored data remove from the queue and returned

Example

use streamson_lib::handler;
let mut indexer = handler::Indexer::new().set_use_path(true);
while let Some((path, output)) = indexer.pop() {
    // Do something with the data
    println!("{} ({:?})", path.unwrap(), output);
}

Trait Implementations

impl Debug for Indexer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Indexer

fn default() -> Self

Returns the "default value" for a type.

impl Handler for Indexer

fn handle(
    &mut self,
    _path: &Path,
    _matcher_idx: usize,
    _data: Option<&[u8]>
) -> Result<(), Handler>

Calls handler on matched data

fn handle_idx(
    &mut self,
    path: &Path,
    _matcher_idx: usize,
    idx: Output
) -> Result<(), Handler>

Calls when an index occured

fn use_path(&self) -> bool

Should path be used

fn buffering_required(&self) -> bool

If true is returned a buffer will be used to store input data when matcher matches

fn separator(&self) -> &str

A str which will be used to separate records