Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Migorithm/duva
/ functions
Functions
954 in github.com/Migorithm/duva
⨍
Functions
954
◇
Types & classes
154
↓ 1 callers
Method
take_version
(&mut self)
duva/src/domains/saves/endec/decoder.rs:183
↓ 1 callers
Method
try_extract_expiry_time_in_milliseconds
(&mut self)
duva/src/domains/saves/endec/decoder.rs:332
↓ 1 callers
Method
try_extract_expiry_time_in_seconds
(&mut self)
duva/src/domains/saves/endec/decoder.rs:320
↓ 1 callers
Method
try_extract_key_bytes
(&mut self)
duva/src/domains/saves/endec/decoder.rs:344
↓ 1 callers
Method
try_extract_metadata_key_value
(&mut self)
duva/src/domains/saves/endec/decoder.rs:211
↓ 1 callers
Method
try_get_checksum
(&mut self)
duva/src/domains/saves/endec/decoder.rs:352
↓ 1 callers
Method
try_send_ttl
(&self, cache_entry: &CacheEntry)
duva/src/domains/caches/actor.rs:158
↓ 1 callers
Method
try_set_index
(&mut self, builder: &mut DatabaseSectionBuilder)
duva/src/domains/saves/endec/decoder.rs:276
↓ 1 callers
Method
try_set_table_sizes
(&mut self, builder: &mut DatabaseSectionBuilder)
duva/src/domains/saves/endec/decoder.rs:282
↓ 1 callers
Method
turn_follower_mode
(&mut self)
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:134
↓ 1 callers
Method
turn_leader_mode
(&mut self)
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:119
↓ 1 callers
Method
unpack_single_entry
(self)
duva/src/domains/query_io.rs:66
↓ 1 callers
Method
update_metadata
(&mut self, new_entries: &[WriteOperation])
duva/src/domains/replications/replication.rs:338
↓ 1 callers
Method
update_repl_leader
(&mut self, replid: ReplicationId, new_pnode: PeerIdentifier)
duva/src/domains/cluster_actors/hash_ring.rs:171
↓ 1 callers
Method
update_reqid
(&mut self, replid: ReplicationId, res: &ServerResponse)
duva-client/src/broker/mod.rs:287
↓ 1 callers
Method
update_topology
(&mut self, topology: Topology)
duva-client/src/broker/mod.rs:275
↓ 1 callers
Method
vectorize
(self)
duva/src/domains/replications/state.rs:119
↓ 1 callers
Method
vote_for
(&mut self, candidate_id: PeerIdentifier)
duva/src/domains/replications/replication.rs:122
↓ 1 callers
Method
wait_for_acceptance
(&self)
duva/src/domains/cluster_actors/queue.rs:53
↓ 1 callers
Method
wait_signals
(self)
duva/src/signals.rs:39
↓ 1 callers
Method
with_port
(mut self, port: u16)
duva/tests/common.rs:49
↓ 1 callers
Method
with_topology_path
(mut self, topology_path: impl AsRef<Path>)
duva/tests/common.rs:68
Method
ack
(log_idx: u64, curr_term: u64)
duva/src/domains/peers/command.rs:66
Method
add_peer
( mut self, cluster_handler: ClusterActorSender, )
duva/src/domains/peers/connections/inbound/stream.rs:100
Method
add_peer
( mut self, self_port: u16, cluster_handler: ClusterActorSender, optional_call
duva/src/domains/peers/connections/outbound/stream.rs:77
Method
as_str
(&self)
duva/src/domains/caches/cache_objects/entry.rs:66
Method
authenticate
( mut stream: TcpStream, conn_req: ConnectionRequest, )
duva-client/src/broker/mod.rs:113
Method
borrow_decode
( decoder: &mut D, )
duva/src/types.rs:63
Method
cache_manager
Helper function to create cache manager with con_idx
duva/src/domains/cluster_actors/actor/tests/mod.rs:77
Method
cache_manager_with_keys
( keys: Vec<String>, )
duva/src/domains/cluster_actors/actor/tests/mod.rs:83
Method
cluster_actor
(role: ReplicationRole)
duva/src/domains/cluster_actors/actor/tests/mod.rs:163
Method
cluster_meet
! Callback chaining is required as otherwise it will block cluster actor from consuming more messages. ! For example, trying to connect to a server re
duva/src/domains/cluster_actors/actor.rs:574
Method
cluster_member
( actor: &mut ClusterActor, fake_bufs: Vec<FakeReadWrite>, cluster_sender: ClusterActo
duva/src/domains/cluster_actors/actor/tests/mod.rs:182
Method
complete
( &self, line: &str, pos: usize, _ctx: &Context<'_>, )
duva-client/src/cli/editor/completion.rs:62
Method
completion
(&self)
duva-client/src/cli/editor/hints.rs:36
Method
connect
(connect_to: &str)
duva/src/adapters/io/tokio_stream.rs:122
Method
connect_to_server
( &mut self, connect_to: PeerIdentifier, optional_callback: Option<Callback<anyhow::Re
duva/src/domains/cluster_actors/actor.rs:209
Method
consensus_request
( callback: Callback<ConsensusResponse>, session_req: Option<ConnectionOffset>, )
duva/src/domains/cluster_actors/actor/tests/mod.rs:223
Method
convert_str_vec_res
(values: Vec<String>, index: u64)
duva/src/domains/query_io.rs:114
Method
create_peer
( cluster_sender: ClusterActorSender, con_idx: u64, repl_id: &ReplicationId, p
duva/src/domains/cluster_actors/actor/tests/mod.rs:95
Method
decode
(decoder: &mut D)
duva/src/types.rs:57
Method
default
()
duva/src/domains/caches/cache_objects/types/quicklist.rs:184
Method
default
()
duva/tests/common.rs:29
Method
default_with_repl_id
(repl_id: ReplicationId)
duva/src/domains/saves/snapshot/mod.rs:30
Method
deref
(&self)
duva/src/domains/saves/endec/decoder.rs:382
Method
deref
(&self)
duva/src/domains/cluster_actors/hash_ring.rs:200
Method
deref_mut
(&mut self)
duva/src/domains/saves/endec/decoder.rs:387
Method
deserialize
Deserialize `WriteOperation`s from the given bytes.
duva/src/domains/replications/operation.rs:44
Method
detect_and_sort_existing_segments
(path: &Path)
duva/src/adapters/loggers/disk_based.rs:219
Method
determine_role
( replicaof: Option<&PeerIdentifier>, pre_connected_nodes: &[ReplicationState], )
duva/src/config.rs:64
Method
display
(&self)
duva-client/src/cli/editor/hints.rs:32
Method
drop
(&mut self)
duva/tests/common.rs:94
Method
election_votes
(&self)
duva/src/domains/replications/replication.rs:346
Method
encode
(&self, encoder: &mut E)
duva/src/types.rs:52
Method
eq
(&self, _: &Self)
duva/src/types.rs:39
Method
eq
(&self, other: &&str)
duva/src/domains/saves/endec/decoder.rs:398
Method
eq
(&self, other: &Self)
duva/src/domains/peers/peer.rs:99
Method
eq
(&self, _: &Self)
duva/src/domains/peers/connections/connection_types.rs:16
Method
eq
(&self, other: &Self)
duva/src/domains/cluster_actors/hash_ring.rs:232
Function
estimate_serialized_size
(query: &QueryIO)
duva/src/domains/query_io.rs:126
Method
expiry_in_i64
(&self)
duva/src/domains/caches/cache_objects/entry.rs:36
Method
extract_my_repl_id
(contents: &str)
duva/src/domains/replications/state.rs:93
Method
extract_replid
(id_part: &str)
duva/src/domains/replications/state.rs:55
Method
fmt
(&self, f: &mut std::fmt::Formatter<'_>)
duva-client/src/controller.rs:166
Method
fmt
(&self, f: &mut std::fmt::Formatter<'_>)
duva/src/domains/peers/identifier.rs:60
Method
fmt
(&self, f: &mut std::fmt::Formatter<'_>)
duva/src/domains/replications/state.rs:139
Method
fmt
(&self, f: &mut std::fmt::Formatter<'_>)
duva/src/domains/replications/replication.rs:401
Function
follower_accepts_entries_with_empty_log_and_prev_log_index_zero
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:382
Function
follower_cluster_actor_replicate_log
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:89
Function
follower_cluster_actor_replicate_state_only_upto_con_idx
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:183
Function
follower_cluster_actor_sessionless_replicate_state
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:113
Function
follower_rejects_entries_with_empty_log_and_prev_log_index_nonzero
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:398
Function
follower_truncates_log_on_term_mismatch
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:348
Method
from
(value: &ClientAction)
duva-client/src/command.rs:158
Method
from
(value: ErrorKind)
duva/src/adapters/io/tokio_stream.rs:146
Method
from
(value: String)
duva/src/domains/query_io.rs:139
Method
from
(data: &'a [u8])
duva/src/domains/saves/endec/decoder.rs:375
Method
from
(s: &str)
duva/src/domains/caches/cache_objects/value.rs:54
Method
from
(cmd: PeerCommand)
duva/src/domains/peers/command.rs:19
Method
from
(value: T)
duva/src/domains/peers/connections/connection_types.rs:10
Method
from
(value: ReplicationId)
duva/src/domains/replications/state.rs:148
Method
from
(value: String)
duva/src/domains/replications/replication.rs:409
Method
from
(msg: SchedulerMessage)
duva/src/domains/cluster_actors/command.rs:34
Method
from
(value: NonMutatingAction)
duva/src/presentation/clients/request.rs:52
Method
from_file
(path: &str)
duva/src/domains/replications/state.rs:63
Method
from_path
(path: &PathBuf)
duva/src/adapters/loggers/disk_based.rs:95
Method
from_slice
(chunk: &[(&String, &CacheValue)])
duva/src/domains/caches/cache_objects/entry.rs:44
Method
from_str
(s: &str)
duva/src/domains/cluster_actors/command.rs:110
Method
get_pnode_count
(&self)
duva/src/domains/cluster_actors/hash_ring.rs:138
Method
get_vnode_count
(&self)
duva/src/domains/cluster_actors/hash_ring.rs:143
Method
handle_client_stream
( mut self, handler: ClientController, stream_writer_sender: Sender<ServerResponse>,
duva/src/presentation/clients/stream.rs:27
Method
has_expiry
(&self)
duva/src/domains/caches/cache_objects/value.rs:70
Method
heartbeat
( term: u64, leader_commit_idx: Option<u64>, op_logs: Vec<WriteOperation>, )
duva/src/domains/cluster_actors/actor/tests/mod.rs:143
Method
heartbeat_msg
(&self, expected_count: usize)
duva/tests/common.rs:144
Method
highlight_hint
(&self, hint: &'h str)
duva-client/src/cli/editor/hints.rs:240
Method
highlight_prompt
( &'s self, prompt: &'p str, default: bool, )
duva-client/src/cli/editor/hints.rs:228
Method
hint
(&self, line: &str, pos: usize, _ctx: &Context<'_>)
duva-client/src/cli/editor/hints.rs:44
Method
hop_count
(fanout: usize, node_count: usize)
duva/src/domains/cluster_actors/actor.rs:681
Method
id
(&self)
duva/src/domains/replications/state.rs:27
Method
initialize_with_snapshot
Refactiring : this should run before cluster actor runs
duva/src/lib.rs:76
← previous
next →
501–600 of 954, ranked by callers