aboutsummaryrefslogtreecommitdiff
path: root/jsonrpc/README.md
diff options
context:
space:
mode:
authorhozan23 <hozan23@proton.me>2023-11-19 22:19:06 +0300
committerhozan23 <hozan23@proton.me>2023-11-19 22:19:06 +0300
commit4d51e3211740764764a6423f8ead4944e1790341 (patch)
tree01ba1b4d9f27913d563b6df1112d67d697627cdc /jsonrpc/README.md
parent938b29d418a9df2f93ee273a394f34adc99ea25d (diff)
karyons jsonrpc implementation
Diffstat (limited to 'jsonrpc/README.md')
-rw-r--r--jsonrpc/README.md50
1 files changed, 50 insertions, 0 deletions
diff --git a/jsonrpc/README.md b/jsonrpc/README.md
new file mode 100644
index 0000000..82ab2e9
--- /dev/null
+++ b/jsonrpc/README.md
@@ -0,0 +1,50 @@
+# karyons jsonrpc
+
+A fast and lightweight async [JSONRPC2.0](https://www.jsonrpc.org/specification) implementation.
+
+## Example
+
+```rust
+use std::sync::Arc;
+
+use serde_json::Value;
+
+use karyons_jsonrpc::{JsonRPCError, Server, Client, register_service};
+
+struct HelloWorld {}
+
+impl HelloWorld {
+ async fn say_hello(&self, params: Value) -> Result<Value, JsonRPCError> {
+ let msg: String = serde_json::from_value(params)?;
+ Ok(serde_json::json!(format!("Hello {msg}!")))
+ }
+}
+
+//////////////////
+// Server
+//////////////////
+let ex = Arc::new(smol::Executor::new());
+
+// Creates a new server
+let endpoint = "tcp://127.0.0.1:60000".parse().unwrap();
+let server = Server::new_with_endpoint(&endpoint, ex.clone()).await.unwrap();
+
+// Register the HelloWorld service
+register_service!(HelloWorld, say_hello);
+server.attach_service(HelloWorld{});
+
+// Starts the server
+ex.run(server.start());
+
+
+//////////////////
+// Client
+//////////////////
+
+// Creates a new client
+let endpoint = "tcp://127.0.0.1:60000".parse().unwrap();
+let client = Client::new_with_endpoint(&endpoint, None).await.unwrap();
+
+let result: String = client.call("HelloWorld.say_hello", "world".to_string()).await.unwrap();
+
+```