MCPcopy Create free account

hub / github.com/Migorithm/duva / functions

Functions954 in github.com/Migorithm/duva

⨍ Functions 954◇ Types & classes 154
Functiontest_leader_connections_remove_outdated_connections
()
duva-client/src/broker/node_connections.rs:141
Functiontest_leader_connections_remove_outdated_connections_except_seed
()
duva-client/src/broker/node_connections.rs:179
Functiontest_leader_election
()
duva/tests/replication_ops/test_leader_election.rs:25
Functiontest_leader_election_twice
()
duva/tests/replication_ops/test_leader_election_twice.rs:47
Functiontest_leader_heartbeat_periodically
()
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:232
Functiontest_leader_mode_initialization
()
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:184
Functiontest_leader_req_consensus_early_return_when_already_processed_session_req_given
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:457
Functiontest_leader_req_consensus_with_pending_requests
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:592
Functiontest_leader_req_consensus_with_processed_session
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:615
Functiontest_lindex
()
duva/tests/client_ops/test_lindex.rs:20
Functiontest_list_variant_encode_decode
()
duva/src/domains/caches/cache_objects/value.rs:92
Functiontest_llen
()
duva/tests/client_ops/test_llen.rs:24
Functiontest_loading_all
()
duva/src/domains/saves/endec/decoder.rs:651
Functiontest_long_string
()
duva/src/domains/saves/endec/encoder.rs:202
Functiontest_lpop
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:922
Functiontest_lpop
()
duva/tests/client_ops/test_lpop.rs:31
Functiontest_lpush
()
duva/tests/client_ops/test_lpush.rs:19
Functiontest_lpush_and_node_creation
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:765
Functiontest_lpushx
()
duva/tests/client_ops/test_lpushx.rs:20
Functiontest_lrange
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:944
Functiontest_lru_basic
()
duva/src/domains/caches/lru_cache.rs:347
Functiontest_lru_capacity_one
()
duva/src/domains/caches/lru_cache.rs:386
Functiontest_lru_get_non_existent
()
duva/src/domains/caches/lru_cache.rs:400
Functiontest_lru_remove_head_tail_update
()
duva/src/domains/caches/lru_cache.rs:427
Functiontest_lru_remove_key
()
duva/src/domains/caches/lru_cache.rs:409
Functiontest_lru_update_existing
()
duva/src/domains/caches/lru_cache.rs:368
Functiontest_lru_with_expiry
()
duva/src/domains/caches/lru_cache.rs:597
Functiontest_lset
()
duva/tests/client_ops/test_lset.rs:34
Functiontest_ltrim_basic
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:1026
Functiontest_ltrim_empty_result
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:1064
Functiontest_ltrim_negative_indices
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:1045
Functiontest_ltrim_no_change
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:1080
Functiontest_make_migration_plan_when_given_hashring_is_same
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:224
Functiontest_make_migration_plan_when_no_hashring_given
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:238
Functiontest_maybe_update_hashring_replica_only_updates_ring
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:562
Functiontest_maybe_update_hashring_when_noplan_is_made
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:197
Functiontest_mean_calculation_accuracy
()
duva/src/domains/peers/peer.rs:334
Functiontest_merge_array_with_single_element
()
duva/src/domains/query_io.rs:361
Functiontest_merge_arrays
()
duva/src/domains/query_io.rs:334
Functiontest_merge_null_with_array
()
duva/src/domains/query_io.rs:380
Functiontest_metadata_loading_no_metadata
()
duva/src/domains/saves/endec/decoder.rs:610
Functiontest_migrate_batch_send_migrate_batch_peer_message
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:330
Functiontest_migrate_keys_target_peer_not_found
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:310
Functiontest_minimum_mean_threshold
()
duva/src/domains/peers/peer.rs:551
Functiontest_mixed_operations
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:973
Functiontest_multiple_ownership_changes
()
duva/src/domains/cluster_actors/hash_ring/tests/migration.rs:133
Functiontest_new_creates_initial_segment
()
duva/src/adapters/loggers/disk_based.rs:671
Functiontest_new_creates_oplogs
()
duva/src/adapters/loggers/disk_based.rs:554
Functiontest_new_handles_corrupted_segment
()
duva/src/adapters/loggers/disk_based.rs:782
Functiontest_new_handles_multiple_segments
()
duva/src/adapters/loggers/disk_based.rs:729
Functiontest_new_loads_existing_segment_metadata
()
duva/src/adapters/loggers/disk_based.rs:692
Functiontest_new_quicklist
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:687
Functiontest_no_migration_when_rings_identical
()
duva/src/domains/cluster_actors/hash_ring/tests/migration.rs:13
Functiontest_node_creation
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:695
Functiontest_node_creation_with_size_limit
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:716
Functiontest_node_merging_is_correct
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:999
Functiontest_node_pool_recycling
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:898
Functiontest_node_removal_redistribution
()
duva/src/domains/cluster_actors/hash_ring/tests/add_and_remove.rs:120
Functiontest_non_expiry_key_value_pair
()
duva/src/domains/saves/endec/decoder.rs:516
Functiontest_partial_commit_with_new_entries
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:296
Functiontest_peer_identifier
()
duva/src/domains/peers/identifier.rs:75
Functiontest_peer_identifier2
()
duva/src/domains/peers/identifier.rs:83
Functiontest_performance_with_maximum_history
()
duva/src/domains/peers/peer.rs:625
Functiontest_phi_calculation_mathematical_accuracy
()
duva/src/domains/peers/peer.rs:651
Functiontest_phi_calculation_normal_operation
()
duva/src/domains/peers/peer.rs:273
Functiontest_prioritize_nodes_with_same_replid
()
duva/src/domains/peers/peer.rs:193
Functiontest_push
()
duva/src/domains/caches/read_queue.rs:50
Functiontest_range_empty_log
()
duva/src/adapters/loggers/disk_based.rs:803
Functiontest_range_multiple_segments
()
duva/src/adapters/loggers/disk_based.rs:886
Functiontest_range_single_segment
()
duva/src/adapters/loggers/disk_based.rs:834
Functiontest_read_at_empty_log
()
duva/src/adapters/loggers/disk_based.rs:943
Functiontest_read_at_multiple_segments
()
duva/src/adapters/loggers/disk_based.rs:983
Functiontest_read_at_single_segment
()
duva/src/adapters/loggers/disk_based.rs:956
Functiontest_realistic_distributed_system_scenario
()
duva/src/domains/peers/peer.rs:591
Functiontest_rebalance_request_before_member_connected
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:23
Functiontest_rebalance_request_happypath
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:61
Functiontest_rebalance_request_to_replica
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:38
Functiontest_rebalance_request_with_lazy
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:8
Functiontest_receive_batch_when_consensus_is_required
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:374
Functiontest_receive_batch_when_empty_cache_entries
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:357
Functiontest_receive_election_vote_candidate_gets_vote_not_enough_to_win
()
duva/src/domains/cluster_actors/actor/tests/elections.rs:212
Functiontest_receive_election_vote_candidate_wins_election
()
duva/src/domains/cluster_actors/actor/tests/elections.rs:157
Functiontest_reconnection_on_gossip
()
duva/src/domains/cluster_actors/actor/tests/cluster_managements.rs:81
Functiontest_reconnection_on_reboot
()
duva/tests/cluster_ops/test_reconnection_on_reboot.rs:44
Functiontest_recovery_after_false_positive
()
duva/src/domains/peers/peer.rs:524
Functiontest_removed_leader_connection_with_replica
()
duva/tests/client_ops/test_removed_leader_connection_with_replica.rs:42
Functiontest_removed_leader_connection_without_replica
()
duva/tests/client_ops/test_removed_leader_connection_without_replica.rs:35
Functiontest_removes_node_when_heartbeat_is_not_received_for_certain_time
()
duva/tests/cluster_ops/test_removes_node_when_heartbeat_is_not_received_for_certain_time.rs:30
Functiontest_replay_multiple_operations
()
duva/src/adapters/loggers/disk_based.rs:596
Functiontest_replay_partial_data
()
duva/src/adapters/loggers/disk_based.rs:625
Functiontest_replication_info
()
duva/tests/client_ops/test_replication_info.rs:25
Functiontest_rolling_window_behavior
()
duva/src/domains/peers/peer.rs:352
Functiontest_route_bulk_set_distribution_across_shards
()
duva/src/domains/caches/cache_manager.rs:452
Functiontest_route_bulk_set_with_expiry
()
duva/src/domains/caches/cache_manager.rs:477
Functiontest_rpop
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:876
Functiontest_rpop
()
duva/tests/client_ops/test_rpop.rs:31
Functiontest_rpush
()
duva/tests/client_ops/test_rpush.rs:19
Functiontest_rpush_and_node_creation
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:739
Functiontest_rpushx
()
duva/tests/client_ops/test_rpushx.rs:20
Functiontest_run_for_election_no_replicas
()
duva/src/domains/cluster_actors/actor/tests/elections.rs:37
← previousnext →801–900 of 954, ranked by callers