LCOV - code coverage report
Current view: top level - proxy/src/context - parquet.rs (source / functions) Coverage Total Hit
Test: 5fe7fa8d483b39476409aee736d6d5e32728bfac.info Lines: 78.0 % 519 405
Test Date: 2025-03-12 16:10:49 Functions: 55.3 % 103 57

Function Name Sort by function name Hit count Sort by function hit count
<proxy::context::parquet::Options as serde::ser::Serialize>::serialize::<&mut serde_json::ser::Serializer<&mut alloc::vec::Vec<u8>>> 0
<proxy::context::parquet::ParquetUploadArgs as clap_builder::derive::FromArgMatches>::from_arg_matches_mut::{closure#0} 0
::from_arg_matches_mut::{closure#0} 0
::update_from_arg_matches_mut::{closure#0} 0
<proxy::context::parquet::ParquetUploadArgs as clap_builder::derive::FromArgMatches>::from_arg_matches_mut::{closure#1} 0
::from_arg_matches_mut::{closure#1} 0
::update_from_arg_matches_mut::{closure#1} 0
<proxy::context::parquet::ParquetUploadArgs as clap_builder::derive::FromArgMatches>::from_arg_matches_mut::{closure#2} 0
::from_arg_matches_mut::{closure#2} 0
::update_from_arg_matches_mut::{closure#2} 0
<proxy::context::parquet::ParquetUploadArgs as clap_builder::derive::FromArgMatches>::from_arg_matches_mut::{closure#3} 0
::from_arg_matches_mut::{closure#3} 0
::update_from_arg_matches_mut::{closure#3} 0
<proxy::context::parquet::ParquetUploadArgs as clap_builder::derive::FromArgMatches>::from_arg_matches_mut::{closure#4} 0
::from_arg_matches_mut::{closure#4} 0
::update_from_arg_matches_mut::{closure#4} 0
<proxy::context::parquet::RequestData as core::convert::From<&proxy::context::RequestContextInner>>::from 0
<proxy::context::parquet::RequestData as core::convert::From<&proxy::context::RequestContextInner>>::from::{closure#0} 0
<proxy::context::parquet::RequestData as core::convert::From<&proxy::context::RequestContextInner>>::from::{closure#1} 0
<proxy::context::parquet::RequestData as core::convert::From<&proxy::context::RequestContextInner>>::from::{closure#2} 0
<proxy::context::parquet::RequestData as core::convert::From<&proxy::context::RequestContextInner>>::from::{closure#3} 0
proxy::context::parquet::upload_parquet::{closure#0}::{closure#3} 0
proxy::context::parquet::upload_parquet::{closure#0}::{closure#5} 0
proxy::context::parquet::worker 0
proxy::context::parquet::worker::{closure#0} 0
proxy::context::parquet::worker::{closure#0}::{closure#0} 0
proxy::context::parquet::worker::{closure#0}::{closure#1} 0
proxy::context::parquet::worker::{closure#0}::{closure#2} 0
proxy::context::parquet::worker::{closure#0}::{closure#3} 0
proxy::context::parquet::worker::{closure#0}::{closure#4} 0
proxy::context::parquet::worker_inner::<futures_util::stream::stream::map::Map<futures_util::stream::poll_fn::PollFn<proxy::context::parquet::worker::{closure#0}::{closure#1}>, <proxy::context::parquet::RequestData as core::convert::From<proxy::context::parquet::RequestData>>::from>>::{closure#0} 0
proxy::context::parquet::worker_inner::, >::from>>::{closure#0} 0
proxy::context::parquet::worker_inner::, >::from>>::{closure#0} 0
proxy::context::parquet::tests::default_parser 1
proxy::context::parquet::tests::full_parser 1
proxy::context::parquet::tests::verify_parquet_regular_upload::{closure#0}::{closure#0} 1
proxy::context::parquet::tests::verify_parquet_no_compression 2
proxy::context::parquet::tests::verify_parquet_no_compression 1
proxy::context::parquet::tests::verify_parquet_no_compression::{closure#0} 1
proxy::context::parquet::tests::verify_parquet_regular_upload 2
proxy::context::parquet::tests::verify_parquet_regular_upload 1
proxy::context::parquet::tests::verify_parquet_regular_upload::{closure#0} 1
proxy::context::parquet::tests::verify_parquet_strong_compression 2
proxy::context::parquet::tests::verify_parquet_strong_compression 1
proxy::context::parquet::tests::verify_parquet_strong_compression::{closure#0} 1
proxy::context::parquet::tests::verify_parquet_unreliable_upload 2
proxy::context::parquet::tests::verify_parquet_unreliable_upload 1
proxy::context::parquet::tests::verify_parquet_unreliable_upload::{closure#0} 1
<proxy::context::parquet::ParquetUploadArgs as clap_builder::derive::Args>::augment_args::{closure#0} 3
::augment_args_for_update::{closure#0} 0
::augment_args::{closure#0} 3
<proxy::context::parquet::ParquetUploadArgs as clap_builder::derive::Args>::augment_args::{closure#1} 3
::augment_args_for_update::{closure#1} 0
::augment_args::{closure#1} 3
<proxy::context::parquet::ParquetUploadArgs as clap_builder::derive::Args>::augment_args::{closure#2} 3
::augment_args_for_update::{closure#2} 0
::augment_args::{closure#2} 3
<proxy::context::parquet::ParquetUploadArgs as clap_builder::derive::Args>::augment_args::{closure#3} 3
::augment_args_for_update::{closure#3} 0
::augment_args::{closure#3} 3
proxy::context::parquet::tests::run_test::<futures_util::stream::poll_fn::PollFn<proxy::context::parquet::tests::verify_parquet_regular_upload::{closure#0}::{closure#1}>> 4
proxy::context::parquet::tests::run_test::> 1
proxy::context::parquet::tests::run_test::>>> 3
proxy::context::parquet::tests::run_test::<futures_util::stream::poll_fn::PollFn<proxy::context::parquet::tests::verify_parquet_regular_upload::{closure#0}::{closure#1}>>::{closure#0} 4
proxy::context::parquet::tests::run_test::>::{closure#0} 1
proxy::context::parquet::tests::run_test::>>>::{closure#0} 3
proxy::context::parquet::worker_inner::<_> 4
proxy::context::parquet::worker_inner::<_> 0
proxy::context::parquet::worker_inner::, >::from>> 0
proxy::context::parquet::worker_inner::, >::from>> 0
proxy::context::parquet::worker_inner::> 1
proxy::context::parquet::worker_inner::>>> 3
proxy::context::parquet::worker_inner::<_>::{closure#0} 4
proxy::context::parquet::worker_inner::<_>::{closure#0} 0
proxy::context::parquet::worker_inner::>::{closure#0} 1
proxy::context::parquet::worker_inner::>>>::{closure#0} 3
proxy::context::parquet::tests::random_stream 6
proxy::context::parquet::tests::run_test::<futures_util::stream::poll_fn::PollFn<proxy::context::parquet::tests::verify_parquet_regular_upload::{closure#0}::{closure#1}>>::{closure#0}::{closure#2} 26
proxy::context::parquet::tests::run_test::>::{closure#0}::{closure#2} 3
proxy::context::parquet::tests::run_test::>>>::{closure#0}::{closure#2} 23
proxy::context::parquet::tests::run_test::<futures_util::stream::poll_fn::PollFn<proxy::context::parquet::tests::verify_parquet_regular_upload::{closure#0}::{closure#1}>>::{closure#0}::{closure#3} 26
proxy::context::parquet::tests::run_test::>::{closure#0}::{closure#3} 3
proxy::context::parquet::tests::run_test::>>>::{closure#0}::{closure#3} 23
proxy::context::parquet::tests::run_test::<futures_util::stream::poll_fn::PollFn<proxy::context::parquet::tests::verify_parquet_regular_upload::{closure#0}::{closure#1}>>::{closure#0}::{closure#4} 26
proxy::context::parquet::tests::run_test::>::{closure#0}::{closure#4} 3
proxy::context::parquet::tests::run_test::>>>::{closure#0}::{closure#4} 23
proxy::context::parquet::tests::run_test::<futures_util::stream::poll_fn::PollFn<proxy::context::parquet::tests::verify_parquet_regular_upload::{closure#0}::{closure#1}>>::{closure#0}::{closure#5} 26
proxy::context::parquet::tests::run_test::>::{closure#0}::{closure#5} 3
proxy::context::parquet::tests::run_test::>>>::{closure#0}::{closure#5} 23
proxy::context::parquet::upload_parquet 26
proxy::context::parquet::upload_parquet::{closure#0} 26
proxy::context::parquet::upload_parquet::{closure#0}::{closure#1} 26
proxy::context::parquet::upload_parquet::{closure#0}::{closure#4} 26
proxy::context::parquet::upload_parquet::{closure#0}::{closure#2} 38
proxy::context::parquet::upload_parquet::{closure#0}::{closure#2}::{closure#0} 38
proxy::context::parquet::tests::run_test::<futures_util::stream::poll_fn::PollFn<proxy::context::parquet::tests::verify_parquet_regular_upload::{closure#0}::{closure#1}>>::{closure#0}::{closure#0} 46
proxy::context::parquet::tests::run_test::>::{closure#0}::{closure#0} 8
proxy::context::parquet::tests::run_test::>>>::{closure#0}::{closure#0} 38
proxy::context::parquet::tests::run_test::<futures_util::stream::poll_fn::PollFn<proxy::context::parquet::tests::verify_parquet_regular_upload::{closure#0}::{closure#1}>>::{closure#0}::{closure#1} 46
proxy::context::parquet::tests::run_test::>::{closure#0}::{closure#1} 8
proxy::context::parquet::tests::run_test::>>>::{closure#0}::{closure#1} 38
proxy::context::parquet::flush_rows::<_> 81
proxy::context::parquet::flush_rows::<_> 0
proxy::context::parquet::flush_rows::> 81
proxy::context::parquet::flush_rows::<_>::{closure#0} 81
proxy::context::parquet::flush_rows::<_>::{closure#0} 0
proxy::context::parquet::flush_rows::>::{closure#0} 81
proxy::context::parquet::flush_rows::<_>::{closure#0}::{closure#0} 81
proxy::context::parquet::flush_rows::<_>::{closure#0}::{closure#0} 0
proxy::context::parquet::flush_rows::>::{closure#0}::{closure#0} 81
proxy::context::parquet::upload_parquet::{closure#0}::{closure#0} 81
proxy::context::parquet::tests::verify_parquet_regular_upload::{closure#0}::{closure#1} 9071
proxy::context::parquet::tests::generate_request_data::<rand::rngs::std::StdRng> 159000
proxy::context::parquet::tests::random_stream::{closure#0} 159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter<proxy::context::parquet::RequestData>>::write_to_row_group::<_>::{closure#0} 1272000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::<_>::{closure#0} 0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::<_>::{closure#1} 0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::<_>::{closure#27} 0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::<_>::{closure#28} 0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::<_>::{closure#29} 0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::<_>::{closure#2} 0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::<_>::{closure#3} 0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::<_>::{closure#4} 0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::>::{closure#0} 159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::>::{closure#1} 159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::>::{closure#27} 159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::>::{closure#28} 159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::>::{closure#29} 159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::>::{closure#2} 159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::>::{closure#3} 159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter>::write_to_row_group::>::{closure#4} 159000

Generated by: LCOV version 2.1-beta