List of all items

Structs

• AppendResponseWithUpdates
• AppendResult
• AppendResults
• BatchBuffer
• ClusterMetadata
• ClusterUpdateResult
• CommitHandlerDependencies
• DefaultCommitHandler
• DefaultPurgeExecutor
• DefaultStateMachineHandler
• ElectionHandler
• LeaderInfo
• LogSizePolicy
• MaybeCloneOneshot
• MaybeCloneOneshotReceiver
• MaybeCloneOneshotSender
• MockCommitHandler
• MockElectionCore
• MockLogStore
• MockMembership
• MockMetaStore
• MockPurgeExecutor
• MockReplicationCore
• MockSnapshotPolicy
• MockStateMachine
• MockStateMachineHandler
• MockTransport
• NewCommitData
• PeerUpdate
• Raft
• RaftContext
• RaftCoreHandlers
• RaftRequestWithSignal
• RaftStorageHandles
• ReplicationData
• ReplicationHandler
• SignalParams
• SnapshotContext
• SnapshotTransferMeta
• StateUpdate
• StreamResponseSender
• VoteResult
• __mock_MockCommitHandler_CommitHandler::__run::Expectation
• __mock_MockElectionCore_ElectionCore_13065831140148901594::__broadcast_vote_requests::Expectation
• __mock_MockElectionCore_ElectionCore_13065831140148901594::__check_vote_request_is_legal::Expectation
• __mock_MockElectionCore_ElectionCore_13065831140148901594::__handle_vote_request::Expectation
• __mock_MockLogStore_LogStore::__entry::Expectation
• __mock_MockLogStore_LogStore::__flush::Expectation
• __mock_MockLogStore_LogStore::__flush_async::Expectation
• __mock_MockLogStore_LogStore::__get_entries::Expectation
• __mock_MockLogStore_LogStore::__last_index::Expectation
• __mock_MockLogStore_LogStore::__persist_entries::Expectation
• __mock_MockLogStore_LogStore::__purge::Expectation
• __mock_MockLogStore_LogStore::__reset::Expectation
• __mock_MockLogStore_LogStore::__truncate::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__activate_node::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__add_learner::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__apply_config_change::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__can_rejoin::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__check_cluster_is_ready::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__contains_node::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__force_remove_node::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__get_address::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__get_all_nodes::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__get_cluster_conf_version::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__get_node_status::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__get_peer_channel::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__get_peers_id_with_condition::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__get_zombie_candidates::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__incr_conf_version::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__initial_cluster_size::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__is_single_node_cluster::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__members::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__nodes_with_status::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__notify_config_applied::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__pre_warm_connections::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__remove_node::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__replication_peers::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__retrieve_cluster_membership_config::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__retrieve_node_meta::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__update_cluster_conf_from_leader::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__update_conf_version::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__update_node_status::Expectation
• __mock_MockMembership_Membership_13065831140148901594::__voters::Expectation
• __mock_MockMetaStore_MetaStore::__flush::Expectation
• __mock_MockMetaStore_MetaStore::__flush_async::Expectation
• __mock_MockMetaStore_MetaStore::__load_hard_state::Expectation
• __mock_MockMetaStore_MetaStore::__save_hard_state::Expectation
• __mock_MockPurgeExecutor_PurgeExecutor::__execute_purge::Expectation
• __mock_MockPurgeExecutor_PurgeExecutor::__post_purge::Expectation
• __mock_MockPurgeExecutor_PurgeExecutor::__pre_purge::Expectation
• __mock_MockPurgeExecutor_PurgeExecutor::__validate_purge::Expectation
• __mock_MockReplicationCore_ReplicationCore_13065831140148901594::__check_append_entries_request_is_legal::Expectation
• __mock_MockReplicationCore_ReplicationCore_13065831140148901594::__handle_append_entries::Expectation
• __mock_MockReplicationCore_ReplicationCore_13065831140148901594::__handle_conflict_response::Expectation
• __mock_MockReplicationCore_ReplicationCore_13065831140148901594::__handle_raft_request_in_batch::Expectation
• __mock_MockReplicationCore_ReplicationCore_13065831140148901594::__handle_success_response::Expectation
• __mock_MockReplicationCore_ReplicationCore_13065831140148901594::__if_update_commit_index_as_follower::Context
• __mock_MockReplicationCore_ReplicationCore_13065831140148901594::__if_update_commit_index_as_follower::EXPECTATIONS
• __mock_MockReplicationCore_ReplicationCore_13065831140148901594::__if_update_commit_index_as_follower::Expectation
• __mock_MockReplicationCore_ReplicationCore_13065831140148901594::__if_update_commit_index_as_follower::ExpectationGuard
• __mock_MockReplicationCore_ReplicationCore_13065831140148901594::__retrieve_to_be_synced_logs_for_peers::Expectation
• __mock_MockSnapshotPolicy_SnapshotPolicy::__mark_snapshot_created::Expectation
• __mock_MockSnapshotPolicy_SnapshotPolicy::__should_trigger::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__apply_chunk::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__apply_snapshot_stream_from_leader::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__cleanup_snapshot::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__create_snapshot::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__get_latest_snapshot_metadata::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__handle_purge_request::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__last_applied::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__load_snapshot_chunk::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__load_snapshot_data::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__pending_range::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__read_from_state_machine::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__should_snapshot::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__update_pending::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__validate_purge_request::Expectation
• __mock_MockStateMachineHandler_StateMachineHandler_13065831140148901594::__wait_applied::Expectation
• __mock_MockStateMachine_StateMachine::__apply_chunk::Expectation
• __mock_MockStateMachine_StateMachine::__apply_snapshot_from_file::Expectation
• __mock_MockStateMachine_StateMachine::__entry_term::Expectation
• __mock_MockStateMachine_StateMachine::__flush::Expectation
• __mock_MockStateMachine_StateMachine::__flush_async::Expectation
• __mock_MockStateMachine_StateMachine::__generate_snapshot_data::Expectation
• __mock_MockStateMachine_StateMachine::__get::Expectation
• __mock_MockStateMachine_StateMachine::__is_empty::Expectation
• __mock_MockStateMachine_StateMachine::__is_running::Expectation
• __mock_MockStateMachine_StateMachine::__last_applied::Expectation
• __mock_MockStateMachine_StateMachine::__lease_background_cleanup::Expectation
• __mock_MockStateMachine_StateMachine::__len::Expectation
• __mock_MockStateMachine_StateMachine::__persist_last_applied::Expectation
• __mock_MockStateMachine_StateMachine::__persist_last_snapshot_metadata::Expectation
• __mock_MockStateMachine_StateMachine::__reset::Expectation
• __mock_MockStateMachine_StateMachine::__save_hard_state::Expectation
• __mock_MockStateMachine_StateMachine::__snapshot_metadata::Expectation
• __mock_MockStateMachine_StateMachine::__start::Expectation
• __mock_MockStateMachine_StateMachine::__stop::Expectation
• __mock_MockStateMachine_StateMachine::__update_last_applied::Expectation
• __mock_MockStateMachine_StateMachine::__update_last_snapshot_metadata::Expectation
• __mock_MockTransport_Transport_13065831140148901594::__discover_leader::Expectation
• __mock_MockTransport_Transport_13065831140148901594::__join_cluster::Expectation
• __mock_MockTransport_Transport_13065831140148901594::__request_snapshot_from_leader::Expectation
• __mock_MockTransport_Transport_13065831140148901594::__send_append_requests::Expectation
• __mock_MockTransport_Transport_13065831140148901594::__send_cluster_update::Expectation
• __mock_MockTransport_Transport_13065831140148901594::__send_purge_requests::Expectation
• __mock_MockTransport_Transport_13065831140148901594::__send_vote_requests::Expectation
• config::AutoJoinConfig
• config::BackoffPolicy
• config::ClusterConfig
• config::CommitHandlerConfig
• config::ConnectionParams
• config::ElectionConfig
• config::InstallSnapshotBackoffPolicy
• config::LeaseConfig
• config::MembershipConfig
• config::NetworkConfig
• config::PersistenceConfig
• config::PromotionConfig
• config::RaftConfig
• config::RaftNodeConfig
• config::ReadConsistencyConfig
• config::ReplicationConfig
• config::RetryPolicies
• config::RpcCompressionConfig
• config::SnapshotConfig
• config::StateMachineConfig
• config::TlsConfig
• config::WatchConfig
• config::ZombieConfig
• test_utils::EntryBuilder
• test_utils::mock::MockNode
• test_utils::mock::MockRpcService
• test_utils::mock::MockStorageEngine
• test_utils::mock::MockTypeConfig
• test_utils::mock::mock_raft_builder::MockBuilder
• watch::WatchDispatcher
• watch::WatchEvent
• watch::WatchRegistry
• watch::WatcherHandle

