MCPcopy Create free account

hub / github.com/Migorithm/duva / functions

Functions954 in github.com/Migorithm/duva

⨍ Functions 954◇ Types & classes 154
Methodinto_inner
(self)
duva/src/domains/saves/actor.rs:83
Methodis_empty
(&self)
duva/src/adapters/loggers/memory_based.rs:36
Methodis_votable
(&self, candidate_id: &PeerIdentifier)
duva/src/domains/replications/consensus/election.rs:28
Methodjoin_peer_network_if_absent
( &mut self, cluster_nodes: Vec<ReplicationState>, )
duva/src/domains/cluster_actors/actor.rs:1158
Functionleader_consensus_tracker_not_changed_when_followers_not_exist
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:573
Methodlindex
(&mut self, index: isize)
duva/src/domains/caches/cache_objects/types/quicklist.rs:605
Methodload_from_bytes
(bytes: &[u8])
duva/src/domains/saves/snapshot/snapshot_loader.rs:16
Methodload_from_filepath
Optimization: OS maps the file pages into VM pages and the data is read from the file only when the VM page is accessed. No extra copy is made between
duva/src/domains/saves/snapshot/snapshot_loader.rs:11
Functionlogger_create_entries_from_lowest
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:6
Functionlrange
()
duva/tests/client_ops/test_lrange.rs:24
Methodlset
(&mut self, index: isize, value: String)
duva/src/domains/caches/cache_objects/types/quicklist.rs:629
Functionltrim
()
duva/tests/client_ops/test_ltrim.rs:19
Functionmain
()
duva-client/src/cli/main.rs:21
Functionmain
()
duva/src/main.rs:4
Functionmigration_task_create_helper
(start_hash: u64, end_hash: u64)
duva/src/domains/cluster_actors/hash_ring/tests/mod.rs:10
Methodnew
( client_action: ClientAction, callback: oneshot::Sender<(ClientAction, ServerResponse)>,
duva-client/src/command.rs:59
Methodnew
(editor: T, server_addr: &PeerIdentifier)
duva-client/src/controller.rs:22
Methodnew
(text: &str)
duva-client/src/cli/editor/hints.rs:18
Methodnew
(server_addr: &PeerIdentifier)
duva-client/src/broker/mod.rs:39
Methodnew
(target_id: ReplicationId)
duva-client/src/broker/node_connections.rs:31
Methodnew
(arg: impl Into<Bytes>)
duva/src/types.rs:72
Methodnew
(wal: OperationLogs, writer: File)
duva/src/lib.rs:102
Methodnew
()
duva/src/signals.rs:20
Methodnew
Creates a new mock stream from a vector of byte chunks, which are flattened.
duva/src/adapters/io/tokio_stream.rs:169
Methodnew
(log_index: u64, byte_offset: usize)
duva/src/adapters/loggers/disk_based.rs:47
Methodnew
(append_only: bool)
duva/src/adapters/loggers/op_logs.rs:14
Methodnew
( target: SaveTarget, num_of_shards: usize, repl_id: ReplicationId, current_of
duva/src/domains/saves/actor.rs:19
Methodnew
( header: String, metadata: Metadata, database: Vec<SubDatabase>, checksum: Ve
duva/src/domains/saves/snapshot/mod.rs:14
Methodnew
(con_idx: Arc<AtomicU64>)
duva/src/domains/caches/read_queue.rs:20
Methodnew
(capacity: usize)
duva/src/domains/caches/lru_cache.rs:88
Methodnew
(value: impl Into<TypedValue>)
duva/src/domains/caches/cache_objects/value.rs:16
Methodnew
(key: impl Into<String>, value: impl Into<TypedValue>)
duva/src/domains/caches/cache_objects/entry.rs:14
Methodnew
(fill_factor: FillFactor, compress_depth: usize)
duva/src/domains/caches/cache_objects/types/quicklist.rs:349
Methodnew
(target_repl: ReplicationId, tasks: Vec<MigrationChunk>)
duva/src/domains/peers/command.rs:172
Methodnew
( w: impl Into<WriteConnected>, state: ReplicationState, listener_kill_trigger: Listen
duva/src/domains/peers/peer.rs:25
Methodnew
(host: &str, port: u16)
duva/src/domains/peers/identifier.rs:8
Methodnew
(msg: String)
duva/src/domains/peers/connections/inbound/request.rs:16
Methodnew
(self_port: u16, logger: OperationLogs, state: ReplicationState)
duva/src/domains/replications/replication.rs:31
Methodnew
(replica_count: u8, self_id: PeerIdentifier)
duva/src/domains/replications/consensus/election.rs:11
Methodnew
( callback: Callback<ConsensusResponse>, replica_count: usize, conn_offset: Option<Con
duva/src/domains/replications/consensus/log.rs:24
Methodnew
(offset: u64, conn_id: String)
duva/src/domains/cluster_actors/command.rs:83
Methodnew
(known_peers: Vec<PeerIdentifier>)
duva/src/domains/cluster_actors/actor.rs:86
Methodnew
()
duva/src/domains/cluster_actors/actor/tests/mod.rs:43
Methodnew
(process: Child, port: u16)
duva/tests/common.rs:157
Methodnew_with_cache_value
(key: impl Into<String>, value: CacheValue)
duva/src/domains/caches/cache_objects/entry.rs:18
Methodnum_reqs
(&self)
duva/src/domains/peers/command.rs:210
Methodopen_topology_file
(tpp: String)
duva/src/config.rs:75
Methodparse_node_info
(line: &str)
duva/src/domains/replications/state.rs:31
Methodpoll_next
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
duva/src/domains/cluster_actors/queue.rs:190
Methodpoll_read
( self: std::pin::Pin<&mut Self>, _cx: &mut std::task::Context<'_>, buf: &
duva/src/adapters/io/tokio_stream.rs:176
Methodrange
Retrieve logs that fall between the current 'commit' index and target 'log' index. This is NOT async as it is expected to be infallible and an in-memo
duva/src/adapters/loggers/op_logs.rs:42
Methodrange
(&self, start_exclusive: u64, end_inclusive: u64)
duva/src/adapters/loggers/memory_based.rs:24
Methodread_at
Retrieves the log at a given index.
duva/src/adapters/loggers/op_logs.rs:53
Methodread_at
(&mut self, prev_log_index: u64)
duva/src/adapters/loggers/memory_based.rs:32
Methodread_file_if_valid
(path: &str)
duva/src/domains/replications/state.rs:82
Methodreceive_connection_msgs
(&mut self)
duva/src/adapters/io/tokio_stream.rs:69
Methodreceive_peer_msgs
(&mut self)
duva/src/adapters/io/tokio_stream.rs:61
Methodrecord_vote
(&mut self, voter_id: PeerIdentifier)
duva/src/domains/replications/consensus/election.rs:21
Methodregister_delayed_schedule
( cluster_sender: ClusterActorSender, completion_awaiter: CallbackAwaiter<anyhow::Result<C>>,
duva/src/domains/cluster_actors/actor.rs:612
Methodreject
(log_idx: u64, reason: RejectionReason, curr_term: u64)
duva/src/domains/peers/command.rs:70
Methodreplay
Replays all logged operations from the beginning of the WAL, calling the provided callback `f` for each operation. The callback `f(WriteOperation)` re
duva/src/adapters/loggers/op_logs.rs:48
Methodreplay
(&mut self, f: &mut dyn FnMut(WriteOperation))
duva/src/adapters/loggers/memory_based.rs:17
Methodreplicaof
Forces the current node to become a replica of the given peer.
duva/src/domains/cluster_actors/actor.rs:558
Methodreplicate_log_entries
( &mut self, operations: Vec<WriteOperation>, prev_log_index: u64, prev_log_te
duva/src/domains/replications/replication.rs:294
Functionreplicate_stores_only_latest_session_per_client
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:153
Methodreplid
(&mut self)
duva/src/domains/replications/replication.rs:76
Functionreq_consensus_inserts_consensus_voting
()
duva/src/domains/cluster_actors/actor/tests/replications.rs:416
Methodrequest_id
(&self)
duva/src/presentation/clients/request.rs:311
Methodresponse
(&self)
duva/src/presentation/clients/request.rs:321
Methodrun
(mut self)
duva-client/src/broker/write_stream.rs:17
Methodrun
( mut self, controller_sender: tokio::sync::mpsc::Sender<BrokerMessage>, replication_i
duva-client/src/broker/read_stream.rs:10
Methodrun
(mut self, mut inbox: Receiver<SaveCommand>)
duva/src/domains/saves/service.rs:5
Methodrun
( topology_writer: std::fs::File, heartbeat_interval: u64, replication: Replication,
duva/src/domains/cluster_actors/actor.rs:97
Methodrun
( cluster_handler: ClusterActorSender, is_leader_mode: bool, cluster_heartbeat_interva
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:18
Methodrun
( mut self, mut topology_observer: tokio::sync::broadcast::Receiver<Topology>, )
duva/src/presentation/clients/stream.rs:73
Methodrun_cache_actors
(con_idx: Arc<AtomicU64>)
duva/src/domains/caches/cache_manager.rs:41
Functionrun_route_del
()
duva/tests/client_ops/test_route_del.rs:42
Functionrun_route_exists
()
duva/tests/client_ops/test_route_exists.rs:46
Functionrun_route_keys
()
duva/tests/client_ops/test_route_keys.rs:53
Functionrun_route_mget
()
duva/tests/client_ops/test_route_mget.rs:42
Methodschedule_migration_in_batch
( batch: PendingMigrationTask, handler: ClusterActorSender, )
duva/src/domains/cluster_actors/actor.rs:1270
Methodsend
(&mut self, msg: PeerMessage)
duva/src/adapters/io/tokio_stream.rs:91
Methodsend_append_entries_rpc
( heartbeat_interval: u64, cluster_handler: ClusterActorSender, )
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:51
Methodsend_connection_msg
(&mut self, arg: &str)
duva/src/adapters/io/tokio_stream.rs:102
Methodsend_keys_to_shard
stateless function to send keys
duva/src/domains/caches/cache_manager.rs:58
Functionserialize_with_bincode
(prefix: char, arg: &T)
duva/src/domains/query_io.rs:252
Methodsession_write
( index_num: u64, term: u64, key: &str, value: &str, session_req: Conn
duva/src/domains/cluster_actors/actor/tests/mod.rs:128
Functionset_helper
(index: u64, term: u64)
duva/src/adapters/loggers/disk_based.rs:544
Methodshutdown_gracefully
(&self)
duva/src/domains/cluster_actors/queue.rs:168
Methodstart
(&mut self)
duva/src/domains/peers/service.rs:41
Methodstart_accepting_peer_connections
( peer_bind_addr: String, ca_sender: ClusterActorSender, )
duva/src/lib.rs:183
Methodstart_election_timer
( cluster_handler: ClusterActorSender, )
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:82
Methodstate
(&self)
duva/src/domains/replications/replication.rs:59
Methodtake_last_segment_otherwise_init
( path: &Path, segment_paths: Vec<PathBuf>, )
duva/src/adapters/loggers/disk_based.rs:242
Functiontest_16_bit_integer
()
duva/src/domains/saves/endec/encoder.rs:241
Functiontest_16_bit_integer_decode
()
duva/src/domains/saves/endec/encoder.rs:250
Functiontest_32_bit_integer
()
duva/src/domains/saves/endec/encoder.rs:259
Functiontest_32_bit_integer_decode
()
duva/src/domains/saves/endec/encoder.rs:268
Functiontest_8_bit_integer_decode
()
duva/src/domains/saves/endec/encoder.rs:232
Functiontest_8_bit_integer_encode
()
duva/src/domains/saves/endec/encoder.rs:223
← previousnext →601–700 of 954, ranked by callers