MCPcopy Create free account

hub / github.com/Migorithm/duva / functions

Functions954 in github.com/Migorithm/duva

⨍ Functions 954◇ Types & classes 154
Functiontest_run_for_election_transitions_to_candidate_and_sends_request_votes
()
duva/src/domains/cluster_actors/actor/tests/elections.rs:4
Functiontest_run_invalid_replicaof
()
duva/tests/cluster_ops/test_lazy_discovery.rs:79
Functiontest_same_voter_can_vote_only_once
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:534
Functiontest_send_migrate_and_wait_callback_error
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:279
Functiontest_send_migrate_and_wait_happypath
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:251
Functiontest_set_get
()
duva/tests/client_ops/test_set_get.rs:28
Functiontest_set_operation_reaches_to_all_replicas
()
duva/tests/replication_ops/test_raft_happy_case.rs:30
Functiontest_set_partitions_empty_list
()
duva/src/domains/cluster_actors/hash_ring/tests/add_and_remove.rs:53
Functiontest_set_partitions_idempotent_addition
()
duva/src/domains/cluster_actors/hash_ring/tests/add_and_remove.rs:101
Functiontest_set_partitions_multiple_partitions
()
duva/src/domains/cluster_actors/hash_ring/tests/add_and_remove.rs:38
Functiontest_set_partitions_virtual_node_consistency
()
duva/src/domains/cluster_actors/hash_ring/tests/add_and_remove.rs:82
Functiontest_set_twice_after_election
()
duva/tests/replication_ops/test_set_twice_after_election.rs:50
Functiontest_shard_leaders
()
duva/src/domains/cluster_actors/actor/tests/cluster_managements.rs:192
Functiontest_single_node_ownership_change
()
duva/src/domains/cluster_actors/hash_ring/tests/migration.rs:40
Functiontest_size_decoding
()
duva/src/domains/saves/endec/decoder.rs:407
Functiontest_size_encode_14_bit
()
duva/src/domains/saves/endec/encoder.rs:165
Functiontest_size_encode_32_bit
()
duva/src/domains/saves/endec/encoder.rs:176
Functiontest_size_encode_6_bit
()
duva/src/domains/saves/endec/encoder.rs:156
Functiontest_size_encode_too_large
()
duva/src/domains/saves/endec/encoder.rs:193
Functiontest_snapshot_persists_and_recovers_state
()
duva/tests/client_ops/test_snapshot_persists_and_recovers_state.rs:49
Functiontest_socket_to_string
()
duva/src/adapters/io/tokio_stream.rs:198
Functiontest_start_rebalance_before_connection_is_made
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:84
Functiontest_start_rebalance_happy_path
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:114
Functiontest_start_rebalance_only_when_replica_is_found
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:98
Functiontest_start_rebalance_schedules_migration_batches
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:144
Functiontest_store_current_topology
()
duva/src/domains/cluster_actors/actor/tests/cluster_managements.rs:58
Functiontest_stored_duration_to_datetime
()
duva/src/domains/saves/endec/mod.rs:120
Functiontest_string_decoding
()
duva/src/domains/saves/endec/decoder.rs:440
Functiontest_string_variant_encode_decode
()
duva/src/domains/caches/cache_objects/value.rs:83
Functiontest_suspicion_level_progression
()
duva/src/domains/peers/peer.rs:383
Functiontest_topology_broadcast_on_hash_ring_change
()
duva/src/domains/cluster_actors/actor/tests/cluster_managements.rs:126
Functiontest_truncate_after
()
duva/src/adapters/loggers/disk_based.rs:1137
Functiontest_ttl
()
duva/tests/client_ops/test_ttl.rs:22
Functiontest_unblock_write_reqs_if_done_multiple_times
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:446
Functiontest_unblock_write_reqs_if_done_when_migrations_still_pending
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:409
Functiontest_unblock_write_reqs_if_done_when_no_pending_migrations
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:396
Functiontest_unblock_write_reqs_if_done_when_not_blocked
()
duva/src/domains/cluster_actors/actor/tests/partitionings.rs:432
Functiontest_update_cluster_members_updates_fields
()
duva/src/domains/cluster_actors/actor/tests/cluster_managements.rs:164
Functiontest_update_leader_heartbeat
()
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:296
Functiontest_varying_heartbeat_intervals
()
duva/src/domains/peers/peer.rs:313
Functiontest_vote_election_deny_vote_lower_candidate_term
()
duva/src/domains/cluster_actors/actor/tests/elections.rs:131
Functiontest_vote_election_deny_vote_older_log
()
duva/src/domains/cluster_actors/actor/tests/elections.rs:91
Functiontest_vote_election_grant_vote
()
duva/src/domains/cluster_actors/actor/tests/elections.rs:58
Functiontest_with_milliseconds_expiry_key_value_pair
()
duva/src/domains/saves/endec/decoder.rs:534
Functiontest_with_seconds_expiry_key_value_pair
()
duva/src/domains/saves/endec/decoder.rs:555
Methodtruncate_after
Truncate logs that are positioned after `log_index`.
duva/src/adapters/loggers/op_logs.rs:63
Methodtruncate_after
(&mut self, log_index: u64)
duva/src/adapters/loggers/memory_based.rs:40
Methodtry_from
(value: String)
duva/src/domains/peers/connections/inbound/request.rs:93
Methodtry_from
(value: String)
duva/src/domains/peers/connections/outbound/response.rs:13
Methodunpack_array
(self)
duva/src/domains/query_io.rs:79
Methodvalidate_folder
(path: &Path)
duva/src/adapters/loggers/disk_based.rs:204
Methodwith_capacity
(cap: usize)
duva/src/domains/caches/lru_cache.rs:38
Methodwith_log_level
(mut self, level: impl Into<String>)
duva-client/src/observability.rs:15
Methodwrite_many
(&mut self, ops: Vec<WriteOperation>)
duva/src/adapters/loggers/memory_based.rs:12
← previous901–954 of 954, ranked by callers