MCPcopy Create free account

hub / github.com/Migorithm/duva / functions

Functions954 in github.com/Migorithm/duva

⨍ Functions 954◇ Types & classes 154
↓ 1 callersMethodentry_count
(&self)
duva/src/domains/caches/cache_objects/types/quicklist.rs:20
↓ 1 callersMethodexcept
(self, target: &ReplicationId)
duva/src/domains/cluster_actors/hash_ring.rs:190
↓ 1 callersMethodexpire_in
(&self)
duva/src/domains/caches/cache_objects/entry.rs:51
↓ 1 callersFunctionextract_action
(action: &str, args: &[&str])
duva/src/presentation/clients/request.rs:63
↓ 1 callersMethodextract_capa
(&self)
duva/src/domains/peers/connections/inbound/request.rs:49
↓ 1 callersFunctionextract_expiry
(expiry: &str)
duva/src/presentation/clients/request.rs:298
↓ 1 callersMethodextract_listening_port
(&mut self)
duva/src/domains/peers/connections/inbound/request.rs:33
↓ 1 callersMethodextract_psync
( &mut self, )
duva/src/domains/peers/connections/inbound/request.rs:71
↓ 1 callersMethodextract_replication_info
(&self)
duva/src/domains/saves/snapshot/mod.rs:26
↓ 1 callersMethodextract_requests
(&mut self)
duva/src/domains/peers/command.rs:205
↓ 1 callersFunctionfilter_keys_in_partition
( keys: &[String], partition_start: u64, partition_end: u64, )
duva/src/domains/cluster_actors/hash_ring.rs:205
↓ 1 callersMethodfinalize_or_requeue
( &mut self, query_io: ServerResponse, mut context: InputContext, )
duva-client/src/command.rs:24
↓ 1 callersMethodflushout_readqueue
(&mut self)
duva/src/domains/caches/actor.rs:334
↓ 1 callersMethodfollower_setup
(&mut self, replid: ReplicationId)
duva/src/domains/cluster_actors/actor.rs:263
↓ 1 callersMethodforget_peer
( &mut self, peer_addr: PeerIdentifier, )
duva/src/domains/cluster_actors/actor.rs:280
↓ 1 callersFunctionget_available_port
Let the OS assign a free port dynamically to reduce port conflicts:
duva/tests/common.rs:79
↓ 1 callersMethodget_default_hint
(&self, line: &str, pos: usize)
duva-client/src/cli/editor/hints.rs:105
↓ 1 callersMethodget_dynamic_hint
( &self, command: &str, args_count: usize, needs_space: bool, )
duva-client/src/cli/editor/hints.rs:71
↓ 1 callersMethodget_filepath
(&self)
duva/src/config.rs:79
↓ 1 callersMethodget_handler
(&self)
duva/src/domains/cluster_actors/actor/heartbeat_scheduler.rs:148
↓ 1 callersMethodget_leader_id
(&self)
duva/src/domains/cluster_actors/actor.rs:797
↓ 1 callersMethodget_repeating_hint_text
(&self, hint: &DynamicHint, args_count: usize)
duva-client/src/cli/editor/hints.rs:97
↓ 1 callersMethodget_replication_ids
(&self)
duva/src/domains/cluster_actors/hash_ring.rs:180
↓ 1 callersMethodget_required_votes
(&self)
duva/src/domains/replications/consensus/election.rs:17
↓ 1 callersMethodget_required_votes
(&self)
duva/src/domains/replications/consensus/log.rs:37
↓ 1 callersMethodget_result
(&mut self)
duva-client/src/command.rs:77
↓ 1 callersMethodget_sorted_roles
(&mut self)
duva/src/domains/cluster_actors/actor.rs:694
↓ 1 callersMethodget_virtual_nodes
(&self)
duva/src/domains/cluster_actors/hash_ring.rs:133
↓ 1 callersMethodgossip
(&mut self, mut hop_count: u8)
duva/src/domains/cluster_actors/actor.rs:843
↓ 1 callersMethodgrant_vote
(&mut self, request_vote: &RequestVote)
duva/src/domains/replications/replication.rs:110
↓ 1 callersMethodhandle_client_stream
! TODO ! If multiple connections(due to client's level connection pool or simply the number of clients) are stormed into follower on leader crash, ! `
duva/src/lib.rs:235
↓ 1 callersMethodhandle_cmd
(&mut self, cmd: SaveCommand)
duva/src/domains/saves/actor.rs:37
↓ 1 callersMethodhandle_mutating
( &self, conn_offset: u64, conn_id: String, entry: LogEntry, )
duva/src/presentation/clients/controller.rs:141
↓ 1 callersMethodhandle_repl_rejection
(&mut self, repl_res: Option<RejectionReason>)
duva/src/domains/cluster_actors/actor.rs:1141
↓ 1 callersMethodhas_majority
(&self)
duva/src/domains/replications/consensus/election.rs:25
↓ 1 callersMethodhas_majority_vote
(&self)
duva/src/domains/replications/replication.rs:166
↓ 1 callersMethodincrease_vote
(&mut self, voter: PeerIdentifier)
duva/src/domains/replications/consensus/log.rs:32
↓ 1 callersFunctioninit_logs
()
duva-client/src/observability.rs:21
↓ 1 callersFunctioninit_logs
()
duva/src/lib.rs:268
↓ 1 callersFunctioninit_observability_with_config
( config: ObservabilityConfig, )
duva-client/src/observability.rs:60
↓ 1 callersMethodinto_mut
(self)
duva/src/domains/caches/lru_cache.rs:313
↓ 1 callersMethodis_candidate
(&self)
duva/src/domains/replications/replication.rs:132
↓ 1 callersMethodis_dead
(&self, now: Instant)
duva/src/domains/peers/peer.rs:160
↓ 1 callersMethodis_eligible_voter
(&self, voter: &PeerIdentifier)
duva/src/domains/replications/consensus/log.rs:42
↓ 1 callersMethodis_empty_log
(&self)
duva/src/domains/replications/replication.rs:66
↓ 1 callersMethodis_follower
(&self, replid: &ReplicationId)
duva/src/domains/peers/peer.rs:70
↓ 1 callersMethodis_granted
(&self)
duva/src/domains/peers/command.rs:74
↓ 1 callersMethodis_log_up_to_date
( &self, candidate_last_log_index: u64, candidate_last_log_term: u64, )
duva/src/domains/replications/replication.rs:136
↓ 1 callersMethodis_processed
(&self, req: &Option<ConnectionOffset>)
duva/src/domains/cluster_actors/actor/client_sessions.rs:16
↓ 1 callersMethodis_string
(&self)
duva/src/domains/caches/cache_objects/value.rs:29
↓ 1 callersMethodis_valid
(&self, current_datetime: &DateTime<Utc>)
duva/src/domains/caches/cache_objects/entry.rs:26
↓ 1 callersMethodis_votable
(&self, candidate_id: &PeerIdentifier)
duva/src/domains/replications/replication.rs:158
↓ 1 callersMethodkey_values
(self)
duva/src/domains/saves/snapshot/mod.rs:22
↓ 1 callersMethodkeys
(&self, pattern: Option<String>, callback: Callback<Vec<String>>)
duva/src/domains/caches/actor.rs:122
↓ 1 callersMethodkeys_with_expiry
(&self)
duva/src/domains/caches/actor.rs:118
↓ 1 callersMethodlast_applied
(&self)
duva/src/domains/replications/replication.rs:50
↓ 1 callersMethodlast_applied_mut
(&mut self)
duva/src/domains/replications/replication.rs:54
↓ 1 callersMethodlast_seen
(&self)
duva/src/domains/peers/peer.rs:166
↓ 1 callersMethodlindex
(&mut self, key: String, index: isize)
duva/src/domains/caches/actor.rs:309
↓ 1 callersMethodllen
(&self)
duva/src/domains/caches/cache_objects/types/quicklist.rs:414
↓ 1 callersMethodlog_level
(&self)
duva-client/src/cli/cli.rs:21
↓ 1 callersMethodlpushx
(&mut self, key: String, values: Vec<String>)
duva/src/domains/caches/actor.rs:210
↓ 1 callersMethodlrange
( &mut self, key: String, start: isize, end: isize, )
duva/src/domains/caches/actor.rs:277
↓ 1 callersMethodlset
(&mut self, key: String, index: isize, val: String)
duva/src/domains/caches/actor.rs:323
↓ 1 callersMethodltrim
(&mut self, key: String, start: isize, end: isize)
duva/src/domains/caches/actor.rs:296
↓ 1 callersMethodmake_handshake
(&mut self, self_port: u16)
duva/src/domains/peers/connections/outbound/stream.rs:23
↓ 1 callersMethodnumeric_delta
(&mut self, key: String, delta: i64)
duva/src/domains/caches/actor.rs:183
↓ 1 callersMethodon_election_timeout
(&mut self, term: u64)
duva/src/domains/replications/replication.rs:376
↓ 1 callersFunctionparse_array
(buffer: Bytes)
duva/src/domains/query_io.rs:199
↓ 1 callersFunctionparse_bulk_string
(buffer: Bytes)
duva/src/domains/query_io.rs:220
↓ 1 callersFunctionparse_custom_type
(buffer: &Bytes)
duva/src/domains/replications/operation.rs:35
↓ 1 callersMethodpeer_bind_addr
(&self)
duva/src/config.rs:87
↓ 1 callersMethodpeerid_by_replid
(&self, target_repl_id: &ReplicationId)
duva/src/domains/cluster_actors/actor.rs:735
↓ 1 callersMethodping
(&self)
duva/src/domains/caches/actor.rs:397
↓ 1 callersMethodpings
(&self)
duva/src/domains/caches/cache_manager.rs:232
↓ 1 callersMethodpop
(&mut self)
duva-client/src/command.rs:20
↓ 1 callersMethodpop_batch
(&mut self, id: &BatchId)
duva/src/domains/peers/command.rs:202
↓ 1 callersFunctionprint_res
(kind: ClientAction, query_io: ServerResponse)
duva-client/src/controller.rs:144
↓ 1 callersMethodprocess_client_message
(&mut self, client_message: ClusterClientRequest)
duva/src/domains/cluster_actors/service.rs:75
↓ 1 callersMethodprocess_connection_message
(&mut self, conn_msg: ConnectionMessage)
duva/src/domains/cluster_actors/service.rs:153
↓ 1 callersMethodprocess_graceful_shutdown
(&mut self)
duva/src/domains/cluster_actors/actor.rs:1465
↓ 1 callersMethodprocess_peer_message
(&mut self, peer_message: PeerMessage, from: PeerIdentifier)
duva/src/domains/cluster_actors/service.rs:133
↓ 1 callersMethodprocess_scheduler_message
! Beware scheduler is a separate task that asychrnously sends message, therefore leadership change in between may not be observed.
duva/src/domains/cluster_actors/service.rs:45
↓ 1 callersMethodrandomized_send
(&self, client_action: ClientAction)
duva-client/src/broker/node_connections.rs:53
↓ 1 callersMethodread_command
(&mut self)
duva/src/domains/peers/service.rs:52
↓ 1 callersMethodreceive_cluster_heartbeat
#[instrument(level = tracing::Level::DEBUG, skip(self, heartbeat), fields(peer_id = %heartbeat.from))]
duva/src/domains/cluster_actors/actor.rs:290
↓ 1 callersMethodreceive_peer_msgs
(&mut self)
duva/src/domains/cluster_actors/actor/tests/mod.rs:50
↓ 1 callersMethodrecord_vote
(&mut self, voter_id: PeerIdentifier)
duva/src/domains/replications/replication.rs:162
↓ 1 callersMethodrecv_ok
(&mut self)
duva/src/domains/peers/connections/inbound/stream.rs:91
↓ 1 callersMethodrecv_ping
(&mut self)
duva/src/domains/peers/connections/inbound/stream.rs:40
↓ 1 callersMethodrecv_psync
(&mut self)
duva/src/domains/peers/connections/inbound/stream.rs:64
↓ 1 callersMethodrecv_replconf_capa
(&mut self)
duva/src/domains/peers/connections/inbound/stream.rs:58
↓ 1 callersMethodrecv_replconf_listening_port
(&mut self)
duva/src/domains/peers/connections/inbound/stream.rs:48
↓ 1 callersMethodregister
(&mut self, switches: Vec<Box<dyn TActorKillSwitch>>)
duva/src/signals.rs:47
↓ 1 callersMethodregister_awaiter_if_pending
(&mut self, callback: Callback<()>)
duva/src/domains/cluster_actors/actor.rs:764
↓ 1 callersMethodremove_from_banlist
(&mut self, peer_id: &PeerIdentifier)
duva/src/domains/cluster_actors/actor.rs:156
↓ 1 callersMethodremove_idle_peers
remove idle peers based on ttl.
duva/src/domains/cluster_actors/actor.rs:821
↓ 1 callersFunctionrender_return
(kind: ClientAction, res: QueryIO)
duva-client/src/controller.rs:30
↓ 1 callersMethodreplicate_state
(&mut self, leader_hb: HeartBeat)
duva/src/domains/cluster_actors/actor.rs:1053
↓ 1 callersMethodreply_with_ok
(&mut self)
duva/src/domains/peers/connections/outbound/stream.rs:72
← previousnext →301–400 of 954, ranked by callers