MCPcopy Create free account

hub / github.com/ShisoftResearch/bifrost / functions

Functions541 in github.com/ShisoftResearch/bifrost

Functionsnapshot_disk_persistence
()
src/raft/mod.rs:4820
Functionsnapshot_persistence_and_recovery
()
src/raft/mod.rs:4885
Methodstart
(server: &Arc<RaftService>, recover_registered: bool)
src/raft/mod.rs:1654
Functionstartup
()
src/raft/mod.rs:3683
Functionstruct_rpc
()
src/rpc/mod.rs:460
Methodsubscribe
( &mut self, key: SubKey, address: String, session_id: u64, )
src/raft/state_machine/configs.rs:84
Methodsubscribe
( &mut self, key: SubKey, address: &String, session_id: u64, )
src/raft/state_machine/callback/server.rs:40
Functiontest_abrupt_crash_full_recovery
()
src/raft/mod.rs:6192
Functiontest_active_connections_close_on_shutdown
()
tests/graceful_shutdown_tests.rs:285
Functiontest_all_exec_error_variants
()
src/raft/state_machine/master.rs:684
Functiontest_clear_subs
()
src/raft/state_machine/master.rs:510
Functiontest_client_by_rpc_client_creation
()
src/rpc/cluster.rs:121
Functiontest_client_connect_timeout
()
src/tcp/client.rs:137
Functiontest_client_server_id
()
src/tcp/client.rs:168
Functiontest_client_standalone_address
()
src/tcp/client.rs:153
Functiontest_config_snapshot_serialization
()
src/raft/state_machine/configs.rs:261
Functiontest_configures_has_subscriptions
()
src/raft/state_machine/configs.rs:279
Functiontest_configures_id
()
src/raft/state_machine/configs.rs:185
Functiontest_configures_new
()
src/raft/state_machine/configs.rs:175
Functiontest_configures_recoverable
()
src/raft/state_machine/configs.rs:192
Functiontest_del_member
()
src/raft/state_machine/configs.rs:251
Functiontest_equals_empty_clocks
()
src/vector_clock/mod.rs:544
Functiontest_equals_with_zero_values
()
src/vector_clock/mod.rs:552
Functiontest_exec_error_clone
()
src/raft/state_machine/master.rs:676
Functiontest_exec_error_debug
()
src/raft/state_machine/master.rs:669
Functiontest_exec_error_display
()
src/raft/state_machine/master.rs:658
Functiontest_full_stack_shutdown_releases_port
()
tests/graceful_shutdown_tests.rs:187
Functiontest_happened_before_empty_clocks
()
src/vector_clock/mod.rs:534
Functiontest_has_sub
()
src/raft/state_machine/master.rs:529
Functiontest_inc_new_server
()
src/vector_clock/mod.rs:499
Functiontest_install_snapshot_compacts_logs
()
src/raft/mod.rs:5252
Functiontest_is_recoverable_config_sm
()
src/raft/state_machine/master.rs:328
Functiontest_is_recoverable_non_recoverable_sm
()
src/raft/state_machine/master.rs:351
Functiontest_is_recoverable_registered_sm
()
src/raft/state_machine/master.rs:336
Functiontest_is_recoverable_unregistered_sm
()
src/raft/state_machine/master.rs:366
Functiontest_learn_from
()
src/vector_clock/mod.rs:427
Functiontest_learn_from_empty
()
src/vector_clock/mod.rs:438
Functiontest_learn_from_into_empty
()
src/vector_clock/mod.rs:449
Functiontest_log_compaction_removes_old_logs
()
src/raft/mod.rs:5082
Functiontest_master_state_machine_id
()
src/raft/state_machine/master.rs:316
Functiontest_master_state_machine_new
()
src/raft/state_machine/master.rs:304
Functiontest_master_state_machine_recoverable
()
src/raft/state_machine/master.rs:322
Functiontest_member_address
()
src/raft/state_machine/configs.rs:208
Functiontest_member_existed
()
src/raft/state_machine/configs.rs:198
Functiontest_members
()
src/raft/state_machine/master.rs:502
Functiontest_membership_duplicate_join_attempt
()
src/raft/state_machine/configs.rs:478
Functiontest_membership_join_unreachable_server
()
src/raft/state_machine/configs.rs:610
Functiontest_membership_leave_nonexistent
()
src/raft/state_machine/configs.rs:600
Functiontest_membership_multiple_servers_join
()
src/raft/state_machine/configs.rs:388
Functiontest_membership_partial_leave
()
src/raft/state_machine/configs.rs:433
Functiontest_membership_recovery_with_changes
()
src/raft/state_machine/configs.rs:550
Functiontest_membership_server_join
()
src/raft/state_machine/configs.rs:291
Functiontest_membership_server_leave
()
src/raft/state_machine/configs.rs:325
Functiontest_membership_server_rejoin
()
src/raft/state_machine/configs.rs:356
Functiontest_membership_snapshot_with_members
()
src/raft/state_machine/configs.rs:505
Functiontest_merge_with
()
src/vector_clock/mod.rs:391
Functiontest_merge_with_empty
()
src/vector_clock/mod.rs:406
Functiontest_merge_with_into_empty
()
src/vector_clock/mod.rs:417
Functiontest_notify_error_debug
()
src/raft/state_machine/callback/server.rs:410
Functiontest_ord
()
src/vector_clock/mod.rs:521
Functiontest_parse_output_none
()
src/raft/state_machine/master.rs:650
Functiontest_parse_output_some
()
src/raft/state_machine/master.rs:641
Functiontest_partial_ord
()
src/vector_clock/mod.rs:510
Functiontest_raft_service_shutdown_stops_tasks
()
tests/graceful_shutdown_tests.rs:131
Functiontest_rapid_shutdown_restart_cycles
()
tests/graceful_shutdown_tests.rs:255
Functiontest_real_world_concurrent_queries
()
src/raft/state_machine/master.rs:1155
Functiontest_real_world_config_sm_operations
()
src/raft/state_machine/master.rs:1088
Functiontest_real_world_error_handling
()
src/raft/state_machine/master.rs:1034
Functiontest_real_world_kv_store_workflow
()
src/raft/state_machine/master.rs:803
Functiontest_real_world_multiple_operations
()
src/raft/state_machine/master.rs:846
Functiontest_real_world_multiple_state_machines
()
src/raft/state_machine/master.rs:966
Functiontest_real_world_query_on_non_existent_sm
()
src/raft/state_machine/master.rs:1071
Functiontest_real_world_snapshot_and_recovery
()
src/raft/state_machine/master.rs:907
Functiontest_real_world_state_machine_lifecycle
()
src/raft/state_machine/master.rs:1109
Functiontest_recover_empty_snapshot
()
src/raft/state_machine/configs.rs:229
Functiontest_recover_invalid_data
()
src/raft/state_machine/configs.rs:239
Functiontest_recover_invalid_snapshot
()
src/raft/state_machine/master.rs:626
Functiontest_recover_registered_snapshots_applies_config_snapshot
()
src/raft/state_machine/master.rs:477
Functiontest_recover_valid_snapshot
()
src/raft/state_machine/master.rs:610
Functiontest_register_existed
()
src/raft/state_machine/master.rs:417
Functiontest_register_ok
()
src/raft/state_machine/master.rs:374
Functiontest_register_reserved
()
src/raft/state_machine/master.rs:390
Functiontest_register_result_variants
()
src/raft/state_machine/master.rs:697
Functiontest_register_with_snapshot_recovery
()
src/raft/state_machine/master.rs:442
Functiontest_remove_subscriber
()
src/raft/state_machine/callback/server.rs:371
Functiontest_remove_subscriber_nonexistent
()
src/raft/state_machine/callback/server.rs:400
Functiontest_remove_subscription
()
src/raft/state_machine/callback/server.rs:346
Functiontest_remove_subscription_nonexistent
()
src/raft/state_machine/callback/server.rs:335
Functiontest_rpc_server_shutdown_releases_port
()
tests/graceful_shutdown_tests.rs:88
Functiontest_server_callback_invocation
()
src/tcp/server.rs:177
Functiontest_server_creation
()
src/tcp/server.rs:120
Functiontest_server_listen_and_shutdown
()
src/tcp/server.rs:142
Functiontest_server_vector_clock
()
src/vector_clock/mod.rs:459
Functiontest_server_vector_clock_relation
()
src/vector_clock/mod.rs:484
Functiontest_shutdown_completes_within_timeout
()
tests/graceful_shutdown_tests.rs:322
Functiontest_shutdown_handle
()
src/tcp/server.rs:129
Functiontest_single_node_cluster_recovery_becomes_leader
()
tests/single_node_recovery_test.rs:12
Functiontest_single_node_multiple_restart_cycles
()
tests/single_node_recovery_test.rs:194
Functiontest_snapshot_corruption_detection
()
src/raft/mod.rs:5034
Functiontest_snapshot_empty
()
src/raft/state_machine/configs.rs:215
← previousnext →401–500 of 541, ranked by callers