MCPcopy Create free account

hub / github.com/Migorithm/duva / functions

Functions954 in github.com/Migorithm/duva

⨍ Functions 954◇ Types & classes 154
↓ 127 callersMethodlen
(&self)
duva/src/domains/caches/lru_cache.rs:99
↓ 123 callersMethodsend
( &self, cmd: impl Into<ClusterCommand>, )
duva/src/domains/cluster_actors/queue.rs:37
↓ 85 callersFunctioncreate
()
duva-client/src/cli/editor/mod.rs:9
↓ 80 callersMethodinsert
(&mut self, value: T)
duva/src/domains/caches/lru_cache.rs:45
↓ 79 callersMethoditer
(&self)
duva/src/domains/caches/lru_cache.rs:107
↓ 75 callersMethodwith_append_only
(mut self, append_only: bool)
duva/tests/common.rs:72
↓ 67 callersMethodrecv
(&mut self)
duva/src/domains/cluster_actors/queue.rs:182
↓ 61 callersMethodpush
(&mut self, index: u64, deferred_read: DeferredRead)
duva/src/domains/caches/read_queue.rs:24
↓ 54 callersMethodsend_and_get
Get one line response (with a bounded timeout). Returns empty string on timeout/error.
duva/tests/common.rs:297
↓ 51 callersMethodrpush
(&mut self, value: &Bytes)
duva/src/domains/caches/cache_objects/types/quicklist.rs:91
↓ 45 callersFunctionspawn_server_process
(env: &ServerEnv)
duva/tests/common.rs:106
↓ 41 callersMethodlog_state
(&self)
duva/src/domains/cluster_actors/actor.rs:110
↓ 40 callersMethodis_empty
Returns true if there are no logs. Otherwise, returns false.
duva/src/adapters/loggers/op_logs.rs:58
↓ 36 callersMethodas_str
(&self)
duva/src/domains/caches/cache_objects/value.rs:60
↓ 36 callersMethodput
(&mut self, key: K, value: V)
duva/src/domains/caches/lru_cache.rs:230
↓ 30 callersMethodget_mut
(&mut self, index: usize)
duva/src/domains/caches/lru_cache.rs:64
↓ 28 callersMethodlen
(&self)
duva/src/domains/caches/cache_objects/value.rs:33
↓ 26 callersMethodwrite_many
(&mut self, ops: Vec<WriteOperation>)
duva/src/adapters/loggers/disk_based.rs:274
↓ 25 callersMethodtest_add_peer
( &mut self, port: u16, repl_id: Option<ReplicationId>, is_leader: bool, )
duva/src/domains/cluster_actors/actor/tests/mod.rs:266
↓ 24 callersMethodentry
(&mut self, key: K)
duva/src/domains/caches/lru_cache.rs:111
↓ 23 callersMethodrecord_heartbeat
(&mut self)
duva/src/domains/peers/peer.rs:54
↓ 23 callersMethodset_partitions
Sets the hash ring partitions to exactly match the provided list. This method will not respect any existing partitions that are not in the given parti
duva/src/domains/cluster_actors/hash_ring.rs:40
↓ 21 callersMethodsend_and_get_vec
Collect up to `cnt` response lines (each line will block up to read_timeout) Returns collected lines (could be fewer than cnt on timeout/disconnect).
duva/tests/common.rs:326
↓ 19 callersMethodselect_shard
(&self, key: &str)
duva/src/domains/caches/cache_manager.rs:302
↓ 18 callersMethodget
(&mut self, key: &str, callback: Callback<CacheValue>)
duva/src/domains/caches/actor.rs:142
↓ 17 callersMethodremove
(&mut self, index: usize)
duva/src/domains/caches/lru_cache.rs:51
↓ 16 callersMethodor_insert
(self, default: V)
duva/src/domains/caches/lru_cache.rs:299
↓ 16 callersMethodrange
(&self, start_exclusive: u64, end_inclusive: u64)
duva/src/adapters/loggers/disk_based.rs:356
↓ 16 callersMethodread_at
(&mut self, log_index: u64)
duva/src/adapters/loggers/disk_based.rs:458
↓ 15 callersFunctionencode_string
(size: usize, value: &str)
duva/src/domains/saves/endec/encoder.rs:101
↓ 15 callersFunctionform_cluster
(envs: [&mut ServerEnv; T])
duva/tests/common.rs:392
↓ 15 callersMethodto_vec
(&self)
duva/src/domains/caches/cache_objects/types/quicklist.rs:157
↓ 14 callersFunctionfnv_1a_hash
(value: &str)
duva/src/domains/cluster_actors/hash_ring/hash_func.rs:4
↓ 14 callersMethodget_node_for_key
(&self, key: &str)
duva/src/domains/cluster_actors/hash_ring.rs:166
↓ 14 callersMethodis_leader
(&self)
duva/src/domains/replications/replication.rs:127
↓ 14 callersMethodself_identifier
(&self)
duva/src/domains/replications/replication.rs:71
↓ 12 callersFunctionassert_expected_queryio
Helper function to assert migration batch ack
duva/src/domains/cluster_actors/actor/tests/mod.rs:253
↓ 12 callersMethodnext
(&mut self)
duva/src/domains/caches/lru_cache.rs:284
↓ 12 callersMethodskip
(&mut self, n: usize)
duva/src/domains/saves/endec/decoder.rs:38
↓ 11 callersMethodlrange
(&mut self, start: isize, stop: isize)
duva/src/domains/caches/cache_objects/types/quicklist.rs:521
↓ 11 callersMethodreplicate
(&mut self, mut heartbeat: HeartBeat)
duva/src/domains/cluster_actors/actor.rs:985
↓ 11 callersMethodwith_hf
(mut self, hf: u128)
duva/tests/common.rs:63
↓ 11 callersMethodwrite_all
(&mut self, buf: &[u8])
duva-client/src/broker/write_stream.rs:9
↓ 10 callersMethodchain
( &self, senders: Vec<Callback<T>>, )
duva/src/domains/caches/cache_manager.rs:50
↓ 10 callersFunctioncreate_ops
Helper to create dummy operations
duva/src/adapters/loggers/disk_based.rs:817
↓ 10 callersMethodflush
(&mut self)
duva/src/domains/replications/replication.rs:195
↓ 10 callersFunctionio_error_from_kind
(kind: ErrorKind)
duva/src/adapters/io/tokio_stream.rs:130
↓ 10 callersMethodsend
(&mut self, msg: PeerMessage)
duva/src/domains/cluster_actors/actor/tests/mod.rs:63
↓ 10 callersMethodwrite
(&mut self, buf: &[u8])
duva/src/domains/saves/actor.rs:98
↓ 9 callersMethodcalculate_phi_at
(&self, now: Instant)
duva/src/domains/peers/peer.rs:143
↓ 9 callersMethodensure_decompressed
Ensures the node is decompressed. Must be called before any read/write.
duva/src/domains/caches/cache_objects/types/quicklist.rs:204
↓ 9 callersMethodget
(&self, index: usize)
duva/src/domains/caches/lru_cache.rs:60
↓ 9 callersMethodlast_log_index
(&self)
duva/src/domains/replications/replication.rs:369
↓ 9 callersFunctionreplid_and_nodeid
(port: u16)
duva/src/domains/cluster_actors/hash_ring/tests/mod.rs:17
↓ 9 callersMethodrotate_segment
(&mut self)
duva/src/adapters/loggers/disk_based.rs:253
↓ 9 callersMethodsend
(&mut self, io: impl Into<PeerMessage>)
duva/src/domains/peers/peer.rs:58
↓ 9 callersMethodtruncate
(&mut self, log_index: u64)
duva/src/adapters/loggers/disk_based.rs:144
↓ 8 callersMethodbuild
(self)
duva/src/domains/saves/endec/decoder.rs:31
↓ 8 callersFunctiondeserialize
(buffer: impl Into<Bytes>)
duva/src/domains/query_io.rs:176
↓ 8 callersMethodkeys
(&self)
duva/src/domains/caches/lru_cache.rs:103
↓ 8 callersMethodsend
(&self, client_action: ClientAction)
duva-client/src/broker/node_connections.rs:99
↓ 8 callersMethodsend_connection_msg
(&mut self, _arg: &str)
duva/src/domains/cluster_actors/actor/tests/mod.rs:69
↓ 8 callersMethodset_term
(&mut self, term: u64)
duva/src/domains/replications/replication.rs:84
↓ 8 callersMethodunblock_write_on_migration_done
New hash ring stored at this point with the current shard leaders
duva/src/domains/cluster_actors/actor.rs:1409
↓ 7 callersMethodclear
(&mut self)
duva/src/domains/caches/lru_cache.rs:183
↓ 7 callersMethodclone_state
(&self)
duva/src/domains/replications/replication.rs:62
↓ 7 callersMethoddefault_heartbeat
(&self, hop_count: u8)
duva/src/domains/replications/replication.rs:91
↓ 7 callersMethoddeserialized_read
(&mut self)
duva/src/adapters/io/tokio_stream.rs:108
↓ 7 callersMethodis_empty
(&self)
duva/src/adapters/loggers/disk_based.rs:479
↓ 7 callersMethodis_replica
(&self, replid: &ReplicationId)
duva/src/domains/peers/peer.rs:66
↓ 7 callersMethodpush
(&mut self, input_context: InputContext)
duva-client/src/command.rs:16
↓ 7 callersMethodremove_identifier
(&mut self)
duva/src/domains/saves/endec/decoder.rs:48
↓ 7 callersMethodserialized_write
(&mut self, buf: impl bincode::Encode + Send)
duva/src/adapters/io/tokio_stream.rs:75
↓ 6 callersMethodack_replication
( &mut self, from: &PeerIdentifier, repl_res: ReplicationAck, )
duva/src/domains/cluster_actors/actor.rs:464
↓ 6 callersMethodbyte_size
(&self)
duva/src/domains/caches/cache_objects/types/quicklist.rs:250
↓ 6 callersMethodcompress_if_needed
(&mut self)
duva/src/domains/caches/cache_objects/types/quicklist.rs:498
↓ 6 callersMethodget_mut
(&mut self)
duva/src/adapters/loggers/op_logs.rs:22
↓ 6 callersMethodid
(&self)
duva/src/domains/peers/peer.rs:37
↓ 6 callersMethodincrease_con_idx_by
(&self, by: u64)
duva/src/domains/replications/replication.rs:224
↓ 6 callersMethodkey
(&self)
duva/src/domains/caches/cache_objects/entry.rs:40
↓ 6 callersMethodllen
(&mut self, key: String)
duva/src/domains/caches/actor.rs:267
↓ 6 callersMethodmaybe_update_hashring
If the hashring is valid, make a plan to migrate data for each paritition
duva/src/domains/cluster_actors/actor.rs:1198
↓ 6 callersMethodreplid
(&self)
duva/src/domains/peers/peer.rs:43
↓ 6 callersFunctionreplid_create_helper
Migration plan tests
duva/src/domains/cluster_actors/hash_ring/tests/migration.rs:8
↓ 6 callersMethodreq_consensus
(&mut self, req: ConsensusRequest, send_in_mills: Option<u64>)
duva/src/domains/cluster_actors/actor.rs:376
↓ 6 callersMethodroute_get
(&self, key: impl AsRef<str>)
duva/src/domains/caches/cache_manager.rs:66
↓ 6 callersMethodstart_rebalance
(&mut self)
duva/src/domains/cluster_actors/actor.rs:659
↓ 6 callersMethodtry_key_value
(&mut self)
duva/src/domains/saves/endec/decoder.rs:291
↓ 6 callersMethodwait
(self)
duva/src/types.rs:33
↓ 6 callersMethodwith_expiry
(self, expiry: DateTime<Utc>)
duva/src/domains/caches/cache_objects/value.rs:19
↓ 5 callersMethodbind_addr
(&self)
duva/src/domains/peers/identifier.rs:19
↓ 5 callersMethodblock_write_reqs
! BLOCK subsequent requests until rebalance is done
duva/src/domains/cluster_actors/actor.rs:773
↓ 5 callersMethodcluster_nodes
(&self)
duva/src/domains/cluster_actors/actor.rs:420
↓ 5 callersMethodcreate_migration_chunks
( &self, new_ring: &HashRing, keys: Vec<String>, )
duva/src/domains/cluster_actors/hash_ring.rs:94
↓ 5 callersFunctionencode_size
(size: usize)
duva/src/domains/saves/endec/encoder.rs:118
↓ 5 callersFunctionextract_range
(encoded: &[u8], range: RangeInclusive<usize>)
duva/src/domains/saves/endec/mod.rs:92
↓ 5 callersMethodfind_tail_offset
Helper function to find the tail offset
duva/src/domains/caches/cache_objects/types/quicklist.rs:131
↓ 5 callersMethodindex_get
(&mut self, key: &str, read_idx: u64, callback: Callback<CacheValue>)
duva/src/domains/caches/actor.rs:146
↓ 5 callersMethodlen_bytes
(&self, from: usize)
duva/src/domains/caches/cache_objects/types/quicklist.rs:38
↓ 5 callersMethodmove_to_head
(&mut self, index: usize)
duva/src/domains/caches/lru_cache.rs:119
next →1–100 of 954, ranked by callers