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
↓ 55 callers
Method
len
(&self)
hkv-common/src/types.rs:131
↓ 26 callers
Function
repeated_reads
(key: &[u8], count: usize)
hkv-server/tests/hotness_workloads.rs:335
↓ 25 callers
Method
as_bytes
(&self)
hkv-common/src/types.rs:125
↓ 20 callers
Method
is_empty
(&self)
hkv-common/src/types.rs:137
↓ 19 callers
Method
set
Inserts or replaces a key/value pair and updates LRU ordering. This resets TTL to `None` and triggers eviction when over budget.
hkv-engine/src/memory.rs:622
↓ 18 callers
Function
resp_error
(message: &str)
hkv-server/src/server.rs:427
↓ 14 callers
Function
eq_ignore_ascii_case
(a: &[u8], b: &[u8])
hkv-server/src/server.rs:683
↓ 12 callers
Method
get
Looks up a key, updates LRU, and returns its value if present. Expired entries are removed on access to keep memory usage stable.
hkv-engine/src/memory.rs:590
↓ 12 callers
Function
run_redis_cli
(port: u16, args: &[&str])
hkv-server/tests/redis_cli.rs:29
↓ 10 callers
Method
as_nanos
(&self)
hkv-common/src/types.rs:303
↓ 9 callers
Method
exec_with_retry
(&self, args: &[&[u8]])
hkv-client/src/client.rs:272
↓ 8 callers
Method
expire
Sets a TTL for an existing key. Missing or expired keys return `HkvError::NotFound`.
hkv-engine/src/memory.rs:661
↓ 8 callers
Function
invokeCommand
( command: string, args?: Record<string, unknown> )
hkv-gui/src/lib/api.ts:35
↓ 8 callers
Method
parse
Attempts to parse a single command from the buffer. Returns `Ok(None)` if more data is required.
hkv-server/src/protocol.rs:57
↓ 8 callers
Method
remove_idx
Removes a node by index and returns its byte size. This updates the map, LRU links, and free list.
hkv-engine/src/memory.rs:284
↓ 8 callers
Function
sample_request
()
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:518
↓ 8 callers
Method
write
( command: CommandKind, key: Vec<u8>, value_size: Option<usize>, timestamp: Sy
hkv-server/src/observation.rs:69
↓ 7 callers
Method
cmp
(&self, other: &Self)
hkv-engine/src/memory.rs:106
↓ 7 callers
Function
read_response
Reads one RESP value from the buffered reader.
hkv-client/src/resp.rs:58
↓ 7 callers
Method
record_request_start
Records the start of a request. Call this when a request is accepted to increment totals and in-flight.
hkv-server/src/metrics.rs:100
↓ 7 callers
Method
set
(&self, key: Vec<u8>, value: Vec<u8>)
hkv-server/src/server.rs:751
↓ 7 callers
Method
start
(&self, request: Option<StartServerRequest>)
hkv-gui/src-tauri/src/server_manager.rs:130
↓ 7 callers
Method
start_expirer
Starts a background thread that periodically removes expired entries. The returned handle must be stopped to avoid leaking the thread.
hkv-engine/src/memory.rs:420
↓ 7 callers
Method
stop
Stops the sweeper and waits for the thread to finish. Use this in tests or shutdown hooks to avoid leaking threads.
hkv-engine/src/memory.rs:349
↓ 6 callers
Method
clear
(&mut self, flag: u8)
hkv-common/src/types.rs:372
↓ 6 callers
Function
iso_timestamp
()
hkv-gui/src-tauri/src/benchmark_manager.rs:338
↓ 6 callers
Function
recv_lifecycle
( receiver: &mut tokio::sync::broadcast::Receiver<BenchmarkEventEnvelope>, )
hkv-gui/src-tauri/src/benchmark_manager.rs:497
↓ 6 callers
Function
recv_lifecycle_matching
( receiver: &mut tokio::sync::broadcast::Receiver<BenchmarkEventEnvelope>, event: &str,
hkv-gui/src-tauri/src/benchmark_manager.rs:517
↓ 6 callers
Function
renderTestRouter
(path: string)
hkv-gui/src/test/router.tsx:5
↓ 6 callers
Function
resp_integer
(value: i64)
hkv-server/src/server.rs:435
↓ 6 callers
Function
send_raw
(addr: SocketAddr, request: &[u8])
hkv-server/tests/observation.rs:76
↓ 6 callers
Method
snapshot
Returns a snapshot of all counters and histogram buckets.
hkv-server/src/metrics.rs:119
↓ 6 callers
Method
start
( &self, request: BenchmarkRunRequest, events: Sender<BenchmarkLifecycleEvent>, )
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:223
↓ 6 callers
Method
subscribe_lifecycle
(&self)
hkv-gui/src-tauri/src/benchmark_manager.rs:78
↓ 6 callers
Method
top_keys
(&self, limit: usize)
hkv-server/src/observation/exact.rs:110
↓ 5 callers
Function
assert_stability_capture
(capture: &StabilityCapture, expected: &[(&[u8], u64)])
hkv-server/tests/hotness_workloads.rs:215
↓ 5 callers
Function
contract_schema
()
hkv-gui/src-tauri/src/models.rs:140
↓ 5 callers
Function
evaluate_workload
(events: Vec<ObservationEvent>, limit: usize)
hkv-server/tests/hotness_workloads.rs:211
↓ 5 callers
Function
formatOpsPerSec
(value: number | null | undefined)
hkv-gui/src/lib/format.ts:21
↓ 5 callers
Method
get
(&self, key: &[u8])
hkv-server/src/server.rs:746
↓ 5 callers
Method
is_expired
Returns true when the entry has expired at `now`. Used on access to keep the hot path simple and predictable.
hkv-engine/src/memory.rs:86
↓ 5 callers
Method
next
(&self)
hkv-common/src/types.rs:268
↓ 5 callers
Function
observe_command_result
( sink: Option<&dyn ExperimentObservationSink>, events: Vec<ObservationEvent>, dispatch: F, )
hkv-server/src/server.rs:457
↓ 5 callers
Function
planned_observations
(args: &[Vec<u8>])
hkv-server/src/server.rs:476
↓ 5 callers
Method
purge_expired
Removes expired entries across all shards. This walks only per-shard TTL heap heads plus any stale heap entries.
hkv-engine/src/memory.rs:403
↓ 5 callers
Method
record_observation
(&self, event: ObservationEvent)
hkv-server/src/observation.rs:53
↓ 5 callers
Function
recv_event
(receiver: &mpsc::Receiver<BenchmarkLifecycleEvent>)
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:537
↓ 5 callers
Function
recv_run
(receiver: &mut tokio::sync::broadcast::Receiver<BenchmarkRun>)
hkv-gui/src-tauri/src/benchmark_manager.rs:491
↓ 5 callers
Function
recv_run_matching
( receiver: &mut tokio::sync::broadcast::Receiver<BenchmarkRun>, status: &str, )
hkv-gui/src-tauri/src/benchmark_manager.rs:505
↓ 5 callers
Function
renderRoute
(path: string)
hkv-gui/src/__tests__/app-shell.test.tsx:7
↓ 5 callers
Function
sample_request
()
hkv-gui/src-tauri/src/benchmark_manager.rs:480
↓ 5 callers
Function
serve_with_shutdown
Serves accepted TCP connections until shutdown is triggered. The shutdown signal stops new accepts immediately, then drains active connections for a
hkv-server/src/server.rs:48
↓ 5 callers
Method
shard_for
Returns the shard responsible for a given key.
hkv-engine/src/memory.rs:454
↓ 5 callers
Method
start
(&self, request: BenchmarkRunRequest)
hkv-gui/src-tauri/src/benchmark_manager.rs:82
↓ 5 callers
Method
subscribe
(&self)
hkv-gui/src-tauri/src/benchmark_manager.rs:73
↓ 4 callers
Method
clear
(&self)
hkv-gui/src-tauri/src/info_poller.rs:118
↓ 4 callers
Function
client_with_addr
(addr: String)
hkv-client/tests/client.rs:125
↓ 4 callers
Function
currentInfoSnapshot
()
hkv-gui/src/lib/api.ts:70
↓ 4 callers
Function
dispatch_command
( args: &[Vec<u8>], engine: &impl KVEngine, metrics: &Metrics, observation_sink: Option<&dyn E
hkv-server/src/server.rs:231
↓ 4 callers
Function
finish_tracked_request
( metrics: &Metrics, started_at: Instant, response: &[u8], write_result: std::io::Result<()>,
hkv-server/src/server.rs:576
↓ 4 callers
Function
formatDecimal
(value: number | null | undefined, digits = 1)
hkv-gui/src/lib/format.ts:9
↓ 4 callers
Function
formatLatencyMs
(value: number | null | undefined)
hkv-gui/src/lib/format.ts:29
↓ 4 callers
Function
getRunDetail
(runId: string)
hkv-gui/src/lib/api.ts:54
↓ 4 callers
Method
get_run
(&self, run_id: &str)
hkv-gui/src-tauri/src/run_repository.rs:36
↓ 4 callers
Function
loadRuntimePreferences
()
hkv-gui/src/lib/runtime-preferences.ts:43
↓ 4 callers
Function
miri_aware_ttl
(default: Duration, under_miri: Duration)
hkv-engine/src/memory.rs:749
↓ 4 callers
Function
parse_key_value_number
(line: &str, key: &str)
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:394
↓ 4 callers
Function
parse_usize
(value: Option<String>, fallback: usize)
hkv-engine/src/bin/bench_engine.rs:71
↓ 4 callers
Method
percentile_us
Returns the histogram upper bound that satisfies the requested percentile.
hkv-server/src/metrics.rs:235
↓ 4 callers
Method
persist
(&self, run: &BenchmarkRun)
hkv-gui/src-tauri/src/run_repository.rs:71
↓ 4 callers
Method
record_request_end
Records the end of a request. Call this on completion to decrement in-flight and capture latency.
hkv-server/src/metrics.rs:108
↓ 4 callers
Function
select_runner
( runners: &[Arc<dyn BenchmarkRunner>], runner_type: &str, )
hkv-gui/src-tauri/src/runners/mod.rs:45
↓ 4 callers
Function
startServer
(request?: StartServerRequest)
hkv-gui/src/lib/api.ts:58
↓ 4 callers
Method
stop
(&self)
hkv-gui/src-tauri/src/server_manager.rs:194
↓ 4 callers
Function
temp_storage_dir
(test_name: &str)
hkv-gui/src-tauri/src/run_repository.rs:120
↓ 4 callers
Method
try_wait
(&mut self)
hkv-gui/src-tauri/src/server_manager.rs:73
↓ 4 callers
Function
write_simple
(stream: &mut TcpStream, msg: &str)
hkv-client/tests/client.rs:102
↓ 3 callers
Function
assert_top_keys
(actual: &[ExactHotKey], expected: &[(&[u8], u64, u64, u64)])
hkv-server/tests/hotness_workloads.rs:237
↓ 3 callers
Method
build_command
(&self, request: &BenchmarkRunRequest)
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:99
↓ 3 callers
Function
detailValue
(value: number | null | undefined, suffix: string)
hkv-gui/src/components/runs/RunDetail.tsx:7
↓ 3 callers
Method
event_count
(&self)
hkv-server/tests/hotness_workloads.rs:31
↓ 3 callers
Function
handleChange
(field: keyof RuntimePreferences, value: string)
hkv-gui/src/routes/Settings.tsx:30
↓ 3 callers
Function
lifecycle_envelope
( run_id: &str, event: &str, message: Option<String>, error: Option<String>, )
hkv-gui/src-tauri/src/benchmark_manager.rs:298
↓ 3 callers
Function
listRuns
()
hkv-gui/src/lib/api.ts:50
↓ 3 callers
Method
list_runs
(&self)
hkv-gui/src-tauri/src/state.rs:66
↓ 3 callers
Method
list_runs
(&self)
hkv-gui/src-tauri/src/run_repository.rs:30
↓ 3 callers
Function
loadSnapshot
()
hkv-gui/src/components/layout/workbenchSnapshot.ts:19
↓ 3 callers
Method
load_runs
(&self)
hkv-gui/src-tauri/src/run_repository.rs:41
↓ 3 callers
Method
next_ttl_token
Returns a fresh token for TTL heap scheduling.
hkv-engine/src/memory.rs:459
↓ 3 callers
Function
onBenchmarkEvent
( handler: (payload: BenchmarkEventEnvelope) => void )
hkv-gui/src/lib/api.ts:107
↓ 3 callers
Function
parse_i64
(data: &[u8])
hkv-client/src/resp.rs:134
↓ 3 callers
Function
parse_key_value_u64
(line: &str, key: &str)
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:404
↓ 3 callers
Function
percent_change
(baseline: f64, observed: f64)
hkv-server/tests/observation.rs:263
↓ 3 callers
Function
read_command
(reader: &mut BufReader<TcpStream>)
hkv-client/tests/client.rs:29
↓ 3 callers
Method
record_error
(&self, message: String)
hkv-gui/src-tauri/src/info_poller.rs:132
↓ 3 callers
Function
recv_event_matching
( receiver: &mpsc::Receiver<BenchmarkLifecycleEvent>, predicate: F, )
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:771
↓ 3 callers
Method
release_slot
(&self)
hkv-client/src/pool.rs:115
↓ 3 callers
Function
resp_bulk
(data: &[u8])
hkv-server/src/server.rs:443
↓ 3 callers
Function
resp_simple
(message: &str)
hkv-server/src/server.rs:419
↓ 3 callers
Function
sample_run
(id: &str, status: &str, throughput: f64, p95_latency_ms: f64)
hkv-gui/src-tauri/src/run_repository.rs:130
next →
1–100 of 617, ranked by callers