|
Function Name  |
Hit count  |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#0} |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>> |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0} |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#0} |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#0}::{closure#0} |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#1} |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#2} |
0 |
| <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts::<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#2}::{closure#0} |
0 |
| <safekeeper::send_wal::EndWatch>::view |
0 |
| <safekeeper::send_wal::EndWatchView>::get |
0 |
| <safekeeper::send_wal::ReplyReader<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::handle_feedback::{closure#0} |
0 |
| <safekeeper::send_wal::ReplyReader<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0} |
0 |
| <safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::run::{closure#0} |
0 |
| <safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_for_lsn |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_for_lsn |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_for_lsn::{closure#0} |
0 |
| <safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_for_lsn::{closure#0}::{closure#0} |
0 |
| <safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_for_lsn::{closure#0}::{closure#0}::{closure#0} |
0 |
| <safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_for_lsn::{closure#0}::{closure#1} |
0 |
| <safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal |
0 |
| >, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal::{closure#0} |
0 |
| <safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal::{closure#0}::{closure#0} |
0 |
| <safekeeper::send_wal::WalSender<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>>::wait_wal::{closure#0}::{closure#0}::{closure#0} |
0 |
| <safekeeper::send_wal::WalSenderGuard as core::ops::drop::Drop>::drop |
0 |
| <safekeeper::send_wal::WalSenderGuard>::id |
0 |
| <safekeeper::send_wal::WalSenderGuard>::walsenders |
0 |
| <safekeeper::send_wal::WalSenderState>::get_addr |
0 |
| <safekeeper::send_wal::WalSenderState>::get_mut_feedback |
0 |
| <safekeeper::send_wal::WalSenders>::create_or_update_interpreted_reader::<<safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#0}, <safekeeper::handler::SafekeeperPostgresHandler>::handle_start_replication_guts<utils::measured_stream::MeasuredStream<core::pin::Pin<&mut tokio_io_timeout::TimeoutReader<tokio::net::tcp::stream::TcpStream>>, safekeeper::wal_service::handle_socket::{closure#0}::{closure#0}, safekeeper::wal_service::handle_socket::{closure#0}::{closure#1}>>::{closure#0}::{closure#1}> |
0 |
| <safekeeper::send_wal::WalSenders>::get_all_public |
0 |
| <safekeeper::send_wal::WalSenders>::get_all_public::{closure#0} |
0 |
| <safekeeper::send_wal::WalSenders>::get_ws_remote_consistent_lsn |
0 |
| <safekeeper::send_wal::WalSenders>::info_for_metrics |
0 |
| <safekeeper::send_wal::WalSenders>::info_for_metrics::{closure#0} |
0 |
| <safekeeper::send_wal::WalSenders>::info_for_metrics::{closure#1} |
0 |
| <safekeeper::send_wal::WalSenders>::laggard_lsn |
0 |
| <safekeeper::send_wal::WalSenders>::laggard_lsn::{closure#0} |
0 |
| <safekeeper::send_wal::WalSenders>::record_hs_feedback |
0 |
| <safekeeper::send_wal::WalSenders>::record_ps_feedback |
0 |
| <safekeeper::send_wal::WalSenders>::record_standby_reply |
0 |
| <safekeeper::send_wal::WalSenders>::register |
0 |
| <safekeeper::send_wal::WalSenders>::register::{closure#0} |
0 |
| <safekeeper::send_wal::WalSenders>::unregister |
0 |
| <safekeeper::send_wal::WalSendersShared>::get_slot |
0 |
| <safekeeper::send_wal::WalSendersShared>::get_slot_mut |
0 |
| safekeeper::send_wal::tests::test_hs_feedback |
1 |
| safekeeper::send_wal::tests::test_hs_feedback_no_valid |
1 |
| <safekeeper::send_wal::WalSendersShared>::update_reply_feedback |
2 |
| <safekeeper::send_wal::EndWatch>::wait_for_lsn |
4 |
| <safekeeper::send_wal::EndWatch>::wait_for_lsn::{closure#0} |
4 |
| <safekeeper::send_wal::WalSenderState>::get_feedback |
4 |
| safekeeper::send_wal::tests::hs_feedback |
4 |
| safekeeper::send_wal::tests::mock_addr |
4 |
| safekeeper::send_wal::tests::mock_ttid |
4 |
| safekeeper::send_wal::tests::push_feedback |
4 |
| <safekeeper::send_wal::WalSenders>::new |
5 |
| <safekeeper::send_wal::WalSendersShared>::new |
7 |
| <safekeeper::send_wal::EndWatch>::get |
12 |
| <safekeeper::send_wal::EndWatch>::changed |
14 |
| ::changed |
7 |
| ::changed::{closure#0} |
7 |
| <safekeeper::send_wal::WalSenders>::get_hotstandby |
620 |