Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Chiicake/hybrid-kv
/ functions
Functions
617 in github.com/Chiicake/hybrid-kv
⨍
Functions
617
◇
Types & classes
131
↓ 1 callers
Function
contract_schema
()
hkv-gui/src-tauri/src/commands.rs:148
↓ 1 callers
Function
default_address_string
()
hkv-gui/src-tauri/src/server_manager.rs:386
↓ 1 callers
Method
delete
Deletes a key. Returns true when a key was removed. `DEL` returns an integer count. Non-zero maps to true.
hkv-client/src/client.rs:210
↓ 1 callers
Method
evict_if_needed
Evicts entries until within the configured byte budget. Scans shards in round-robin order to avoid concentrating evictions.
hkv-engine/src/memory.rs:541
↓ 1 callers
Method
evict_one_from_shard
Evicts a single LRU entry from a shard. Returns the reclaimed byte size for global accounting.
hkv-engine/src/memory.rs:573
↓ 1 callers
Method
exec
Executes a RESP command and returns the parsed response.
hkv-client/src/pool.rs:147
↓ 1 callers
Method
expire
(&self, key: &[u8], ttl: Duration)
hkv-server/src/server.rs:778
↓ 1 callers
Function
formatBenchmarkStartError
(message: string, targetAddr: string)
hkv-gui/src/routes/Benchmarks.tsx:52
↓ 1 callers
Function
formatBenchmarkStopError
(message: string)
hkv-gui/src/routes/Benchmarks.tsx:66
↓ 1 callers
Function
formatBytes
(value: number | null | undefined)
hkv-gui/src/lib/format.ts:45
↓ 1 callers
Function
formatDurationSeconds
(durationMs: number | null | undefined)
hkv-gui/src/lib/format.ts:37
↓ 1 callers
Function
formatStartServerError
(message: string, address: string)
hkv-gui/src/routes/Server.tsx:24
↓ 1 callers
Function
formatTerminalLineCount
(value: number | null | undefined)
hkv-gui/src/lib/format.ts:66
↓ 1 callers
Method
get
Fetches a value by key. Returns `Ok(None)` when the key is missing. The server response is expected to be a bulk string or null bulk string.
hkv-client/src/client.rs:176
↓ 1 callers
Method
get_run_detail
(&self, run_id: &str)
hkv-gui/src-tauri/src/state.rs:79
↓ 1 callers
Function
handle_connection_with_metrics
Handles a single TCP client connection with shared server metrics.
hkv-server/src/server.rs:171
↓ 1 callers
Function
handle_connection_with_observation
( stream: TcpStream, engine: Arc<E>, metrics: Arc<Metrics>, observation_log: Option<Arc<Shared
hkv-server/src/server.rs:182
↓ 1 callers
Function
handle_del
(args: &[Vec<u8>], engine: &impl KVEngine)
hkv-server/src/server.rs:330
↓ 1 callers
Function
handle_expire
(args: &[Vec<u8>], engine: &impl KVEngine)
hkv-server/src/server.rs:347
↓ 1 callers
Function
handle_get
(args: &[Vec<u8>], engine: &impl KVEngine)
hkv-server/src/server.rs:285
↓ 1 callers
Function
handle_info
(metrics: &Metrics)
hkv-server/src/server.rs:377
↓ 1 callers
Function
handle_ping
(args: &[Vec<u8>])
hkv-server/src/server.rs:277
↓ 1 callers
Function
handle_set
(args: &[Vec<u8>], engine: &impl KVEngine)
hkv-server/src/server.rs:296
↓ 1 callers
Function
handle_ttl
(args: &[Vec<u8>], engine: &impl KVEngine)
hkv-server/src/server.rs:364
↓ 1 callers
Method
id
(&self)
hkv-gui/src-tauri/src/server_manager.rs:69
↓ 1 callers
Method
increment
(&mut self)
hkv-common/src/types.rs:261
↓ 1 callers
Method
info
(&self)
hkv-gui/src-tauri/src/info_poller.rs:32
↓ 1 callers
Method
insert_new
Inserts a new node and returns its slot index. Reuses a free slot if available to reduce allocations under churn.
hkv-engine/src/memory.rs:229
↓ 1 callers
Method
into_client_error
(self)
hkv-client/src/pool.rs:21
↓ 1 callers
Method
is_expired
Returns true if entry has expired relative to current time
hkv-common/src/types.rs:314
↓ 1 callers
Method
is_healthy
(&self)
hkv-client/src/pool.rs:222
↓ 1 callers
Method
is_infinite
(&self)
hkv-common/src/types.rs:309
↓ 1 callers
Method
is_invalidated
(&self)
hkv-common/src/types.rs:360
↓ 1 callers
Function
is_retryable_connect_error
(err: &ClientError)
hkv-client/src/client.rs:296
↓ 1 callers
Function
is_retryable_read_error_kind
(kind: ErrorKind)
hkv-client/src/pool.rs:296
↓ 1 callers
Function
is_retryable_write_error_kind
(kind: ErrorKind)
hkv-client/src/pool.rs:269
↓ 1 callers
Function
iso_timestamp
(time: SystemTime)
hkv-gui/src-tauri/src/server_manager.rs:409
↓ 1 callers
Method
kill
(&mut self)
hkv-gui/src-tauri/src/server_manager.rs:79
↓ 1 callers
Method
kill
(&mut self)
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:42
↓ 1 callers
Function
latencyDeltaLabel
(current: number | null, previous: number | null)
hkv-gui/src/routes/Overview.tsx:19
↓ 1 callers
Function
lifecycle_event_name
(event: &BenchmarkLifecycleEvent)
hkv-gui/src-tauri/src/benchmark_manager.rs:288
↓ 1 callers
Function
loadDetail
()
hkv-gui/src/components/runs/useRunSelection.ts:23
↓ 1 callers
Function
loadMissingDetails
()
hkv-gui/src/components/runs/useRunSelection.ts:45
↓ 1 callers
Function
loadRuns
()
hkv-gui/src/routes/Runs.tsx:19
↓ 1 callers
Function
near_uniform_weak_signal_workload
()
hkv-server/tests/hotness_workloads.rs:312
↓ 1 callers
Function
next_run_id
()
hkv-gui/src-tauri/src/benchmark_manager.rs:330
↓ 1 callers
Method
next_u64
(&mut self)
hkv-engine/src/bin/bench_engine.rs:94
↓ 1 callers
Function
normalize_power_of_two
(value: usize)
hkv-engine/src/bin/bench_engine.rs:75
↓ 1 callers
Function
normalize_runner_type
(runner_type: &str)
hkv-gui/src-tauri/src/runners/mod.rs:63
↓ 1 callers
Function
normalize_shard_count
Normalizes shard counts to a power of two for fast masking. This keeps shard selection branch-free and avoids modulo operations.
hkv-engine/src/memory.rs:738
↓ 1 callers
Function
observation_log_sink
( log: Option<&SharedObservationLog>, )
hkv-server/src/server.rs:551
↓ 1 callers
Function
observed_read
(command: CommandKind, key: &[u8])
hkv-server/tests/hotness_workloads.rs:167
↓ 1 callers
Function
parse_array_len
( reader: &mut R, len: i64, line_buf: &mut Vec<u8>, )
hkv-client/src/resp.rs:105
↓ 1 callers
Function
parse_bulk_len
( reader: &mut R, len: i64, line_buf: &mut Vec<u8>, )
hkv-client/src/resp.rs:83
↓ 1 callers
Function
parse_csv_number
(segment: &str)
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:385
↓ 1 callers
Function
parse_inline_command
(data: &[u8])
hkv-server/src/protocol.rs:144
↓ 1 callers
Method
persist
(&self, _run: &BenchmarkRun)
hkv-gui/src-tauri/src/benchmark_manager.rs:25
↓ 1 callers
Method
poll
(&self, address: &str)
hkv-gui/src-tauri/src/info_poller.rs:75
↓ 1 callers
Method
pop_due_expiration
Pops stale heap heads until a live expired entry is found or the next deadline is still in the future.
hkv-engine/src/memory.rs:260
↓ 1 callers
Method
pop_idle
(&self)
hkv-client/src/pool.rs:101
↓ 1 callers
Method
pop_lru
Removes and returns the least-recently used node size. Used by the eviction logic when over capacity.
hkv-engine/src/memory.rs:300
↓ 1 callers
Function
preferred_state_root
()
hkv-gui/src-tauri/src/state.rs:141
↓ 1 callers
Function
previewBenchmarkBinaryPathExpansion
(values: RuntimePreferences)
hkv-gui/src/routes/Settings.tsx:9
↓ 1 callers
Method
read
(command: CommandKind, key: Vec<u8>, timestamp: SystemTime)
hkv-server/src/observation.rs:59
↓ 1 callers
Function
read_line
(reader: &mut R, buf: &mut Vec<u8>)
hkv-client/src/resp.rs:121
↓ 1 callers
Method
record
(&mut self, event: ObservationEvent)
hkv-server/src/observation/exact.rs:100
↓ 1 callers
Method
record_event
(&mut self)
hkv-server/tests/hotness_workloads.rs:27
↓ 1 callers
Function
redis_cli_available
()
hkv-server/tests/redis_cli.rs:25
↓ 1 callers
Function
refreshRunDetail
(runId: string)
hkv-gui/src/routes/Benchmarks.tsx:95
↓ 1 callers
Function
register
()
hkv-gui/src/components/layout/workbenchSnapshot.ts:32
↓ 1 callers
Function
register
()
hkv-gui/src/routes/Benchmarks.tsx:124
↓ 1 callers
Method
reset
(&mut self)
hkv-server/tests/hotness_workloads.rs:35
↓ 1 callers
Function
resolveBenchmarkBinaryPath
(preferences: RuntimePreferences)
hkv-gui/src/lib/runtime-preferences.ts:71
↓ 1 callers
Function
resp_null
()
hkv-server/src/server.rs:453
↓ 1 callers
Method
return_connection
(&self, conn: Connection)
hkv-client/src/pool.rs:120
↓ 1 callers
Function
run
()
hkv-engine/src/bin/bench_engine.rs:139
↓ 1 callers
Method
runner_type
(&self)
hkv-gui/src-tauri/src/runners/mod.rs:89
↓ 1 callers
Method
seed_run_for_test
(&self, summary: NormalizedRunSummary)
hkv-gui/src-tauri/src/benchmark_manager.rs:158
↓ 1 callers
Function
send_raw
(addr: SocketAddr, request: &[u8])
hkv-server/tests/expanded.rs:39
↓ 1 callers
Function
serve_with_shutdown_and_observation
( listener: tokio::net::TcpListener, engine: Arc<E>, metrics: Arc<Metrics>, observation_log: A
hkv-server/src/server.rs:69
↓ 1 callers
Function
serve_with_shutdown_config
( listener: tokio::net::TcpListener, engine: Arc<E>, metrics: Arc<Metrics>, shutdown: F, c
hkv-server/src/server.rs:100
↓ 1 callers
Function
server_binary_name
()
hkv-gui/src-tauri/src/server_manager.rs:401
↓ 1 callers
Method
set
Sets a value for a key without expiration. Uses RESP2 `SET key value` and expects a simple string response.
hkv-client/src/client.rs:187
↓ 1 callers
Method
set_with_ttl
(&self, key: Vec<u8>, value: Vec<u8>, ttl: Duration)
hkv-server/src/server.rs:759
↓ 1 callers
Method
set_with_ttl
Sets a value and attaches an expiration in seconds. Uses RESP2 `SET key value EX seconds`. TTL seconds are encoded without heap allocations.
hkv-client/src/client.rs:198
↓ 1 callers
Method
shard_index
Hashes a key to its owning shard index. Uses the same hash state as the shard map to keep distribution uniform.
hkv-engine/src/memory.rs:447
↓ 1 callers
Function
shutdown_signal
()
hkv-server/src/main.rs:37
↓ 1 callers
Method
size
Returns entry size in bytes (key + value + metadata)
hkv-common/src/types.rs:499
↓ 1 callers
Method
snapshot
(&self)
hkv-gui/src-tauri/src/info_poller.rs:110
↓ 1 callers
Method
spawn
(&self, spec: &LaunchSpec)
hkv-gui/src-tauri/src/server_manager.rs:41
↓ 1 callers
Method
spawn
( &self, program: &str, args: &[String], )
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:66
↓ 1 callers
Function
spawn_baseline_server
()
hkv-server/tests/observation.rs:50
↓ 1 callers
Method
spawn_event_worker
( &self, run_id: String, receiver: mpsc::Receiver<BenchmarkLifecycleEvent>, )
hkv-gui/src-tauri/src/benchmark_manager.rs:179
↓ 1 callers
Function
spawn_ping_reconnect_server
()
hkv-client/tests/client.rs:142
↓ 1 callers
Function
spawn_retryable_write_failure_server
()
hkv-client/tests/client.rs:160
↓ 1 callers
Function
spawn_test_server
()
hkv-server/tests/redis_cli.rs:58
↓ 1 callers
Method
specs
(&self)
hkv-gui/src-tauri/src/server_manager.rs:440
↓ 1 callers
Method
start_benchmark
(&self, request: BenchmarkRunRequest)
hkv-gui/src-tauri/src/state.rs:89
↓ 1 callers
Method
start_server
( &self, request: Option<StartServerRequest>, )
hkv-gui/src-tauri/src/state.rs:105
↓ 1 callers
Method
stop
(&self, run_id: &str)
hkv-gui/src-tauri/src/benchmark_manager.rs:128
← previous
next →
201–300 of 617, ranked by callers