MCPcopy Create free account

hub / github.com/Migorithm/duva / functions

Functions954 in github.com/Migorithm/duva

Functiontest_adaptive_behavior_with_changing_patterns
()
duva/src/domains/peers/peer.rs:416
Functiontest_add_and_remove_node
()
duva/src/domains/cluster_actors/hash_ring/tests/add_and_remove.rs:4
Functiontest_add_peer_for_follower_send_heartbeat
()
duva/src/domains/cluster_actors/actor/tests/cluster_managements.rs:233
Functiontest_append
()
duva/tests/client_ops/test_append.rs:8
Functiontest_append_stores_to_disk
()
duva/src/adapters/loggers/disk_based.rs:570
Functiontest_apply_multiple_committed_entries
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:242
Functiontest_become_candidate_not_allow_write_request_processing
()
duva/src/domains/cluster_actors/actor/tests/elections.rs:230
Functiontest_cache_entry_encode_decode_with_expiry
()
duva/src/domains/caches/cache_objects/entry.rs:117
Functiontest_cache_value_encode
()
duva/src/domains/saves/endec/encoder.rs:304
Functiontest_cache_value_encode_decode_with_expiry
()
duva/src/domains/caches/cache_objects/entry.rs:80
Functiontest_cache_value_encode_decode_without_expiry
()
duva/src/domains/caches/cache_objects/entry.rs:99
Functiontest_cache_value_encode_with_binary_data
()
duva/src/domains/saves/endec/encoder.rs:402
Functiontest_cache_value_with_expiry_milliseconds
()
duva/src/domains/saves/endec/encoder.rs:324
Functiontest_cloning_replication_state
()
duva/src/domains/replications/replication.rs:418
Functiontest_cluster_forget_makes_all_nodes_forget_target_node
()
duva/tests/cluster_ops/test_cluster_forget_makes_all_nodes_forget_target_node.rs:35
Functiontest_cluster_forget_node_return_error_when_wrong_id_given
()
duva/tests/cluster_ops/test_cluster_forget_when_wrong_id_given.rs:28
Functiontest_cluster_meet
()
duva/tests/cluster_ops/test_cluster_meet.rs:62
Functiontest_cluster_meet_with_migration
()
duva/tests/cluster_ops/test_cluster_meet.rs:141
Functiontest_cluster_nodes
()
duva/src/domains/cluster_actors/actor/tests/cluster_managements.rs:6
Functiontest_cluster_topology_change_when_new_node_added
()
duva/tests/cluster_ops/test_cluster_known_nodes_increase_when_new_replica_is_added.rs:39
Functiontest_compress_respects_depth
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:825
Functiontest_compression
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:840
Functiontest_compression_and_decompression_on_access
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:789
Functiontest_config_get_dir
()
duva/tests/client_ops/test_config_get_dir.rs:24
Functiontest_consensus_voting_deleted_when_consensus_reached
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:483
Functiontest_consistent_hashing
()
duva/src/domains/cluster_actors/hash_ring/tests/add_and_remove.rs:62
Functiontest_consistent_timing_low_phi
()
duva/src/domains/peers/peer.rs:481
Functiontest_database_loading
()
duva/src/domains/saves/endec/decoder.rs:626
Functiontest_database_section_extractor
()
duva/src/domains/saves/endec/decoder.rs:481
Functiontest_decode_multiple_strings
()
duva/src/domains/saves/endec/decoder.rs:469
Functiontest_decoding
()
duva/src/domains/saves/endec/decoder.rs:453
Functiontest_decr
()
duva/tests/client_ops/test_decr.rs:41
Functiontest_decrby
()
duva/tests/client_ops/test_decrby.rs:40
Functiontest_del
()
duva/tests/client_ops/test_del.rs:28
Functiontest_deserialize_array
()
duva/src/domains/query_io.rs:315
Functiontest_deserialize_bulk_string
()
duva/src/domains/query_io.rs:289
Functiontest_deserialize_bulk_string_empty
()
duva/src/domains/query_io.rs:302
Functiontest_deserialize_reads
()
duva/src/adapters/io/tokio_stream.rs:208
Functiontest_deserialize_reads_vec
()
duva/src/adapters/io/tokio_stream.rs:229
Functiontest_drop_cache
()
duva/src/domains/caches/actor.rs:480
Functiontest_edge_case_very_large_intervals
()
duva/src/domains/peers/peer.rs:450
Functiontest_election_timeout
()
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:263
Functiontest_empty_history_pop_safety
()
duva/src/domains/peers/peer.rs:575
Functiontest_empty_keys_migration_plan
()
duva/src/domains/cluster_actors/hash_ring/tests/migration.rs:24
Functiontest_encode_header
()
duva/src/domains/saves/endec/encoder.rs:355
Functiontest_encode_metadata
()
duva/src/domains/saves/endec/encoder.rs:362
Functiontest_entry_multiple_operations
()
duva/src/domains/caches/lru_cache.rs:571
Functiontest_entry_mutable_reference_modification
()
duva/src/domains/caches/lru_cache.rs:557
Functiontest_entry_occupied_moves_to_head
()
duva/src/domains/caches/lru_cache.rs:542
Functiontest_entry_occupied_or_insert
()
duva/src/domains/caches/lru_cache.rs:528
Functiontest_entry_vacant_or_insert
()
duva/src/domains/caches/lru_cache.rs:515
Functiontest_exists
()
duva/tests/client_ops/test_exists.rs:25
Functiontest_find_target_peer_for_replication
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:462
Functiontest_follower_mode_initialization
()
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:195
Functiontest_full_sync_on_newly_added_replica
()
duva/tests/replication_ops/test_sync.rs:28
Functiontest_generate_follower_entries
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:43
Functiontest_get_node_for_key
()
duva/src/domains/cluster_actors/hash_ring/tests/add_and_remove.rs:25
Functiontest_get_required_votes
()
duva/src/domains/replications/consensus/election.rs:34
Functiontest_get_required_votes
()
duva/src/domains/replications/consensus/log.rs:52
Functiontest_get_required_votes_edge_cases
()
duva/src/domains/replications/consensus/log.rs:69
Functiontest_handle_migration_ack_batch_id_not_found
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:482
Functiontest_handle_migration_ack_success_case_with_pending_reqs_and_migration
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:503
Functiontest_hash64_average_dispersion
()
duva/src/domains/cluster_actors/hash_ring/hash_func.rs:80
Functiontest_hash64_bit_entropy
()
duva/src/domains/cluster_actors/hash_ring/hash_func.rs:60
Functiontest_hash64_range_spread
()
duva/src/domains/cluster_actors/hash_ring/hash_func.rs:45
Functiontest_hash64_uniqueness
()
duva/src/domains/cluster_actors/hash_ring/hash_func.rs:39
Functiontest_hash_avalanche_effect
()
duva/src/domains/cluster_actors/hash_ring/hash_func.rs:117
Functiontest_hash_collision_resistance
()
duva/src/domains/cluster_actors/hash_ring/hash_func.rs:105
Functiontest_hash_deterministic
()
duva/src/domains/cluster_actors/hash_ring/hash_func.rs:31
Functiontest_header_loading
()
duva/src/domains/saves/endec/decoder.rs:590
Functiontest_header_loading_data_length_error
()
duva/src/domains/saves/endec/decoder.rs:601
Functiontest_heartbeat_periodically
()
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:206
Functiontest_history_size_limit
()
duva/src/domains/peers/peer.rs:229
Functiontest_hop_count_when_one
()
duva/src/domains/cluster_actors/actor/tests/mod.rs:289
Functiontest_hop_count_when_thirty
()
duva/src/domains/cluster_actors/actor/tests/mod.rs:322
Functiontest_hop_count_when_three
()
duva/src/domains/cluster_actors/actor/tests/mod.rs:311
Functiontest_hop_count_when_two
()
duva/src/domains/cluster_actors/actor/tests/mod.rs:300
Functiontest_incr
()
duva/tests/client_ops/test_incr.rs:35
Functiontest_incrby
()
duva/tests/client_ops/test_incrby.rs:40
Functiontest_index_data_accuracy
()
duva/src/adapters/loggers/disk_based.rs:1022
Functiontest_index_data_after_rotation
()
duva/src/adapters/loggers/disk_based.rs:1052
Functiontest_index_data_recovery
()
duva/src/adapters/loggers/disk_based.rs:1097
Functiontest_index_get_put_in_rq
()
duva/src/domains/caches/actor.rs:408
Functiontest_index_get_returns_successfully_when_ping_is_made_after_con_idx_update
()
duva/src/domains/caches/actor.rs:443
Functiontest_integer_decoding
()
duva/src/domains/saves/endec/decoder.rs:425
Functiontest_integer_decoding1
()
duva/src/domains/saves/endec/encoder.rs:277
Functiontest_integer_decoding2
()
duva/src/domains/saves/endec/encoder.rs:286
Functiontest_integer_decoding3
()
duva/src/domains/saves/endec/encoder.rs:295
Functiontest_invalid_expiry_key_value_pair
()
duva/src/domains/saves/endec/decoder.rs:573
Functiontest_irregular_timing_adaptation
()
duva/src/domains/peers/peer.rs:501
Functiontest_is_dead_insufficient_history
()
duva/src/domains/peers/peer.rs:254
Functiontest_is_dead_with_long_delay
()
duva/src/domains/peers/peer.rs:294
Functiontest_iter_after_access_reorders
()
duva/src/domains/caches/lru_cache.rs:477
Functiontest_iter_doesnt_modify_cache
()
duva/src/domains/caches/lru_cache.rs:495
Functiontest_iter_empty_cache
()
duva/src/domains/caches/lru_cache.rs:445
Functiontest_iter_multiple_items_mru_order
()
duva/src/domains/caches/lru_cache.rs:462
Functiontest_iter_single_item
()
duva/src/domains/caches/lru_cache.rs:452
Functiontest_keys
()
duva/tests/client_ops/test_keys.rs:25
Functiontest_lazy_discovery_of_leader
()
duva/tests/cluster_ops/test_lazy_discovery.rs:52
Functiontest_leader_connections_remove_connection
()
duva-client/src/broker/node_connections.rs:116
← previousnext →701–800 of 954, ranked by callers