Module ndjson

Re-exports

pub use self::stats::FileStats;

pub use self::stats::Stats;

Modules

errors

stats

Structs

StatsResult

Traits

JSONStats

Functions

apply_settings

Apply pre-processing based on settings from CLI args. Single threaded.

apply_settings_par

Apply pre-processing based on settings from CLI args. Multi-threaded.

expand_jsonpath_query

Handles the jsonpath query expansion of the Iterators values. Single threaded

expand_jsonpath_query_par

Handles the jsonpath query expansion of the Iterators values. Multi-threaded.

limit

Apply line limiting from the arg to the Iterator

parse_iterDeprecated

Early version of apply_settings, kept as an example of alternative version of limit that could be used without the need to Box the return value

parse_ndjson_bufreader

Indexes data from the bufreader, converts it to serde JSON Values and filters out data that does not parse as JSON to the errors container. Single threaded version of parse_ndjson_bufreader_par.

parse_ndjson_bufreader_par

Indexes data from the file_path with a bufreader, converts it to serde JSON Values and filters out data that does not parse as JSON to the errors container. Multithreaded version of parse_ndjson_bufreader.

parse_ndjson_file

Indexes data from the file, converts it to serde JSON Values and filters out data that does not parse as JSON to the errors container. Single threaded.

parse_ndjson_file_path

Indexes data from the file_path, converts it to serde JSON Values and filters out data that does not parse as JSON to the errors container. Single threaded.

parse_ndjson_iter_par

Processes indexed data from the Iterator, converts it to serde JSON Values and filters out data that does not parse as JSON to the errors container.

parse_ndjson_receiver

Indexes data from the mpsc channel, converts it to serde JSON Values and filters out data that does not parse as JSON to the errors container. Single threaded.

parse_ndjson_receiver_par

Indexes data from the mpsc channel, converts it to serde JSON Values and filters out data that does not parse as JSON to the errors container. Multithreaded version of parse_ndjson_receiver.

process_json_iterable

Main function processing the JSON data, collecting key infomation about the content. Single threaded.

process_json_iterable_par

Main function processing the JSON data, collecting key infomation about the content. Mulit-threaded version of process_json_iterable.