Rust client for the anna-rs KVS that can run in the WasmEdge Runtime

Last update: Nov 8, 2022

Related tags

Overview

wasmedge-anna-client

wasmedge-anna-client is a Rust client for anna-rs based on Tokio for WasmEdge. It communicates with Anna routing nodes and KVS nodes via vanilla TCP connections instead of Zenoh.

Usage

use std::time::Duration;
use wasmedge_anna_client::{Client, ClientConfig};

let mut client = Client::new(ClientConfig {
    routing_ip: "127.0.0.1".parse().unwrap(),
    routing_port_base: 12340,
    routing_threads: 1,
    timeout: Duration::from_secs(10),
})?;

// put the value
client.put_lww("foo".into(), "bar".into()).await?;

// sleep 1 second
tokio::time::sleep(Duration::from_secs(1)).await;

// get the value
let bytes = client.get_lww("foo".into()).await?;
let value = String::from_utf8(bytes)?;
println!("Successfully GET value of `foo`: {}", value);

Run the example

First, run routing node and KVS node of anna-rs:

$ cd anna-rs
$ cp example-config.yml config.yml
$ ANNA_PUBLIC_IP=127.0.0.1 ANNA_TCP_PORT_BASE=12340 cargo run --bin routing -- config.yml
$ # in another shell
$ ANNA_PUBLIC_IP=127.0.0.1 cargo run --bin kvs -- config.yml

Then, build and run the example app of wasmedge-anna-client:

$ cd example
$ cargo build --target wasm32-wasi
$ /path/to/wasmedge --dir .:. target/wasm32-wasi/debug/example.wasm

Attribution

Many code of this driver is derived from anna-rs.

You might also like...

Awesome books, tutorials, courses, and resources for the Tokio asynchronous runtime ecosystem. ⚡

Awesome Tokio Tokio is an asynchronous runtime for the Rust programming language. It provides the building blocks needed for writing network applicati

59 Oct 27, 2023

Rust lib for a Vec-like structure that can store different types of different sizes contiguous with each other in memory.

hvec In memory of Anna Harren, who coined the term turbofish - which you'll see a lot of if you use this crate. The main purpose of this crate is the

2 Oct 23, 2022

Hypergraph is data structure library to create a directed hypergraph in which a hyperedge can join any number of vertices.

224 Dec 21, 2022

This represents staked SOL, and can be sold for wSOL in the wSOL/stSOL Liquidity Pool

This represents staked SOL, and can be sold for wSOL in the wSOL/stSOL Liquidity Pool (paying a fee to skip the unstaking cool-down period). The value of your stSOL holdings is automatically incremented each epoch when staking rewards are paid.

2 Jun 4, 2022

Cassandra DB native client written in Rust language. Find 1.x versions on https://github.com/AlexPikalov/cdrs/tree/v.1.x Looking for an async version? - Check WIP https://github.com/AlexPikalov/cdrs-async

CDRS CDRS is looking for maintainers CDRS is Apache Cassandra driver written in pure Rust. 💡 Looking for an async version? async-std https://github.c

338 Jan 1, 2023

Comments

Failed to run example

when I run example. I get

wasmedge  ../target/wasm32-wasi/debug/example.wasm
fatal runtime error: assertion failed: thread_info.is_none()
[2022-11-18 12:05:39.929] [error] execution failed: unreachable, Code: 0x89
[2022-11-18 12:05:39.929] [error]     In instruction: unreachable (0x00) , Bytecode offset: 0x000748d4
[2022-11-18 12:05:39.929] [error]     When executing function name: "_start"

my wasmedge version is 0.11.2

$ wasmedge -v
wasmedge version 0.11.2

If you run example is successfully, please tell me your wasmedge version.

opened by L-jasmine 0

add `ReadCommittedTransaction` and `redis_like::Client`
Add ReadCommittedTransaction according to Anna paper, by buffering client writes until transaction.commit()

Add redis_like module, providing Client and Connection structures similar redis-rs
opened by richardchien 0

Rust client for the anna-rs KVS that can run in the WasmEdge Runtime

Related tags

Overview

wasmedge-anna-client

Usage

Run the example

Attribution

You might also like...

Awesome books, tutorials, courses, and resources for the Tokio asynchronous runtime ecosystem. ⚡

Rust lib for a Vec-like structure that can store different types of different sizes contiguous with each other in memory.

Hypergraph is data structure library to create a directed hypergraph in which a hyperedge can join any number of vertices.

This represents staked SOL, and can be sold for wSOL in the wSOL/stSOL Liquidity Pool

Cassandra DB native client written in Rust language. Find 1.x versions on https://github.com/AlexPikalov/cdrs/tree/v.1.x Looking for an async version? - Check WIP https://github.com/AlexPikalov/cdrs-async

CouchDB client-side library for the Rust programming language

A Rust client for the ElasticSearch REST API

An Elasticsearch REST API client for Rust

An etcd client library for Rust.

Comments

Failed to run example

add `ReadCommittedTransaction` and `redis_like::Client`

Owner

WasmEdge Runtime

OBKV Table Client is Rust Library that can be used to access table data from OceanBase storage layer.

The rust client for CeresDB. CeresDB is a high-performance, distributed, schema-less, cloud native time-series database that can handle both time-series and analytics workloads.

rustodrive is a rust client library for communicating with ODrives using the CAN protocol.

This code features a viper-client, which can connect to a viper-server, a custom interface made for Comelit devices.

Affine-client is a client for AFFINE based on Tauri

How to run Rust user programs on Xv6-RISC-V

A tokio-uring backed runtime for Rust

Rust async runtime based on io-uring.

Run SQL queries on CSV files

An Async SDR Runtime for Heterogeneous Architectures