MCPcopy Create free account

hub / github.com/Migorithm/duva / functions

Functions954 in github.com/Migorithm/duva

⨍ Functions 954◇ Types & classes 154
↓ 5 callersMethodpersist_many
(&mut self, entries: Vec<WriteOperation>)
duva/src/domains/replications/replication.rs:203
↓ 5 callersMethodpop
(&mut self, key: String, count: usize, from_left: bool)
duva/src/domains/caches/actor.rs:251
↓ 5 callersMethodrange
(&self, start_exclusive: u64, end_inclusive: u64)
duva/src/domains/replications/replication.rs:257
↓ 5 callersMethodrebalance_request
( &mut self, request_to: PeerIdentifier, lazy_option: LazyOption, )
duva/src/domains/cluster_actors/actor.rs:637
↓ 5 callersMethodroute_set
(&self, cache_entry: CacheEntry)
duva/src/domains/caches/cache_manager.rs:153
↓ 5 callersMethodrun
(mut self)
duva-client/src/broker/mod.rs:68
↓ 5 callersMethodset
(&mut self, cache_entry: CacheEntry)
duva/src/domains/caches/actor.rs:152
↓ 5 callersMethodset_hashring
(&self, ring: HashRing)
duva/src/domains/peers/command.rs:140
↓ 5 callersFunctionsetup_blocked_cluster_actor_with_requests
Helper function to setup blocked cluster actor with pending requests
duva/src/domains/cluster_actors/actor/tests/mod.rs:236
↓ 5 callersMethodsize_decode
(&mut self)
duva/src/domains/saves/endec/decoder.rs:89
↓ 5 callersMethodstring_decode
Decode a size-encoded value based on the first two bits and return the decoded value as a string.
duva/src/domains/saves/endec/decoder.rs:53
↓ 5 callersMethodto_datetime
(&self)
duva/src/domains/saves/endec/mod.rs:103
↓ 4 callersMethodadd_peer
( &mut self, peer: Peer, optional_callback: Option<Callback<anyhow::Result<()>>>,
duva/src/domains/cluster_actors/actor.rs:163
↓ 4 callersMethodbind_addr
(&self)
duva/src/config.rs:83
↓ 4 callersMethodbind_addr
(&self)
duva/tests/common.rs:140
↓ 4 callersMethodcommit_entry
(&mut self, entry: LogEntry, index: u64)
duva/src/domains/cluster_actors/actor.rs:965
↓ 4 callersMethodcurr_match_index
(&self)
duva/src/domains/peers/peer.rs:46
↓ 4 callersMethoddestructure
(self)
duva/src/domains/caches/cache_objects/entry.rs:62
↓ 4 callersMethodencode_with_key
(&self)
duva/src/domains/saves/endec/encoder.rs:16
↓ 4 callersMethodextract_cmd
(&mut self)
duva/src/domains/peers/connections/inbound/stream.rs:87
↓ 4 callersMethodfind_replid
(&self, hash: u64)
duva/src/domains/cluster_actors/hash_ring.rs:85
↓ 4 callersMethodget_topology
(&self)
duva/src/domains/cluster_actors/actor.rs:784
↓ 4 callersMethodhandle
(mut self, mut recv: Receiver<CacheCommand>)
duva/src/domains/caches/actor.rs:36
↓ 4 callersMethodkill
(self)
duva/src/domains/peers/peer.rs:62
↓ 4 callersMethodleader_req_consensus
(&mut self, req: ConsensusRequest)
duva/src/domains/cluster_actors/actor.rs:328
↓ 4 callersMethodload_header
read data and check first 5 ascii code convertable hex bytes are equal to "REDIS" then read 4 digit Header version (like 0011) and return RdbFileLoade
duva/src/domains/saves/endec/decoder.rs:161
↓ 4 callersMethodlpop
(&mut self)
duva/src/domains/caches/cache_objects/types/quicklist.rs:63
↓ 4 callersMethodlpush
Efficiently prepends an entry by rebuilding the data vector once.
duva/src/domains/caches/cache_objects/types/quicklist.rs:45
↓ 4 callersMethodltrim
(&mut self, start: isize, end: isize)
duva/src/domains/caches/cache_objects/types/quicklist.rs:571
↓ 4 callersMethodmatch_query
(&self, request: HandShakeRequestEnum)
duva/src/domains/peers/connections/inbound/request.rs:25
↓ 4 callersMethodmerge
(self, other: QueryIO)
duva/src/domains/query_io.rs:95
↓ 4 callersFunctionpanic_if_election_not_done
(order: &str, port1: u16, port2: u16, num_possible_nodes: u32)
duva/tests/replication_ops/mod.rs:11
↓ 4 callersMethodread_at
(&mut self, at: u64)
duva/src/domains/replications/replication.rs:213
↓ 4 callersMethodremove_peer
(&mut self, peer_addr: &PeerIdentifier)
duva/src/domains/cluster_actors/actor.rs:808
↓ 4 callersMethodreplicas
(&self)
duva/src/domains/cluster_actors/actor.rs:688
↓ 4 callersMethodreplicate_log_entries
(&mut self, rpc: &mut HeartBeat)
duva/src/domains/cluster_actors/actor.rs:1008
↓ 4 callersMethodreturn_node
(&mut self, mut node: QuickListNode)
duva/src/domains/caches/cache_objects/types/quicklist.rs:364
↓ 4 callersMethodroute_mset
(&self, cache_entries: Vec<CacheEntry>)
duva/src/domains/caches/cache_manager.rs:158
↓ 4 callersMethodsend
Just write bytes with newline to the child's stdin.
duva/tests/common.rs:286
↓ 4 callersMethodsend_heartbeat
(&mut self, heartbeat: HeartBeat)
duva/src/domains/cluster_actors/actor.rs:742
↓ 4 callersMethodsend_replication_ack
Follower notified the leader of its acknowledgment, then leader store match index for the given follower
duva/src/domains/cluster_actors/actor.rs:974
↓ 4 callersFunctionserialized_len_with_bincode
(prefix: char, arg: &T)
duva/src/domains/query_io.rs:119
↓ 4 callersMethodset_response
(&mut self, conn_offset: Option<ConnectionOffset>)
duva/src/domains/cluster_actors/actor/client_sessions.rs:26
↓ 4 callersMethodshould_break
(&self)
duva/src/domains/error.rs:24
↓ 4 callersMethodspawn
( read_connected: impl Into<ReadConnected>, cluster_handler: ClusterActorSender, peer_
duva/src/domains/peers/service.rs:21
↓ 4 callersMethodstate
(&self)
duva/src/domains/peers/peer.rs:40
↓ 4 callersMethodstep_down
Used when: 1) on follower's consensus rejection when term is not matched 2) step down operation is given from user
duva/src/domains/cluster_actors/actor.rs:1103
↓ 4 callersMethodstore_batch
(&mut self, id: BatchId, batch: QueuedKeysToMigrate)
duva/src/domains/peers/command.rs:199
↓ 4 callersMethodvote_election
#[instrument(level = tracing::Level::INFO, skip(self, request_vote))]
duva/src/domains/cluster_actors/actor.rs:428
↓ 4 callersMethodwrite_single_entry
( &mut self, entry: LogEntry, current_term: u64, conn_offset: Option<Connectio
duva/src/domains/replications/replication.rs:176
↓ 3 callersMethodappend
(&mut self, key: String, value: String)
duva/src/domains/caches/actor.rs:173
↓ 3 callersMethodcreate
(buffer: usize)
duva/src/domains/cluster_actors/queue.rs:20
↓ 3 callersFunctionencode_key_bytes
(key: &str, value: &[u8])
duva/src/domains/saves/endec/encoder.rs:76
↓ 3 callersMethodfind_replica_mut
(&mut self, peer_id: &PeerIdentifier)
duva/src/domains/cluster_actors/actor.rs:731
↓ 3 callersMethodfsync
Forces any buffered data to be written to disk.
duva/src/adapters/loggers/disk_based.rs:198
↓ 3 callersMethodget
(&self)
duva/src/adapters/loggers/op_logs.rs:28
↓ 3 callersMethodhandle_migration_ack
(&mut self, batch_id: BatchId)
duva/src/domains/cluster_actors/actor.rs:1374
↓ 3 callersMethodhas_expiry
(&self)
duva/src/domains/caches/lru_cache.rs:341
↓ 3 callersMethodinitiate_vote
(&mut self, replica_count: usize)
duva/src/domains/replications/replication.rs:172
↓ 3 callersMethodlast_log_term
(&self)
duva/src/domains/replications/replication.rs:361
↓ 3 callersMethodload_database
(mut self)
duva/src/domains/saves/endec/decoder.rs:220
↓ 3 callersMethodload_metadata
(mut self)
duva/src/domains/saves/endec/decoder.rs:189
↓ 3 callersMethodmigrate_batch
( &mut self, pending_task: PendingMigrationTask, callback: impl Into<Callback<anyhow::
duva/src/domains/cluster_actors/actor.rs:1279
↓ 3 callersMethodoneshot_channels
Send recv handler firstly to the background and return senders and join handlers for receivers
duva/src/domains/caches/cache_manager.rs:273
↓ 3 callersMethodreceive_batch
( &mut self, migrate_batch: BatchEntries, from: &PeerIdentifier, )
duva/src/domains/cluster_actors/actor.rs:1327
↓ 3 callersMethodreceive_connection_msgs
(&mut self)
duva/src/domains/cluster_actors/actor/tests/mod.rs:56
↓ 3 callersMethodreceive_election_vote
( &mut self, from: &PeerIdentifier, election_vote: ElectionVote, )
duva/src/domains/cluster_actors/actor.rs:502
↓ 3 callersMethodremove_outdated_connections
(&mut self, node_repl_ids: Vec<ReplicationId>)
duva-client/src/broker/node_connections.rs:46
↓ 3 callersMethodreplicas_mut
(&mut self)
duva/src/domains/cluster_actors/actor.rs:724
↓ 3 callersMethodrole
(&self)
duva/src/domains/peers/peer.rs:78
↓ 3 callersMethodroute_get_node_state
(&self)
duva/src/domains/cluster_actors/queue.rs:82
↓ 3 callersMethodroute_keys
(&self, pattern: Option<String>)
duva/src/domains/caches/cache_manager.rs:241
↓ 3 callersMethodrun_for_election
(&mut self)
duva/src/domains/cluster_actors/actor.rs:1033
↓ 3 callersMethodsend_to
( &self, node_id: &ReplicationId, client_action: ClientAction, )
duva-client/src/broker/node_connections.rs:69
↓ 3 callersFunctionsetup_scheduler
Helper function to create a test scheduler
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:177
↓ 3 callersMethodshard_leaders
(&self)
duva/src/domains/cluster_actors/actor.rs:706
↓ 3 callersMethodtake_string
(&mut self, n: usize)
duva/src/domains/saves/endec/decoder.rs:42
↓ 3 callersFunctiontime_in_secs
()
duva/src/domains/replications/replication.rs:384
↓ 3 callersMethodtry_merge_at
(&mut self, index: usize)
duva/src/domains/caches/cache_objects/types/quicklist.rs:373
↓ 3 callersMethodtry_to_string
(&self)
duva/src/domains/caches/cache_objects/value.rs:23
↓ 3 callersMethodunblock_pending_requests
(&mut self)
duva/src/domains/cluster_actors/actor.rs:1421
↓ 3 callersMethodwith_bind_addr
(mut self, leader_bind_addr: String)
duva/tests/common.rs:59
↓ 2 callersMethodadd_node_connection
(&mut self, peer_id: PeerIdentifier)
duva-client/src/broker/mod.rs:187
↓ 2 callersMethodadd_partitions
( mut self, partitions: Vec<(ReplicationId, PeerIdentifier)>, )
duva/src/domains/cluster_actors/hash_ring.rs:66
↓ 2 callersMethodadd_req
(&mut self, req: ConsensusRequest)
duva/src/domains/peers/command.rs:196
↓ 2 callersMethodall_keys
Returns all keys involved in the operation.
duva/src/domains/replications/operation.rs:58
↓ 2 callersMethodbecome_candidate
(&mut self)
duva/src/domains/cluster_actors/actor.rs:1135
↓ 2 callersMethodbroadcast_topology_change
Broadcasts the current topology to all connected clients
duva/src/domains/cluster_actors/actor.rs:780
↓ 2 callersMethodcallback
(self, query_io: ServerResponse)
duva-client/src/command.rs:66
↓ 2 callersMethodcheck_indicator
(&self, iden: u8)
duva/src/domains/saves/endec/decoder.rs:153
↓ 2 callersMethodcurr_con_idx
(&self)
duva/src/domains/replications/replication.rs:228
↓ 2 callersMethoddecide_peer_state
(self, my_repl_id: &ReplicationId)
duva/src/domains/replications/state.rs:18
↓ 2 callersMethodencode_chunk_queue
(&mut self)
duva/src/domains/saves/actor.rs:69
↓ 2 callersFunctionencode_header
()
duva/src/domains/saves/endec/encoder.rs:32
↓ 2 callersFunctionencode_metadata
(metadata: Metadata)
duva/src/domains/saves/endec/encoder.rs:39
↓ 2 callersMethodexists
(&mut self, key: String, callback: Callback<bool>)
duva/src/domains/caches/actor.rs:139
↓ 2 callersMethodexpiry
(&self)
duva/src/domains/caches/cache_objects/entry.rs:33
↓ 2 callersFunctionextract_host_and_port
(addr: &str)
duva/src/domains/peers/identifier.rs:29
↓ 2 callersMethodextract_section
(&mut self)
duva/src/domains/saves/endec/decoder.rs:237
↓ 2 callersMethodfind_offset
(&self, log_index: u64)
duva/src/adapters/loggers/disk_based.rs:137
← previousnext →101–200 of 954, ranked by callers