MCPcopy Create free account

hub / github.com/Migorithm/duva / functions

Functions954 in github.com/Migorithm/duva

⨍ Functions 954◇ Types & classes 154
↓ 2 callersMethodformat
(&self, peer_id: &PeerIdentifier)
duva/src/domains/replications/state.rs:105
↓ 2 callersMethodget_node
## Private Helpers for Pooling and Merging
duva/src/domains/caches/cache_objects/types/quicklist.rs:360
↓ 2 callersMethodhandle
(mut self)
duva/src/domains/cluster_actors/service.rs:16
↓ 2 callersMethodhandle_non_mutating
( &self, non_mutating: NonMutatingAction, request_id: u64, )
duva/src/presentation/clients/controller.rs:24
↓ 2 callersMethodin_ban_list
(&self, peer_identifier: &PeerIdentifier)
duva/src/domains/cluster_actors/actor.rs:151
↓ 2 callersMethodinit
()
duva/src/config.rs:28
↓ 2 callersMethodinteger_decode
(&mut self)
duva/src/domains/saves/endec/decoder.rs:124
↓ 2 callersMethodis_compressed
(&self)
duva/src/domains/caches/cache_objects/types/quicklist.rs:199
↓ 2 callersMethodis_full
(&mut self, new_value_size: usize, fill_factor: &FillFactor)
duva/src/domains/caches/cache_objects/types/quicklist.rs:257
↓ 2 callersMethodis_null
(&self)
duva/src/domains/caches/cache_objects/value.rs:26
↓ 2 callersMethodis_self
(&self, bind_addr: &str)
duva/src/domains/replications/state.rs:115
↓ 2 callersMethoditer_follower_append_entries
Creates individualized append entries messages for each follower. This function generates customized heartbeat messages containing only the log entri
duva/src/domains/cluster_actors/actor.rs:881
↓ 2 callersMethodkey_ownership
( &self, keys: impl Iterator<Item = &'a str>, )
duva/src/domains/cluster_actors/hash_ring.rs:147
↓ 2 callersMethodkill
(self)
duva-client/src/broker/node_connections.rs:94
↓ 2 callersMethodlen
(&self)
duva/src/domains/caches/actor.rs:115
↓ 2 callersMethodlist_append_log_entries
( &self, low_watermark: Option<u64>, )
duva/src/domains/replications/replication.rs:245
↓ 2 callersMethodlpush
(&mut self, key: String, values: Vec<String>)
duva/src/domains/caches/actor.rs:195
↓ 2 callersMethodmake_consensus_in_batch
(&mut self, req: ConsensusRequest)
duva/src/domains/cluster_actors/actor.rs:1368
↓ 2 callersMethodnum_batches
(&self)
duva/src/domains/peers/command.rs:214
↓ 2 callersFunctionparse_address
(addr: &str)
duva/src/domains/peers/identifier.rs:37
↓ 2 callersMethodrandom_route
(&self, client_action: ClientAction)
duva-client/src/broker/mod.rs:214
↓ 2 callersMethodread_at_offset
Add method to read operation at specific offset
duva/src/adapters/loggers/disk_based.rs:70
↓ 2 callersMethodread_bytes
Reads a length-prefixed message from the stream. The protocol is: - 4 bytes (u32, big-endian) for the message length. - N bytes for the message body,
duva/src/adapters/io/tokio_stream.rs:23
↓ 2 callersFunctionread_until_crlf_exclusive
(buffer: &Bytes)
duva/src/domains/query_io.rs:240
↓ 2 callersMethodrecv
(self)
duva/src/types.rs:29
↓ 2 callersMethodrecv_handshake
(&mut self)
duva/src/domains/peers/connections/inbound/stream.rs:23
↓ 2 callersMethodremove_connection
( &mut self, leader_id: &ReplicationId, )
duva-client/src/broker/node_connections.rs:35
↓ 2 callersMethodreplay
Replays all existing operations in the op_logs, invoking a callback for each.
duva/src/adapters/loggers/disk_based.rs:417
↓ 2 callersMethodreset_timeout
(&self)
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:113
↓ 2 callersMethodroute_connect_to_server
( &self, connect_to: PeerIdentifier, )
duva/src/domains/cluster_actors/queue.rs:72
↓ 2 callersMethodroute_delete
(&self, keys: Vec<String>)
duva/src/domains/caches/cache_manager.rs:285
↓ 2 callersMethodroute_mget
(&self, keys: Vec<String>)
duva/src/domains/caches/cache_manager.rs:337
↓ 2 callersMethodroute_numeric_delta
(&self, key: String, arg: i64)
duva/src/domains/caches/cache_manager.rs:381
↓ 2 callersMethodrpush
(&mut self, key: String, values: Vec<String>)
duva/src/domains/caches/actor.rs:223
↓ 2 callersMethodrun
(self)
duva/src/lib.rs:127
↓ 2 callersFunctionrun_incr
(with_append_only: bool)
duva/tests/client_ops/test_incr.rs:3
↓ 2 callersFunctionrun_lazy_discovery_of_leader
(with_append_only: bool)
duva/tests/cluster_ops/test_lazy_discovery.rs:3
↓ 2 callersFunctionrun_reconnection_on_reboot
(with_append_only: bool)
duva/tests/cluster_ops/test_reconnection_on_reboot.rs:3
↓ 2 callersFunctionrun_route_exists_keys
( append_only: bool, num_keys: u32, duration: Duration, )
duva/tests/client_ops/test_route_exists.rs:5
↓ 2 callersFunctionrun_route_mget_keys
(append_only: bool, num_keys: u32, duration: Duration)
duva/tests/client_ops/test_route_mget.rs:5
↓ 2 callersMethodsend
(self, value: T)
duva/src/types.rs:20
↓ 2 callersMethodsend_rpc
(&mut self)
duva/src/domains/cluster_actors/actor.rs:408
↓ 2 callersMethodsend_rpc_to_replicas
(&mut self)
duva/src/domains/cluster_actors/actor.rs:859
↓ 2 callersMethodsend_selectively
( &self, keys: Vec<String>, func: fn(String, Callback<T>) -> CacheCommand, )
duva/src/domains/caches/cache_manager.rs:307
↓ 2 callersMethodset_banlist
(self, banlist: Vec<BannedPeer>)
duva/src/domains/peers/command.rs:144
↓ 2 callersMethodset_cluster_nodes
(self, cluster_nodes: Vec<ReplicationState>)
duva/src/domains/peers/command.rs:136
↓ 2 callersMethodset_replid
(&mut self, replid: ReplicationId)
duva/src/domains/replications/replication.rs:80
↓ 2 callersMethodset_role
(&mut self, role: ReplicationRole)
duva/src/domains/peers/peer.rs:74
↓ 2 callersMethodset_role
(&mut self, new_role: ReplicationRole)
duva/src/domains/replications/replication.rs:87
↓ 2 callersMethodsignal_if_peer_discovery_complete
cluster message comes in and connection was tried. At this point, if some task is waiting for the notification, send it. Currently, this flow is meant
duva/src/domains/cluster_actors/actor.rs:1189
↓ 2 callersMethodsnapshot_topology
(&mut self)
duva/src/domains/cluster_actors/actor.rs:751
↓ 2 callersMethodterminate
Attempts to gracefully terminate the process, falling back to force kill if necessary
duva/tests/common.rs:162
↓ 2 callersMethodtruncate_after
(&mut self, log_index: u64)
duva/src/adapters/loggers/disk_based.rs:483
↓ 2 callersMethodtruncate_after
(&mut self, log_index: u64)
duva/src/domains/replications/replication.rs:253
↓ 2 callersMethodtry_compress
Attempts to compress the node.
duva/src/domains/caches/cache_objects/types/quicklist.rs:234
↓ 2 callersMethodupdate_cluster_members
( &mut self, from: &PeerIdentifier, cluster_nodes: &[ReplicationState], )
duva/src/domains/cluster_actors/actor.rs:1449
↓ 2 callersMethodupdate_last_modified
(&mut self)
duva/src/domains/cluster_actors/hash_ring.rs:29
↓ 2 callersMethodwith_expiry
(self, expiry_millis: DateTime<Utc>)
duva/src/domains/caches/cache_objects/entry.rs:22
↓ 2 callersMethodwith_file_name
(mut self, file_name: impl Into<String>)
duva/tests/common.rs:54
↓ 2 callersMethodwrite
(index_num: u64, term: u64, key: &str, value: &str)
duva/src/domains/cluster_actors/actor/tests/mod.rs:120
↓ 2 callersMethodwrite_many
Append one or more `WriteOperation`s to the log.
duva/src/adapters/loggers/op_logs.rs:36
↓ 1 callersMethodaccept_inbound_stream
( &mut self, r: ReadConnected, w: WriteConnected, host_ip: String, )
duva/src/domains/cluster_actors/actor.rs:245
↓ 1 callersMethodactivate_cluster_sync
(&mut self, callback: Callback<()>)
duva/src/domains/cluster_actors/actor.rs:197
↓ 1 callersMethodadd_leader_conns_if_not_found
(&mut self)
duva-client/src/broker/mod.rs:171
↓ 1 callersMethodaddress
(&self)
duva-client/src/cli/cli.rs:17
↓ 1 callersMethodadvance_consensus_on_ack
(&mut self, voter: &PeerIdentifier)
duva/src/domains/cluster_actors/actor.rs:937
↓ 1 callersMethodall_belongs_to
(&self, target: &ReplicationId)
duva/src/domains/cluster_actors/hash_ring.rs:187
↓ 1 callersMethodappend_entries_rpc
(&mut self, heartbeat: HeartBeat)
duva/src/domains/cluster_actors/actor.rs:488
↓ 1 callersMethodapply_banlist
(&mut self, heartbeat: &mut HeartBeat)
duva/src/domains/cluster_actors/actor.rs:302
↓ 1 callersMethodapply_entry
(&self, log_entry: LogEntry, log_index: u64)
duva/src/domains/caches/cache_manager.rs:79
↓ 1 callersMethodapply_snapshot
(self, key_values: Vec<CacheEntry>)
duva/src/domains/caches/cache_manager.rs:256
↓ 1 callersMethodbecome_leader
(&mut self)
duva/src/domains/cluster_actors/actor.rs:1110
↓ 1 callersMethodbytes_decode
Decode a size-encoded value and return the decoded value as bytes.
duva/src/domains/saves/endec/decoder.rs:70
↓ 1 callersMethodcheck_term_outdated
(&mut self, heartbeat: &HeartBeat)
duva/src/domains/cluster_actors/actor.rs:1082
↓ 1 callersFunctionclear_and_make_ascii_art
()
duva-client/src/cli/main.rs:83
↓ 1 callersMethodclear_votes
(&mut self)
duva/src/domains/replications/replication.rs:169
↓ 1 callersMethodclone_con_idx
(&self)
duva/src/domains/replications/replication.rs:232
↓ 1 callersMethodclose_connection
(&mut self, from: &PeerIdentifier)
duva/src/domains/cluster_actors/actor.rs:1474
↓ 1 callersMethodcluster_bind_addr
(&self)
duva/src/domains/peers/identifier.rs:23
↓ 1 callersMethodcreate
()
duva/src/types.rs:15
↓ 1 callersFunctioncreate_unique_file_name
(function_name: &str)
duva/tests/client_ops/test_snapshot_persists_and_recovers_state.rs:42
↓ 1 callersFunctioncreate_user_filter
(log_level: &str)
duva-client/src/observability.rs:43
↓ 1 callersMethoddeconstruct
(self)
duva/src/presentation/clients/authenticate.rs:14
↓ 1 callersFunctiondefault_hints
()
duva-client/src/cli/editor/hints.rs:117
↓ 1 callersMethoddefer_if_stale
( &mut self, read_stat_idx: u64, key: &str, callback: Callback<CacheValue>,
duva/src/domains/caches/read_queue.rs:27
↓ 1 callersMethoddelete
(&mut self, key: String, callback: Callback<bool>)
duva/src/domains/caches/actor.rs:132
↓ 1 callersFunctiondeserialize_by_prefix
(buffer: Bytes, prefix: char)
duva/src/domains/query_io.rs:185
↓ 1 callersMethoddiscover_cluster
(&self)
duva/src/lib.rs:166
↓ 1 callersMethoddiscover_leader_from
(&mut self, follower: PeerIdentifier)
duva-client/src/broker/mod.rs:161
↓ 1 callersMethoddiscover_new_repl_leader
pull-based leader discovery 1. if leader connection is lost, then discover new leader from follower candidates (TopologyChange not happened, LeaderCon
duva-client/src/broker/mod.rs:131
↓ 1 callersMethoddispatch_command_to_server
(&self, action: ClientAction)
duva-client/src/broker/mod.rs:224
↓ 1 callersMethoddrop
(&self)
duva/src/domains/caches/actor.rs:400
↓ 1 callersMethoddrop_cache
(&self)
duva/src/domains/caches/cache_manager.rs:351
↓ 1 callersFunctiondynamic_hints
()
duva-client/src/cli/editor/hints.rs:173
↓ 1 callersFunctionencode_bytes
(size: usize, value: &[u8])
duva/src/domains/saves/endec/encoder.rs:111
↓ 1 callersFunctionencode_checksum
(checksum: &[u8])
duva/src/domains/saves/endec/encoder.rs:69
↓ 1 callersFunctionencode_database_info
(index: usize)
duva/src/domains/saves/endec/encoder.rs:53
↓ 1 callersFunctionencode_database_table_size
( table_size: usize, expires_table_size: usize, )
duva/src/domains/saves/endec/encoder.rs:59
↓ 1 callersFunctionencode_integer
(value: u32)
duva/src/domains/saves/endec/encoder.rs:85
↓ 1 callersMethodencode_meta
(&mut self)
duva/src/domains/saves/actor.rs:31
← previousnext →201–300 of 954, ranked by callers