MCPcopy Create free account
hub / github.com/deventlab/d-engine / client

Method client

d-engine-server/src/api/embedded.rs:596–598  ·  view source on GitHub ↗

Get a reference to the local KV client. The client is available immediately after `start()`, but requests will only succeed after `wait_ready()` completes. # Example ```ignore let engine = EmbeddedEngine::start("./data/my-app").await?; engine.wait_ready(Duration::from_secs(5)).await?; let client = engine.client(); client.put(b"key", b"value").await?; ```

(&self)

Source from the content-addressed store, hash-verified

594 /// client.put(b"key", b"value").await?;
595 /// ```
596 pub fn client(&self) -> Arc<EmbeddedClient> {
597 Arc::clone(&self.inner.client)
598 }
599
600 /// Stop the embedded d-engine gracefully (idempotent).
601 ///

Callers 15

run_benchmark_taskFunction · 0.80
run_local_benchmarkFunction · 0.80
handle_putFunction · 0.80
handle_getFunction · 0.80
bench_watcher_cleanupFunction · 0.80
test_cas_lock_conflictFunction · 0.80
test_cas_release_lockFunction · 0.80

Calls

no outgoing calls