MCPcopy Create free account

hub / github.com/Migorithm/duva / functions

Functions954 in github.com/Migorithm/duva

⨍ Functions 954◇ Types & classes 154
↓ 1 callersMethodrequest_vote
(&self)
duva/src/domains/replications/replication.rs:149
↓ 1 callersMethodreset_election_timeout
(&mut self, term: u64)
duva/src/domains/cluster_actors/actor.rs:1048
↓ 1 callersMethodreset_election_votes
(&mut self)
duva/src/domains/replications/replication.rs:44
↓ 1 callersMethodreset_log
(&mut self)
duva/src/domains/replications/replication.rs:236
↓ 1 callersMethodrevert_voting
(&mut self, term: u64, candidate_id: &PeerIdentifier)
duva/src/domains/replications/replication.rs:105
↓ 1 callersMethodroute_append
(&self, key: String, value: String)
duva/src/domains/caches/cache_manager.rs:375
↓ 1 callersMethodroute_cluster_meet
( &self, peer_identifier: PeerIdentifier, lazy_option: LazyOption, )
duva/src/domains/cluster_actors/queue.rs:130
↓ 1 callersMethodroute_cluster_nodes
(&self)
duva/src/domains/cluster_actors/queue.rs:145
↓ 1 callersMethodroute_cluster_reshard
(&self)
duva/src/domains/cluster_actors/queue.rs:139
↓ 1 callersMethodroute_command_by_keys
The folowing operation is for both: - single key operation - multi key operaitons When in comes to multi key operations, grouping logic needs to be co
duva-client/src/broker/mod.rs:247
↓ 1 callersMethodroute_exists
(&self, keys: Vec<String>)
duva/src/domains/caches/cache_manager.rs:293
↓ 1 callersMethodroute_forget_peer
( &self, peer_identifier: PeerIdentifier, )
duva/src/domains/cluster_actors/queue.rs:111
↓ 1 callersMethodroute_get_cluster_info
(&self)
duva/src/domains/cluster_actors/queue.rs:94
↓ 1 callersMethodroute_get_leader_id
(&self)
duva/src/domains/cluster_actors/queue.rs:88
↓ 1 callersMethodroute_get_peers
(&self)
duva/src/domains/cluster_actors/queue.rs:58
↓ 1 callersMethodroute_get_roles
(&self)
duva/src/domains/cluster_actors/queue.rs:151
↓ 1 callersMethodroute_get_topology
(&self)
duva/src/domains/cluster_actors/queue.rs:65
↓ 1 callersMethodroute_index_get
(&self, key: String, index: u64)
duva/src/domains/caches/cache_manager.rs:329
↓ 1 callersMethodroute_info
(&self, action: ClientAction)
duva-client/src/broker/mod.rs:219
↓ 1 callersMethodroute_lindex
(&self, key: String, index: isize)
duva/src/domains/caches/cache_manager.rs:414
↓ 1 callersMethodroute_llen
(&self, key: String)
duva/src/domains/caches/cache_manager.rs:390
↓ 1 callersMethodroute_lpop
(&self, key: String, count: usize)
duva/src/domains/caches/cache_manager.rs:180
↓ 1 callersMethodroute_lpush
(&self, key: String, values: Vec<String>)
duva/src/domains/caches/cache_manager.rs:166
↓ 1 callersMethodroute_lpushx
(&self, key: String, value: Vec<String>)
duva/src/domains/caches/cache_manager.rs:172
↓ 1 callersMethodroute_lrange
( &self, key: String, start: isize, end: isize, )
duva/src/domains/caches/cache_manager.rs:396
↓ 1 callersMethodroute_lset
(&self, key: String, index: isize, value: String)
duva/src/domains/caches/cache_manager.rs:421
↓ 1 callersMethodroute_ltrim
(&self, key: String, start: isize, end: isize)
duva/src/domains/caches/cache_manager.rs:407
↓ 1 callersMethodroute_replicaof
( &self, peer_identifier: PeerIdentifier, )
duva/src/domains/cluster_actors/queue.rs:121
↓ 1 callersMethodroute_rpop
(&self, key: String, count: usize)
duva/src/domains/caches/cache_manager.rs:202
↓ 1 callersMethodroute_rpush
(&self, key: String, value: Vec<String>)
duva/src/domains/caches/cache_manager.rs:188
↓ 1 callersMethodroute_rpushx
(&self, key: String, value: Vec<String>)
duva/src/domains/caches/cache_manager.rs:194
↓ 1 callersMethodroute_save
( &self, save_target: SaveTarget, repl_id: ReplicationId, current_offset: u64,
duva/src/domains/caches/cache_manager.rs:210
↓ 1 callersMethodroute_subscribe_topology_change
( &self, )
duva/src/domains/cluster_actors/queue.rs:157
↓ 1 callersMethodroute_ttl
(&self, key: String)
duva/src/domains/caches/cache_manager.rs:361
↓ 1 callersMethodrpop
(&mut self)
duva/src/domains/caches/cache_objects/types/quicklist.rs:98
↓ 1 callersMethodrpushx
(&mut self, key: String, values: Vec<String>)
duva/src/domains/caches/actor.rs:238
↓ 1 callersMethodrun
(con_idx: Arc<AtomicU64>)
duva/src/domains/caches/actor.rs:23
↓ 1 callersFunctionrun_cluster_forget_makes_all_nodes_forget_target_node
( with_append_only: bool, )
duva/tests/cluster_ops/test_cluster_forget_makes_all_nodes_forget_target_node.rs:3
↓ 1 callersFunctionrun_cluster_forget_node_return_error_when_wrong_id_given
(env: ServerEnv)
duva/tests/cluster_ops/test_cluster_forget_when_wrong_id_given.rs:7
↓ 1 callersFunctionrun_cluster_meet
(append_only: bool)
duva/tests/cluster_ops/test_cluster_meet.rs:5
↓ 1 callersFunctionrun_cluster_meet_with_migration
(append_only: bool)
duva/tests/cluster_ops/test_cluster_meet.rs:68
↓ 1 callersFunctionrun_cluster_topology_change_when_new_node_added
(with_append_only: bool)
duva/tests/cluster_ops/test_cluster_known_nodes_increase_when_new_replica_is_added.rs:3
↓ 1 callersFunctionrun_config_get_dir
(env: ServerEnv)
duva/tests/client_ops/test_config_get_dir.rs:7
↓ 1 callersFunctionrun_decr
(with_append_only: bool)
duva/tests/client_ops/test_decr.rs:3
↓ 1 callersFunctionrun_decrby
(env: ServerEnv)
duva/tests/client_ops/test_decrby.rs:3
↓ 1 callersFunctionrun_del
(env: ServerEnv)
duva/tests/client_ops/test_del.rs:7
↓ 1 callersFunctionrun_exists
(env: ServerEnv)
duva/tests/client_ops/test_exists.rs:7
↓ 1 callersFunctionrun_full_sync_on_newly_added_replica
(with_append_only: bool)
duva/tests/replication_ops/test_sync.rs:3
↓ 1 callersFunctionrun_incrby
(env: ServerEnv)
duva/tests/client_ops/test_incrby.rs:3
↓ 1 callersFunctionrun_invalid_replicaof
(with_append_only: bool)
duva/tests/cluster_ops/test_lazy_discovery.rs:58
↓ 1 callersFunctionrun_keys
(env: ServerEnv)
duva/tests/client_ops/test_keys.rs:3
↓ 1 callersFunctionrun_leader_election
(with_append_only: bool)
duva/tests/replication_ops/test_leader_election.rs:6
↓ 1 callersFunctionrun_leader_election_twice
following test is to see if election works even after the first election.
duva/tests/replication_ops/test_leader_election_twice.rs:7
↓ 1 callersFunctionrun_lindex
(env: ServerEnv)
duva/tests/client_ops/test_lindex.rs:3
↓ 1 callersFunctionrun_llen
(env: ServerEnv)
duva/tests/client_ops/test_llen.rs:3
↓ 1 callersFunctionrun_lpop
(env: ServerEnv)
duva/tests/client_ops/test_lpop.rs:3
↓ 1 callersFunctionrun_lpush
(env: ServerEnv)
duva/tests/client_ops/test_lpush.rs:3
↓ 1 callersFunctionrun_lpushx
(env: ServerEnv)
duva/tests/client_ops/test_lpushx.rs:5
↓ 1 callersFunctionrun_lrange
(env: ServerEnv)
duva/tests/client_ops/test_lrange.rs:3
↓ 1 callersFunctionrun_lset
(env: ServerEnv)
duva/tests/client_ops/test_lset.rs:3
↓ 1 callersFunctionrun_ltrim
(env: ServerEnv)
duva/tests/client_ops/test_ltrim.rs:3
↓ 1 callersFunctionrun_removed_leader_connection_with_replica
(with_append_only: bool)
duva/tests/client_ops/test_removed_leader_connection_with_replica.rs:8
↓ 1 callersFunctionrun_removed_leader_without_replica
(env1: ServerEnv, env2: ServerEnv)
duva/tests/client_ops/test_removed_leader_connection_without_replica.rs:5
↓ 1 callersFunctionrun_removes_node_when_heartbeat_is_not_received_for_certain_time
( with_append_only: bool, )
duva/tests/cluster_ops/test_removes_node_when_heartbeat_is_not_received_for_certain_time.rs:5
↓ 1 callersFunctionrun_replication_info
(env: ServerEnv)
duva/tests/client_ops/test_replication_info.rs:7
↓ 1 callersFunctionrun_route_del_keys
(append_only: bool, num_keys: u32, duration: Duration)
duva/tests/client_ops/test_route_del.rs:5
↓ 1 callersFunctionrun_route_keys_with_num_of_keys
( append_only: bool, num_keys: u32, duration: Duration, )
duva/tests/client_ops/test_route_keys.rs:5
↓ 1 callersFunctionrun_rpop
(env: ServerEnv)
duva/tests/client_ops/test_rpop.rs:3
↓ 1 callersFunctionrun_rpush
(env: ServerEnv)
duva/tests/client_ops/test_rpush.rs:3
↓ 1 callersFunctionrun_rpushx
(env: ServerEnv)
duva/tests/client_ops/test_rpushx.rs:5
↓ 1 callersFunctionrun_server_process
(env: &ServerEnv)
duva/tests/common.rs:191
↓ 1 callersFunctionrun_set_get
(env: ServerEnv)
duva/tests/client_ops/test_set_get.rs:7
↓ 1 callersFunctionrun_set_operation_reaches_to_all_replicas
(with_append_only: bool)
duva/tests/replication_ops/test_raft_happy_case.rs:7
↓ 1 callersFunctionrun_set_twice_after_election
! EDGE case : when last_log_term is not updated, after the election, first write operation succeeds but second one doesn't ! This is because the leade
duva/tests/replication_ops/test_set_twice_after_election.rs:12
↓ 1 callersFunctionrun_snapshot_persists_and_recovers_state
(env: ServerEnv)
duva/tests/client_ops/test_snapshot_persists_and_recovers_state.rs:6
↓ 1 callersFunctionrun_ttl
(env: ServerEnv)
duva/tests/client_ops/test_ttl.rs:3
↓ 1 callersMethodsave
( &self, outbox: tokio::sync::mpsc::Sender<SaveCommand>, )
duva/src/domains/caches/actor.rs:342
↓ 1 callersMethodsend_all
(&self, client_action: ClientAction)
duva-client/src/broker/node_connections.rs:78
↓ 1 callersMethodsend_batch_ack
(&mut self, batch_id: BatchId, to: PeerIdentifier)
duva/src/domains/cluster_actors/actor.rs:1442
↓ 1 callersMethodsend_cluster_heartbeat
(&mut self)
duva/src/domains/cluster_actors/actor.rs:268
↓ 1 callersMethodsend_cluster_heartbeat
(self, cluster_heartbeat_interval: u64)
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:36
↓ 1 callersMethodsend_cluster_sync_awaiter
( &mut self, callback: Callback<Option<CallbackAwaiter<()>>>, )
duva/src/domains/cluster_actors/actor.rs:201
↓ 1 callersMethodsend_conn_res
( &mut self, cluster_manager: &ClusterActorSender, auth_req: ConnectionRequest, )
duva/src/presentation/clients/stream.rs:99
↓ 1 callersMethodsend_to_seed
(&self, client_action: ClientAction)
duva-client/src/broker/node_connections.rs:65
↓ 1 callersFunctionseparate_command_and_args
(args: Vec<&str>)
duva-client/src/command.rs:43
↓ 1 callersMethodserialize
(self)
duva/src/domains/query_io.rs:33
↓ 1 callersMethodset_append_entries
(self, append_entries: Vec<WriteOperation>)
duva/src/domains/peers/command.rs:128
↓ 1 callersMethodset_match_idx
! leader operation
duva/src/domains/peers/peer.rs:51
↓ 1 callersMethodset_prev_log
(self, prev_log_index: u64, prev_log_term: u64)
duva/src/domains/peers/command.rs:132
↓ 1 callersMethodset_state
(&mut self, state: ReplicationState)
duva/src/domains/replications/replication.rs:356
↓ 1 callersMethodset_target
(&mut self, target: OperationLogs)
duva/src/domains/replications/replication.rs:351
↓ 1 callersMethodshould_stop_extending_storage
( &mut self, builder: &mut DatabaseSectionBuilder, )
duva/src/domains/saves/endec/decoder.rs:258
↓ 1 callersMethodshutdown_gracefully
(&self)
duva/src/domains/caches/cache_manager.rs:433
↓ 1 callersFunctionspawn_stdout_reader_thread
spawn a thread that reads lines from child's stdout and pushes them into tx. The thread will exit when EOF or when an I/O error occurs.
duva/tests/common.rs:367
↓ 1 callersMethodstart_accepting_client_streams
(self)
duva/src/lib.rs:219
↓ 1 callersMethodsuffix
(&self, strip_chars: usize)
duva-client/src/cli/editor/hints.rs:23
↓ 1 callersMethodtake_header
(&mut self)
duva/src/domains/saves/endec/decoder.rs:174
↓ 1 callersMethodtake_low_watermark
(&self)
duva/src/domains/cluster_actors/actor.rs:924
↓ 1 callersMethodtake_pending_requests
(&mut self)
duva/src/domains/caches/read_queue.rs:43
↓ 1 callersMethodtake_shard_key_from_str
(&self, s: &str)
duva/src/domains/caches/cache_manager.rs:323
← previousnext →401–500 of 954, ranked by callers