Enums

• ConnectionType
• ConsensusError
• ConvertError
• ElectionError
• Error
• FileError
• IdAllocationError
• MembershipError
• NetworkError
• ProstError
• QuorumStatus
• RaftEvent
• ReadSendError
• ReplicationError
• RoleEvent
• SerializationError
• SnapshotError
• StorageError
• SystemError
• TestEvent
• WriteSendError
• config::FlushPolicy
• config::PersistenceStrategy
• config::ReadConsistencyPolicy
• watch::WatchEventType

Traits

• CommitHandler
• ElectionCore
• Lease
• LogStore
• Membership
• MetaStore
• PurgeExecutor
• RaftOneshot
• ReplicationCore
• SnapshotPolicy
• StateMachine
• StateMachineHandler
• StorageEngine
• Transport

Functions

• client_command_to_entry_payloads
• ensure_safe_join
• grpc_task_with_timeout_and_exponential_backoff
• raft_event_to_test_event
• test_utils::create_config_entries
• test_utils::create_fake_compressed_snapshot
• test_utils::create_fake_dir_compressed_snapshot
• test_utils::create_mixed_entries
• test_utils::create_test_chunk
• test_utils::create_test_compressed_snapshot
• test_utils::create_test_snapshot_stream
• test_utils::generate_delete_commands
• test_utils::generate_insert_commands
• test_utils::mock::mock_raft_builder::mock_election_core
• test_utils::mock::mock_raft_builder::mock_membership
• test_utils::mock::mock_raft_builder::mock_purge_exewcutor
• test_utils::mock::mock_raft_builder::mock_raft_log
• test_utils::mock::mock_raft_builder::mock_replication_handler
• test_utils::mock::mock_raft_builder::mock_state_machine
• test_utils::mock::mock_raft_builder::mock_state_machine_handler
• test_utils::mock::mock_raft_builder::mock_transport
• test_utils::mock::mock_raft_context
• test_utils::node_config
• test_utils::snapshot_config