MCPcopy Create free account

hub / github.com/Chiicake/hybrid-kv / functions

Functions617 in github.com/Chiicake/hybrid-kv

↓ 55 callersMethodlen
(&self)
hkv-common/src/types.rs:131
↓ 26 callersFunctionrepeated_reads
(key: &[u8], count: usize)
hkv-server/tests/hotness_workloads.rs:335
↓ 25 callersMethodas_bytes
(&self)
hkv-common/src/types.rs:125
↓ 20 callersMethodis_empty
(&self)
hkv-common/src/types.rs:137
↓ 19 callersMethodset
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 callersFunctionresp_error
(message: &str)
hkv-server/src/server.rs:427
↓ 14 callersFunctioneq_ignore_ascii_case
(a: &[u8], b: &[u8])
hkv-server/src/server.rs:683
↓ 12 callersMethodget
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 callersFunctionrun_redis_cli
(port: u16, args: &[&str])
hkv-server/tests/redis_cli.rs:29
↓ 10 callersMethodas_nanos
(&self)
hkv-common/src/types.rs:303
↓ 9 callersMethodexec_with_retry
(&self, args: &[&[u8]])
hkv-client/src/client.rs:272
↓ 8 callersMethodexpire
Sets a TTL for an existing key. Missing or expired keys return `HkvError::NotFound`.
hkv-engine/src/memory.rs:661
↓ 8 callersFunctioninvokeCommand
( command: string, args?: Record<string, unknown> )
hkv-gui/src/lib/api.ts:35
↓ 8 callersMethodparse
Attempts to parse a single command from the buffer. Returns `Ok(None)` if more data is required.
hkv-server/src/protocol.rs:57
↓ 8 callersMethodremove_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 callersFunctionsample_request
()
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:518
↓ 8 callersMethodwrite
( command: CommandKind, key: Vec<u8>, value_size: Option<usize>, timestamp: Sy
hkv-server/src/observation.rs:69
↓ 7 callersMethodcmp
(&self, other: &Self)
hkv-engine/src/memory.rs:106
↓ 7 callersFunctionread_response
Reads one RESP value from the buffered reader.
hkv-client/src/resp.rs:58
↓ 7 callersMethodrecord_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 callersMethodset
(&self, key: Vec<u8>, value: Vec<u8>)
hkv-server/src/server.rs:751
↓ 7 callersMethodstart
(&self, request: Option<StartServerRequest>)
hkv-gui/src-tauri/src/server_manager.rs:130
↓ 7 callersMethodstart_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 callersMethodstop
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 callersMethodclear
(&mut self, flag: u8)
hkv-common/src/types.rs:372
↓ 6 callersFunctioniso_timestamp
()
hkv-gui/src-tauri/src/benchmark_manager.rs:338
↓ 6 callersFunctionrecv_lifecycle
( receiver: &mut tokio::sync::broadcast::Receiver<BenchmarkEventEnvelope>, )
hkv-gui/src-tauri/src/benchmark_manager.rs:497
↓ 6 callersFunctionrecv_lifecycle_matching
( receiver: &mut tokio::sync::broadcast::Receiver<BenchmarkEventEnvelope>, event: &str,
hkv-gui/src-tauri/src/benchmark_manager.rs:517
↓ 6 callersFunctionrenderTestRouter
(path: string)
hkv-gui/src/test/router.tsx:5
↓ 6 callersFunctionresp_integer
(value: i64)
hkv-server/src/server.rs:435
↓ 6 callersFunctionsend_raw
(addr: SocketAddr, request: &[u8])
hkv-server/tests/observation.rs:76
↓ 6 callersMethodsnapshot
Returns a snapshot of all counters and histogram buckets.
hkv-server/src/metrics.rs:119
↓ 6 callersMethodstart
( &self, request: BenchmarkRunRequest, events: Sender<BenchmarkLifecycleEvent>, )
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:223
↓ 6 callersMethodsubscribe_lifecycle
(&self)
hkv-gui/src-tauri/src/benchmark_manager.rs:78
↓ 6 callersMethodtop_keys
(&self, limit: usize)
hkv-server/src/observation/exact.rs:110
↓ 5 callersFunctionassert_stability_capture
(capture: &StabilityCapture, expected: &[(&[u8], u64)])
hkv-server/tests/hotness_workloads.rs:215
↓ 5 callersFunctioncontract_schema
()
hkv-gui/src-tauri/src/models.rs:140
↓ 5 callersFunctionevaluate_workload
(events: Vec<ObservationEvent>, limit: usize)
hkv-server/tests/hotness_workloads.rs:211
↓ 5 callersFunctionformatOpsPerSec
(value: number | null | undefined)
hkv-gui/src/lib/format.ts:21
↓ 5 callersMethodget
(&self, key: &[u8])
hkv-server/src/server.rs:746
↓ 5 callersMethodis_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 callersMethodnext
(&self)
hkv-common/src/types.rs:268
↓ 5 callersFunctionobserve_command_result
( sink: Option<&dyn ExperimentObservationSink>, events: Vec<ObservationEvent>, dispatch: F, )
hkv-server/src/server.rs:457
↓ 5 callersFunctionplanned_observations
(args: &[Vec<u8>])
hkv-server/src/server.rs:476
↓ 5 callersMethodpurge_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 callersMethodrecord_observation
(&self, event: ObservationEvent)
hkv-server/src/observation.rs:53
↓ 5 callersFunctionrecv_event
(receiver: &mpsc::Receiver<BenchmarkLifecycleEvent>)
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:537
↓ 5 callersFunctionrecv_run
(receiver: &mut tokio::sync::broadcast::Receiver<BenchmarkRun>)
hkv-gui/src-tauri/src/benchmark_manager.rs:491
↓ 5 callersFunctionrecv_run_matching
( receiver: &mut tokio::sync::broadcast::Receiver<BenchmarkRun>, status: &str, )
hkv-gui/src-tauri/src/benchmark_manager.rs:505
↓ 5 callersFunctionrenderRoute
(path: string)
hkv-gui/src/__tests__/app-shell.test.tsx:7
↓ 5 callersFunctionsample_request
()
hkv-gui/src-tauri/src/benchmark_manager.rs:480
↓ 5 callersFunctionserve_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 callersMethodshard_for
Returns the shard responsible for a given key.
hkv-engine/src/memory.rs:454
↓ 5 callersMethodstart
(&self, request: BenchmarkRunRequest)
hkv-gui/src-tauri/src/benchmark_manager.rs:82
↓ 5 callersMethodsubscribe
(&self)
hkv-gui/src-tauri/src/benchmark_manager.rs:73
↓ 4 callersMethodclear
(&self)
hkv-gui/src-tauri/src/info_poller.rs:118
↓ 4 callersFunctionclient_with_addr
(addr: String)
hkv-client/tests/client.rs:125
↓ 4 callersFunctioncurrentInfoSnapshot
()
hkv-gui/src/lib/api.ts:70
↓ 4 callersFunctiondispatch_command
( args: &[Vec<u8>], engine: &impl KVEngine, metrics: &Metrics, observation_sink: Option<&dyn E
hkv-server/src/server.rs:231
↓ 4 callersFunctionfinish_tracked_request
( metrics: &Metrics, started_at: Instant, response: &[u8], write_result: std::io::Result<()>,
hkv-server/src/server.rs:576
↓ 4 callersFunctionformatDecimal
(value: number | null | undefined, digits = 1)
hkv-gui/src/lib/format.ts:9
↓ 4 callersFunctionformatLatencyMs
(value: number | null | undefined)
hkv-gui/src/lib/format.ts:29
↓ 4 callersFunctiongetRunDetail
(runId: string)
hkv-gui/src/lib/api.ts:54
↓ 4 callersMethodget_run
(&self, run_id: &str)
hkv-gui/src-tauri/src/run_repository.rs:36
↓ 4 callersFunctionloadRuntimePreferences
()
hkv-gui/src/lib/runtime-preferences.ts:43
↓ 4 callersFunctionmiri_aware_ttl
(default: Duration, under_miri: Duration)
hkv-engine/src/memory.rs:749
↓ 4 callersFunctionparse_key_value_number
(line: &str, key: &str)
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:394
↓ 4 callersFunctionparse_usize
(value: Option<String>, fallback: usize)
hkv-engine/src/bin/bench_engine.rs:71
↓ 4 callersMethodpercentile_us
Returns the histogram upper bound that satisfies the requested percentile.
hkv-server/src/metrics.rs:235
↓ 4 callersMethodpersist
(&self, run: &BenchmarkRun)
hkv-gui/src-tauri/src/run_repository.rs:71
↓ 4 callersMethodrecord_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 callersFunctionselect_runner
( runners: &[Arc<dyn BenchmarkRunner>], runner_type: &str, )
hkv-gui/src-tauri/src/runners/mod.rs:45
↓ 4 callersFunctionstartServer
(request?: StartServerRequest)
hkv-gui/src/lib/api.ts:58
↓ 4 callersMethodstop
(&self)
hkv-gui/src-tauri/src/server_manager.rs:194
↓ 4 callersFunctiontemp_storage_dir
(test_name: &str)
hkv-gui/src-tauri/src/run_repository.rs:120
↓ 4 callersMethodtry_wait
(&mut self)
hkv-gui/src-tauri/src/server_manager.rs:73
↓ 4 callersFunctionwrite_simple
(stream: &mut TcpStream, msg: &str)
hkv-client/tests/client.rs:102
↓ 3 callersFunctionassert_top_keys
(actual: &[ExactHotKey], expected: &[(&[u8], u64, u64, u64)])
hkv-server/tests/hotness_workloads.rs:237
↓ 3 callersMethodbuild_command
(&self, request: &BenchmarkRunRequest)
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:99
↓ 3 callersFunctiondetailValue
(value: number | null | undefined, suffix: string)
hkv-gui/src/components/runs/RunDetail.tsx:7
↓ 3 callersMethodevent_count
(&self)
hkv-server/tests/hotness_workloads.rs:31
↓ 3 callersFunctionhandleChange
(field: keyof RuntimePreferences, value: string)
hkv-gui/src/routes/Settings.tsx:30
↓ 3 callersFunctionlifecycle_envelope
( run_id: &str, event: &str, message: Option<String>, error: Option<String>, )
hkv-gui/src-tauri/src/benchmark_manager.rs:298
↓ 3 callersFunctionlistRuns
()
hkv-gui/src/lib/api.ts:50
↓ 3 callersMethodlist_runs
(&self)
hkv-gui/src-tauri/src/state.rs:66
↓ 3 callersMethodlist_runs
(&self)
hkv-gui/src-tauri/src/run_repository.rs:30
↓ 3 callersFunctionloadSnapshot
()
hkv-gui/src/components/layout/workbenchSnapshot.ts:19
↓ 3 callersMethodload_runs
(&self)
hkv-gui/src-tauri/src/run_repository.rs:41
↓ 3 callersMethodnext_ttl_token
Returns a fresh token for TTL heap scheduling.
hkv-engine/src/memory.rs:459
↓ 3 callersFunctiononBenchmarkEvent
( handler: (payload: BenchmarkEventEnvelope) => void )
hkv-gui/src/lib/api.ts:107
↓ 3 callersFunctionparse_i64
(data: &[u8])
hkv-client/src/resp.rs:134
↓ 3 callersFunctionparse_key_value_u64
(line: &str, key: &str)
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:404
↓ 3 callersFunctionpercent_change
(baseline: f64, observed: f64)
hkv-server/tests/observation.rs:263
↓ 3 callersFunctionread_command
(reader: &mut BufReader<TcpStream>)
hkv-client/tests/client.rs:29
↓ 3 callersMethodrecord_error
(&self, message: String)
hkv-gui/src-tauri/src/info_poller.rs:132
↓ 3 callersFunctionrecv_event_matching
( receiver: &mpsc::Receiver<BenchmarkLifecycleEvent>, predicate: F, )
hkv-gui/src-tauri/src/runners/redis_benchmark.rs:771
↓ 3 callersMethodrelease_slot
(&self)
hkv-client/src/pool.rs:115
↓ 3 callersFunctionresp_bulk
(data: &[u8])
hkv-server/src/server.rs:443
↓ 3 callersFunctionresp_simple
(message: &str)
hkv-server/src/server.rs:419
↓ 3 callersFunctionsample_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