Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ShisoftResearch/bifrost
/ functions
Functions
541 in github.com/ShisoftResearch/bifrost
⨍
Functions
541
◇
Types & classes
103
Function
snapshot_disk_persistence
()
src/raft/mod.rs:4820
Function
snapshot_persistence_and_recovery
()
src/raft/mod.rs:4885
Method
start
(server: &Arc<RaftService>, recover_registered: bool)
src/raft/mod.rs:1654
Function
startup
()
src/raft/mod.rs:3683
Function
struct_rpc
()
src/rpc/mod.rs:460
Method
subscribe
( &mut self, key: SubKey, address: String, session_id: u64, )
src/raft/state_machine/configs.rs:84
Method
subscribe
( &mut self, key: SubKey, address: &String, session_id: u64, )
src/raft/state_machine/callback/server.rs:40
Function
test_abrupt_crash_full_recovery
()
src/raft/mod.rs:6192
Function
test_active_connections_close_on_shutdown
()
tests/graceful_shutdown_tests.rs:285
Function
test_all_exec_error_variants
()
src/raft/state_machine/master.rs:684
Function
test_clear_subs
()
src/raft/state_machine/master.rs:510
Function
test_client_by_rpc_client_creation
()
src/rpc/cluster.rs:121
Function
test_client_connect_timeout
()
src/tcp/client.rs:137
Function
test_client_server_id
()
src/tcp/client.rs:168
Function
test_client_standalone_address
()
src/tcp/client.rs:153
Function
test_config_snapshot_serialization
()
src/raft/state_machine/configs.rs:261
Function
test_configures_has_subscriptions
()
src/raft/state_machine/configs.rs:279
Function
test_configures_id
()
src/raft/state_machine/configs.rs:185
Function
test_configures_new
()
src/raft/state_machine/configs.rs:175
Function
test_configures_recoverable
()
src/raft/state_machine/configs.rs:192
Function
test_del_member
()
src/raft/state_machine/configs.rs:251
Function
test_equals_empty_clocks
()
src/vector_clock/mod.rs:544
Function
test_equals_with_zero_values
()
src/vector_clock/mod.rs:552
Function
test_exec_error_clone
()
src/raft/state_machine/master.rs:676
Function
test_exec_error_debug
()
src/raft/state_machine/master.rs:669
Function
test_exec_error_display
()
src/raft/state_machine/master.rs:658
Function
test_full_stack_shutdown_releases_port
()
tests/graceful_shutdown_tests.rs:187
Function
test_happened_before_empty_clocks
()
src/vector_clock/mod.rs:534
Function
test_has_sub
()
src/raft/state_machine/master.rs:529
Function
test_inc_new_server
()
src/vector_clock/mod.rs:499
Function
test_install_snapshot_compacts_logs
()
src/raft/mod.rs:5252
Function
test_is_recoverable_config_sm
()
src/raft/state_machine/master.rs:328
Function
test_is_recoverable_non_recoverable_sm
()
src/raft/state_machine/master.rs:351
Function
test_is_recoverable_registered_sm
()
src/raft/state_machine/master.rs:336
Function
test_is_recoverable_unregistered_sm
()
src/raft/state_machine/master.rs:366
Function
test_learn_from
()
src/vector_clock/mod.rs:427
Function
test_learn_from_empty
()
src/vector_clock/mod.rs:438
Function
test_learn_from_into_empty
()
src/vector_clock/mod.rs:449
Function
test_log_compaction_removes_old_logs
()
src/raft/mod.rs:5082
Function
test_master_state_machine_id
()
src/raft/state_machine/master.rs:316
Function
test_master_state_machine_new
()
src/raft/state_machine/master.rs:304
Function
test_master_state_machine_recoverable
()
src/raft/state_machine/master.rs:322
Function
test_member_address
()
src/raft/state_machine/configs.rs:208
Function
test_member_existed
()
src/raft/state_machine/configs.rs:198
Function
test_members
()
src/raft/state_machine/master.rs:502
Function
test_membership_duplicate_join_attempt
()
src/raft/state_machine/configs.rs:478
Function
test_membership_join_unreachable_server
()
src/raft/state_machine/configs.rs:610
Function
test_membership_leave_nonexistent
()
src/raft/state_machine/configs.rs:600
Function
test_membership_multiple_servers_join
()
src/raft/state_machine/configs.rs:388
Function
test_membership_partial_leave
()
src/raft/state_machine/configs.rs:433
Function
test_membership_recovery_with_changes
()
src/raft/state_machine/configs.rs:550
Function
test_membership_server_join
()
src/raft/state_machine/configs.rs:291
Function
test_membership_server_leave
()
src/raft/state_machine/configs.rs:325
Function
test_membership_server_rejoin
()
src/raft/state_machine/configs.rs:356
Function
test_membership_snapshot_with_members
()
src/raft/state_machine/configs.rs:505
Function
test_merge_with
()
src/vector_clock/mod.rs:391
Function
test_merge_with_empty
()
src/vector_clock/mod.rs:406
Function
test_merge_with_into_empty
()
src/vector_clock/mod.rs:417
Function
test_notify_error_debug
()
src/raft/state_machine/callback/server.rs:410
Function
test_ord
()
src/vector_clock/mod.rs:521
Function
test_parse_output_none
()
src/raft/state_machine/master.rs:650
Function
test_parse_output_some
()
src/raft/state_machine/master.rs:641
Function
test_partial_ord
()
src/vector_clock/mod.rs:510
Function
test_raft_service_shutdown_stops_tasks
()
tests/graceful_shutdown_tests.rs:131
Function
test_rapid_shutdown_restart_cycles
()
tests/graceful_shutdown_tests.rs:255
Function
test_real_world_concurrent_queries
()
src/raft/state_machine/master.rs:1155
Function
test_real_world_config_sm_operations
()
src/raft/state_machine/master.rs:1088
Function
test_real_world_error_handling
()
src/raft/state_machine/master.rs:1034
Function
test_real_world_kv_store_workflow
()
src/raft/state_machine/master.rs:803
Function
test_real_world_multiple_operations
()
src/raft/state_machine/master.rs:846
Function
test_real_world_multiple_state_machines
()
src/raft/state_machine/master.rs:966
Function
test_real_world_query_on_non_existent_sm
()
src/raft/state_machine/master.rs:1071
Function
test_real_world_snapshot_and_recovery
()
src/raft/state_machine/master.rs:907
Function
test_real_world_state_machine_lifecycle
()
src/raft/state_machine/master.rs:1109
Function
test_recover_empty_snapshot
()
src/raft/state_machine/configs.rs:229
Function
test_recover_invalid_data
()
src/raft/state_machine/configs.rs:239
Function
test_recover_invalid_snapshot
()
src/raft/state_machine/master.rs:626
Function
test_recover_registered_snapshots_applies_config_snapshot
()
src/raft/state_machine/master.rs:477
Function
test_recover_valid_snapshot
()
src/raft/state_machine/master.rs:610
Function
test_register_existed
()
src/raft/state_machine/master.rs:417
Function
test_register_ok
()
src/raft/state_machine/master.rs:374
Function
test_register_reserved
()
src/raft/state_machine/master.rs:390
Function
test_register_result_variants
()
src/raft/state_machine/master.rs:697
Function
test_register_with_snapshot_recovery
()
src/raft/state_machine/master.rs:442
Function
test_remove_subscriber
()
src/raft/state_machine/callback/server.rs:371
Function
test_remove_subscriber_nonexistent
()
src/raft/state_machine/callback/server.rs:400
Function
test_remove_subscription
()
src/raft/state_machine/callback/server.rs:346
Function
test_remove_subscription_nonexistent
()
src/raft/state_machine/callback/server.rs:335
Function
test_rpc_server_shutdown_releases_port
()
tests/graceful_shutdown_tests.rs:88
Function
test_server_callback_invocation
()
src/tcp/server.rs:177
Function
test_server_creation
()
src/tcp/server.rs:120
Function
test_server_listen_and_shutdown
()
src/tcp/server.rs:142
Function
test_server_vector_clock
()
src/vector_clock/mod.rs:459
Function
test_server_vector_clock_relation
()
src/vector_clock/mod.rs:484
Function
test_shutdown_completes_within_timeout
()
tests/graceful_shutdown_tests.rs:322
Function
test_shutdown_handle
()
src/tcp/server.rs:129
Function
test_single_node_cluster_recovery_becomes_leader
()
tests/single_node_recovery_test.rs:12
Function
test_single_node_multiple_restart_cycles
()
tests/single_node_recovery_test.rs:194
Function
test_snapshot_corruption_detection
()
src/raft/mod.rs:5034
Function
test_snapshot_empty
()
src/raft/state_machine/configs.rs:215
← previous
next →
401–500 of 541, ranked by callers