LCOV - code coverage report
Current view:
top level
-
proxy/src/context
- parquet.rs
(
source
/ functions)
Coverage
Total
Hit
Test:
f8d8f5b90fa487a9e82c42da223f012f5d4fece7.info
Lines:
78.8 %
510
402
Test Date:
2024-09-19 20:36:02
Functions:
52.3 %
155
81
Function Name
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::RequestMonitoringInner>>::from
0
<proxy::context::parquet::RequestData as core::convert::From<&proxy::context::RequestMonitoringInner>>::from::{closure#0}
0
<proxy::context::parquet::RequestData as core::convert::From<&proxy::context::RequestMonitoringInner>>::from::{closure#1}
0
<proxy::context::parquet::RequestData as core::convert::From<&proxy::context::RequestMonitoringInner>>::from::{closure#2}
0
<proxy::context::parquet::RequestData as core::convert::From<&proxy::context::RequestMonitoringInner>>::from::{closure#3}
0
proxy::context::parquet::upload_parquet::{closure#0}::{closure#3}
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::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::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::
,
>::from>>::{closure#0}
0
proxy::context::parquet::worker_inner::
,
>::from>>::{closure#0}
0
proxy::context::parquet::worker_inner::
>::{closure#0}
1
proxy::context::parquet::worker_inner::
>>>::{closure#0}
3
<proxy::context::parquet::ParquetUploadArgs as clap_builder::derive::Args>::group_id
6
::augment_args_for_update
0
::group_id
0
::from_arg_matches
0
::update_from_arg_matches
0
::update_from_arg_matches_mut
0
::augment_args
3
::from_arg_matches_mut
3
<proxy::context::parquet::tests::ProxyCliArgs as clap_builder::derive::Args>::group_id
6
::augment_args_for_update
0
::group_id
0
::command_for_update
0
::from_arg_matches
0
::update_from_arg_matches
0
::update_from_arg_matches_mut
0
::augment_args
2
::command
2
::from_arg_matches_mut
2
proxy::context::parquet::tests::random_stream
6
<proxy::context::parquet::ParquetUploadArgs as clap_builder::derive::Args>::augment_args::DEFAULT_VALUE::{closure#0}
12
::augment_args_for_update::DEFAULT_VALUE::{closure#0}
0
::augment_args::DEFAULT_VALUE::{closure#0}
12
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>>::schema
4452085
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>
0
<&[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#10}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#11}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#12}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#13}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#14}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#15}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#16}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#17}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#18}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#19}
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#20}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#21}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#22}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#23}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#24}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#25}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#26}
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#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#5}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#6}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#7}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#8}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::<_>::{closure#9}
0
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::schema
4
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>
81
<&[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#10}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#11}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#12}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#13}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#14}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#15}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#16}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#17}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#18}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#19}
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#20}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#21}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#22}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#23}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#24}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#25}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#26}
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#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
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#5}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#6}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#7}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#8}
159000
<&[proxy::context::parquet::RequestData] as parquet::record::record_writer::RecordWriter
>::write_to_row_group::
>::{closure#9}
159000
Generated by:
LCOV version 2.1-beta