From c5960a55a99c71a9dd056ea25dd7c1c182ef5570 Mon Sep 17 00:00:00 2001
From: Fabian Stamm <mail@fabianstamm.de>
Date: Sun, 6 Nov 2022 17:38:49 +0100
Subject: [PATCH] Switch from python to rust

---
 .dockerignore                            |    1 +
 .gitignore                               |    3 +-
 .tool-versions                           |    1 -
 Cargo.lock                               | 1023 ++++++++++++++++++++++
 Cargo.toml                               |   17 +
 Dockerfile                               |   33 +-
 README.md                                |    6 -
 __pycache__/csi_pb2.cpython-310.pyc      |  Bin 31009 -> 0 bytes
 __pycache__/csi_pb2_grpc.cpython-310.pyc |  Bin 15872 -> 0 bytes
 bin/build.sh                             |    3 -
 bin/gen-protos.sh                        |    3 -
 bin/push.sh                              |    3 -
 bin/test_part1.sh                        |    2 -
 build.rs                                 |    4 +
 csi-spec                                 |    2 +-
 main.py                                  |  138 ---
 requirements.txt                         |    5 -
 src/main.rs                              |  454 ++++++++++
 18 files changed, 1525 insertions(+), 173 deletions(-)
 create mode 100644 .dockerignore
 delete mode 100644 .tool-versions
 create mode 100644 Cargo.lock
 create mode 100644 Cargo.toml
 delete mode 100644 README.md
 delete mode 100644 __pycache__/csi_pb2.cpython-310.pyc
 delete mode 100644 __pycache__/csi_pb2_grpc.cpython-310.pyc
 delete mode 100755 bin/build.sh
 delete mode 100755 bin/gen-protos.sh
 delete mode 100755 bin/push.sh
 delete mode 100755 bin/test_part1.sh
 create mode 100644 build.rs
 delete mode 100644 main.py
 delete mode 100644 requirements.txt
 create mode 100644 src/main.rs

diff --git a/.dockerignore b/.dockerignore
new file mode 100644
index 0000000..9f97022
--- /dev/null
+++ b/.dockerignore
@@ -0,0 +1 @@
+target/
\ No newline at end of file
diff --git a/.gitignore b/.gitignore
index 00219ef..9f97022 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,2 +1 @@
-csi_pb2.py
-csi_pb2_grpc.py
+target/
\ No newline at end of file
diff --git a/.tool-versions b/.tool-versions
deleted file mode 100644
index 85cfd4b..0000000
--- a/.tool-versions
+++ /dev/null
@@ -1 +0,0 @@
-python 3.10.5
diff --git a/Cargo.lock b/Cargo.lock
new file mode 100644
index 0000000..f295d7f
--- /dev/null
+++ b/Cargo.lock
@@ -0,0 +1,1023 @@
+# This file is automatically @generated by Cargo.
+# It is not intended for manual editing.
+version = 3
+
+[[package]]
+name = "anyhow"
+version = "1.0.66"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "216261ddc8289130e551ddcd5ce8a064710c0d064a4d2895c67151c92b5443f6"
+
+[[package]]
+name = "async-stream"
+version = "0.3.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "dad5c83079eae9969be7fadefe640a1c566901f05ff91ab221de4b6f68d9507e"
+dependencies = [
+ "async-stream-impl",
+ "futures-core",
+]
+
+[[package]]
+name = "async-stream-impl"
+version = "0.3.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "10f203db73a71dfa2fb6dd22763990fa26f3d2625a6da2da900d23b87d26be27"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "async-trait"
+version = "0.1.58"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1e805d94e6b5001b651426cf4cd446b1ab5f319d27bab5c644f61de0a804360c"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "autocfg"
+version = "1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d468802bab17cbc0cc575e9b053f41e72aa36bfa6b7f55e3529ffa43161b97fa"
+
+[[package]]
+name = "axum"
+version = "0.5.17"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "acee9fd5073ab6b045a275b3e709c163dd36c90685219cb21804a147b58dba43"
+dependencies = [
+ "async-trait",
+ "axum-core",
+ "bitflags",
+ "bytes",
+ "futures-util",
+ "http",
+ "http-body",
+ "hyper",
+ "itoa",
+ "matchit",
+ "memchr",
+ "mime",
+ "percent-encoding",
+ "pin-project-lite",
+ "serde",
+ "sync_wrapper",
+ "tokio",
+ "tower",
+ "tower-http",
+ "tower-layer",
+ "tower-service",
+]
+
+[[package]]
+name = "axum-core"
+version = "0.2.9"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "37e5939e02c56fecd5c017c37df4238c0a839fa76b7f97acdd7efb804fd181cc"
+dependencies = [
+ "async-trait",
+ "bytes",
+ "futures-util",
+ "http",
+ "http-body",
+ "mime",
+ "tower-layer",
+ "tower-service",
+]
+
+[[package]]
+name = "base64"
+version = "0.13.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9e1b586273c5702936fe7b7d6896644d8be71e6314cfe09d3167c95f712589e8"
+
+[[package]]
+name = "bitflags"
+version = "1.3.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a"
+
+[[package]]
+name = "bytes"
+version = "1.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ec8a7b6a70fde80372154c65702f00a0f56f3e1c36abbc6c440484be248856db"
+
+[[package]]
+name = "cfg-if"
+version = "1.0.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd"
+
+[[package]]
+name = "either"
+version = "1.8.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "90e5c1c8368803113bf0c9584fc495a58b86dc8a29edbf8fe877d21d9507e797"
+
+[[package]]
+name = "fastrand"
+version = "1.8.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a7a407cfaa3385c4ae6b23e84623d48c2798d06e3e6a1878f7f59f17b3f86499"
+dependencies = [
+ "instant",
+]
+
+[[package]]
+name = "fixedbitset"
+version = "0.4.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0ce7134b9999ecaf8bcd65542e436736ef32ddca1b3e06094cb6ec5755203b80"
+
+[[package]]
+name = "fnv"
+version = "1.0.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3f9eec918d3f24069decb9af1554cad7c880e2da24a9afd88aca000531ab82c1"
+
+[[package]]
+name = "futures-channel"
+version = "0.3.25"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "52ba265a92256105f45b719605a571ffe2d1f0fea3807304b522c1d778f79eed"
+dependencies = [
+ "futures-core",
+]
+
+[[package]]
+name = "futures-core"
+version = "0.3.25"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "04909a7a7e4633ae6c4a9ab280aeb86da1236243a77b694a49eacd659a4bd3ac"
+
+[[package]]
+name = "futures-sink"
+version = "0.3.25"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "39c15cf1a4aa79df40f1bb462fb39676d0ad9e366c2a33b590d7c66f4f81fcf9"
+
+[[package]]
+name = "futures-task"
+version = "0.3.25"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2ffb393ac5d9a6eaa9d3fdf37ae2776656b706e200c8e16b1bdb227f5198e6ea"
+
+[[package]]
+name = "futures-util"
+version = "0.3.25"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "197676987abd2f9cadff84926f410af1c183608d36641465df73ae8211dc65d6"
+dependencies = [
+ "futures-core",
+ "futures-task",
+ "pin-project-lite",
+ "pin-utils",
+]
+
+[[package]]
+name = "getrandom"
+version = "0.2.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c05aeb6a22b8f62540c194aac980f2115af067bfe15a0734d7277a768d396b31"
+dependencies = [
+ "cfg-if",
+ "libc",
+ "wasi",
+]
+
+[[package]]
+name = "gluster-dir-csi"
+version = "0.1.0"
+dependencies = [
+ "hostname",
+ "prost",
+ "prost-types",
+ "tokio",
+ "tokio-stream",
+ "tonic",
+ "tonic-build",
+]
+
+[[package]]
+name = "h2"
+version = "0.3.15"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5f9f29bc9dda355256b2916cf526ab02ce0aeaaaf2bad60d65ef3f12f11dd0f4"
+dependencies = [
+ "bytes",
+ "fnv",
+ "futures-core",
+ "futures-sink",
+ "futures-util",
+ "http",
+ "indexmap",
+ "slab",
+ "tokio",
+ "tokio-util",
+ "tracing",
+]
+
+[[package]]
+name = "hashbrown"
+version = "0.12.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8a9ee70c43aaf417c914396645a0fa852624801b24ebb7ae78fe8272889ac888"
+
+[[package]]
+name = "heck"
+version = "0.4.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2540771e65fc8cb83cd6e8a237f70c319bd5c29f78ed1084ba5d50eeac86f7f9"
+
+[[package]]
+name = "hermit-abi"
+version = "0.1.19"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "62b467343b94ba476dcb2500d242dadbb39557df889310ac77c5d99100aaac33"
+dependencies = [
+ "libc",
+]
+
+[[package]]
+name = "hostname"
+version = "0.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3c731c3e10504cc8ed35cfe2f1db4c9274c3d35fa486e3b31df46f068ef3e867"
+dependencies = [
+ "libc",
+ "match_cfg",
+ "winapi",
+]
+
+[[package]]
+name = "http"
+version = "0.2.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "75f43d41e26995c17e71ee126451dd3941010b0514a81a9d11f3b341debc2399"
+dependencies = [
+ "bytes",
+ "fnv",
+ "itoa",
+]
+
+[[package]]
+name = "http-body"
+version = "0.4.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d5f38f16d184e36f2408a55281cd658ecbd3ca05cce6d6510a176eca393e26d1"
+dependencies = [
+ "bytes",
+ "http",
+ "pin-project-lite",
+]
+
+[[package]]
+name = "http-range-header"
+version = "0.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0bfe8eed0a9285ef776bb792479ea3834e8b94e13d615c2f66d03dd50a435a29"
+
+[[package]]
+name = "httparse"
+version = "1.8.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d897f394bad6a705d5f4104762e116a75639e470d80901eed05a860a95cb1904"
+
+[[package]]
+name = "httpdate"
+version = "1.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c4a1e36c821dbe04574f602848a19f742f4fb3c98d40449f11bcad18d6b17421"
+
+[[package]]
+name = "hyper"
+version = "0.14.22"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "abfba89e19b959ca163c7752ba59d737c1ceea53a5d31a149c805446fc958064"
+dependencies = [
+ "bytes",
+ "futures-channel",
+ "futures-core",
+ "futures-util",
+ "h2",
+ "http",
+ "http-body",
+ "httparse",
+ "httpdate",
+ "itoa",
+ "pin-project-lite",
+ "socket2",
+ "tokio",
+ "tower-service",
+ "tracing",
+ "want",
+]
+
+[[package]]
+name = "hyper-timeout"
+version = "0.4.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bbb958482e8c7be4bc3cf272a766a2b0bf1a6755e7a6ae777f017a31d11b13b1"
+dependencies = [
+ "hyper",
+ "pin-project-lite",
+ "tokio",
+ "tokio-io-timeout",
+]
+
+[[package]]
+name = "indexmap"
+version = "1.9.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "10a35a97730320ffe8e2d410b5d3b69279b98d2c14bdb8b70ea89ecf7888d41e"
+dependencies = [
+ "autocfg",
+ "hashbrown",
+]
+
+[[package]]
+name = "instant"
+version = "0.1.12"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7a5bbe824c507c5da5956355e86a746d82e0e1464f65d862cc5e71da70e94b2c"
+dependencies = [
+ "cfg-if",
+]
+
+[[package]]
+name = "itertools"
+version = "0.10.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b0fd2260e829bddf4cb6ea802289de2f86d6a7a690192fbe91b3f46e0f2c8473"
+dependencies = [
+ "either",
+]
+
+[[package]]
+name = "itoa"
+version = "1.0.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4217ad341ebadf8d8e724e264f13e593e0648f5b3e94b3896a5df283be015ecc"
+
+[[package]]
+name = "lazy_static"
+version = "1.4.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e2abad23fbc42b3700f2f279844dc832adb2b2eb069b2df918f455c4e18cc646"
+
+[[package]]
+name = "libc"
+version = "0.2.137"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fc7fcc620a3bff7cdd7a365be3376c97191aeaccc2a603e600951e452615bf89"
+
+[[package]]
+name = "log"
+version = "0.4.17"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "abb12e687cfb44aa40f41fc3978ef76448f9b6038cad6aef4259d3c095a2382e"
+dependencies = [
+ "cfg-if",
+]
+
+[[package]]
+name = "match_cfg"
+version = "0.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ffbee8634e0d45d258acb448e7eaab3fce7a0a467395d4d9f228e3c1f01fb2e4"
+
+[[package]]
+name = "matchit"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "73cbba799671b762df5a175adf59ce145165747bb891505c43d09aefbbf38beb"
+
+[[package]]
+name = "memchr"
+version = "2.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2dffe52ecf27772e601905b7522cb4ef790d2cc203488bbd0e2fe85fcb74566d"
+
+[[package]]
+name = "mime"
+version = "0.3.16"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2a60c7ce501c71e03a9c9c0d35b861413ae925bd979cc7a4e30d060069aaac8d"
+
+[[package]]
+name = "mio"
+version = "0.8.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e5d732bc30207a6423068df043e3d02e0735b155ad7ce1a6f76fe2baa5b158de"
+dependencies = [
+ "libc",
+ "log",
+ "wasi",
+ "windows-sys",
+]
+
+[[package]]
+name = "multimap"
+version = "0.8.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e5ce46fe64a9d73be07dcbe690a38ce1b293be448fd8ce1e6c1b8062c9f72c6a"
+
+[[package]]
+name = "num_cpus"
+version = "1.14.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f6058e64324c71e02bc2b150e4f3bc8286db6c83092132ffa3f6b1eab0f9def5"
+dependencies = [
+ "hermit-abi",
+ "libc",
+]
+
+[[package]]
+name = "once_cell"
+version = "1.16.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "86f0b0d4bf799edbc74508c1e8bf170ff5f41238e5f8225603ca7caaae2b7860"
+
+[[package]]
+name = "percent-encoding"
+version = "2.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "478c572c3d73181ff3c2539045f6eb99e5491218eae919370993b890cdbdd98e"
+
+[[package]]
+name = "petgraph"
+version = "0.6.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e6d5014253a1331579ce62aa67443b4a658c5e7dd03d4bc6d302b94474888143"
+dependencies = [
+ "fixedbitset",
+ "indexmap",
+]
+
+[[package]]
+name = "pin-project"
+version = "1.0.12"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ad29a609b6bcd67fee905812e544992d216af9d755757c05ed2d0e15a74c6ecc"
+dependencies = [
+ "pin-project-internal",
+]
+
+[[package]]
+name = "pin-project-internal"
+version = "1.0.12"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "069bdb1e05adc7a8990dce9cc75370895fbe4e3d58b9b73bf1aee56359344a55"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "pin-project-lite"
+version = "0.2.9"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e0a7ae3ac2f1173085d398531c705756c94a4c56843785df85a60c1a0afac116"
+
+[[package]]
+name = "pin-utils"
+version = "0.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8b870d8c151b6f2fb93e84a13146138f05d02ed11c7e7c54f8826aaaf7c9f184"
+
+[[package]]
+name = "ppv-lite86"
+version = "0.2.17"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5b40af805b3121feab8a3c29f04d8ad262fa8e0561883e7653e024ae4479e6de"
+
+[[package]]
+name = "prettyplease"
+version = "0.1.21"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c142c0e46b57171fe0c528bee8c5b7569e80f0c17e377cd0e30ea57dbc11bb51"
+dependencies = [
+ "proc-macro2",
+ "syn",
+]
+
+[[package]]
+name = "proc-macro2"
+version = "1.0.47"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5ea3d908b0e36316caf9e9e2c4625cdde190a7e6f440d794667ed17a1855e725"
+dependencies = [
+ "unicode-ident",
+]
+
+[[package]]
+name = "prost"
+version = "0.11.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a0841812012b2d4a6145fae9a6af1534873c32aa67fff26bd09f8fa42c83f95a"
+dependencies = [
+ "bytes",
+ "prost-derive",
+]
+
+[[package]]
+name = "prost-build"
+version = "0.11.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1d8b442418ea0822409d9e7d047cbf1e7e9e1760b172bf9982cf29d517c93511"
+dependencies = [
+ "bytes",
+ "heck",
+ "itertools",
+ "lazy_static",
+ "log",
+ "multimap",
+ "petgraph",
+ "prettyplease",
+ "prost",
+ "prost-types",
+ "regex",
+ "syn",
+ "tempfile",
+ "which",
+]
+
+[[package]]
+name = "prost-derive"
+version = "0.11.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "164ae68b6587001ca506d3bf7f1000bfa248d0e1217b618108fba4ec1d0cc306"
+dependencies = [
+ "anyhow",
+ "itertools",
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "prost-types"
+version = "0.11.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "747761bc3dc48f9a34553bf65605cf6cb6288ba219f3450b4275dbd81539551a"
+dependencies = [
+ "bytes",
+ "prost",
+]
+
+[[package]]
+name = "quote"
+version = "1.0.21"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bbe448f377a7d6961e30f5955f9b8d106c3f5e449d493ee1b125c1d43c2b5179"
+dependencies = [
+ "proc-macro2",
+]
+
+[[package]]
+name = "rand"
+version = "0.8.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "34af8d1a0e25924bc5b7c43c079c942339d8f0a8b57c39049bef581b46327404"
+dependencies = [
+ "libc",
+ "rand_chacha",
+ "rand_core",
+]
+
+[[package]]
+name = "rand_chacha"
+version = "0.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e6c10a63a0fa32252be49d21e7709d4d4baf8d231c2dbce1eaa8141b9b127d88"
+dependencies = [
+ "ppv-lite86",
+ "rand_core",
+]
+
+[[package]]
+name = "rand_core"
+version = "0.6.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ec0be4795e2f6a28069bec0b5ff3e2ac9bafc99e6a9a7dc3547996c5c816922c"
+dependencies = [
+ "getrandom",
+]
+
+[[package]]
+name = "redox_syscall"
+version = "0.2.16"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fb5a58c1855b4b6819d59012155603f0b22ad30cad752600aadfcb695265519a"
+dependencies = [
+ "bitflags",
+]
+
+[[package]]
+name = "regex"
+version = "1.7.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e076559ef8e241f2ae3479e36f97bd5741c0330689e217ad51ce2c76808b868a"
+dependencies = [
+ "regex-syntax",
+]
+
+[[package]]
+name = "regex-syntax"
+version = "0.6.28"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "456c603be3e8d448b072f410900c09faf164fbce2d480456f50eea6e25f9c848"
+
+[[package]]
+name = "remove_dir_all"
+version = "0.5.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3acd125665422973a33ac9d3dd2df85edad0f4ae9b00dafb1a05e43a9f5ef8e7"
+dependencies = [
+ "winapi",
+]
+
+[[package]]
+name = "serde"
+version = "1.0.147"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d193d69bae983fc11a79df82342761dfbf28a99fc8d203dca4c3c1b590948965"
+
+[[package]]
+name = "slab"
+version = "0.4.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4614a76b2a8be0058caa9dbbaf66d988527d86d003c11a94fbd335d7661edcef"
+dependencies = [
+ "autocfg",
+]
+
+[[package]]
+name = "socket2"
+version = "0.4.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "02e2d2db9033d13a1567121ddd7a095ee144db4e1ca1b1bda3419bc0da294ebd"
+dependencies = [
+ "libc",
+ "winapi",
+]
+
+[[package]]
+name = "syn"
+version = "1.0.103"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a864042229133ada95abf3b54fdc62ef5ccabe9515b64717bcb9a1919e59445d"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "unicode-ident",
+]
+
+[[package]]
+name = "sync_wrapper"
+version = "0.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "20518fe4a4c9acf048008599e464deb21beeae3d3578418951a189c235a7a9a8"
+
+[[package]]
+name = "tempfile"
+version = "3.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5cdb1ef4eaeeaddc8fbd371e5017057064af0911902ef36b39801f67cc6d79e4"
+dependencies = [
+ "cfg-if",
+ "fastrand",
+ "libc",
+ "redox_syscall",
+ "remove_dir_all",
+ "winapi",
+]
+
+[[package]]
+name = "tokio"
+version = "1.21.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a9e03c497dc955702ba729190dc4aac6f2a0ce97f913e5b1b5912fc5039d9099"
+dependencies = [
+ "autocfg",
+ "bytes",
+ "libc",
+ "memchr",
+ "mio",
+ "num_cpus",
+ "pin-project-lite",
+ "socket2",
+ "tokio-macros",
+ "winapi",
+]
+
+[[package]]
+name = "tokio-io-timeout"
+version = "1.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "30b74022ada614a1b4834de765f9bb43877f910cc8ce4be40e89042c9223a8bf"
+dependencies = [
+ "pin-project-lite",
+ "tokio",
+]
+
+[[package]]
+name = "tokio-macros"
+version = "1.8.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9724f9a975fb987ef7a3cd9be0350edcbe130698af5b8f7a631e23d42d052484"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "tokio-stream"
+version = "0.1.11"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d660770404473ccd7bc9f8b28494a811bc18542b915c0855c51e8f419d5223ce"
+dependencies = [
+ "futures-core",
+ "pin-project-lite",
+ "tokio",
+]
+
+[[package]]
+name = "tokio-util"
+version = "0.7.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0bb2e075f03b3d66d8d8785356224ba688d2906a371015e225beeb65ca92c740"
+dependencies = [
+ "bytes",
+ "futures-core",
+ "futures-sink",
+ "pin-project-lite",
+ "tokio",
+ "tracing",
+]
+
+[[package]]
+name = "tonic"
+version = "0.8.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "55b9af819e54b8f33d453655bef9b9acc171568fb49523078d0cc4e7484200ec"
+dependencies = [
+ "async-stream",
+ "async-trait",
+ "axum",
+ "base64",
+ "bytes",
+ "futures-core",
+ "futures-util",
+ "h2",
+ "http",
+ "http-body",
+ "hyper",
+ "hyper-timeout",
+ "percent-encoding",
+ "pin-project",
+ "prost",
+ "prost-derive",
+ "tokio",
+ "tokio-stream",
+ "tokio-util",
+ "tower",
+ "tower-layer",
+ "tower-service",
+ "tracing",
+ "tracing-futures",
+]
+
+[[package]]
+name = "tonic-build"
+version = "0.8.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "48c6fd7c2581e36d63388a9e04c350c21beb7a8b059580b2e93993c526899ddc"
+dependencies = [
+ "prettyplease",
+ "proc-macro2",
+ "prost-build",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "tower"
+version = "0.4.13"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b8fa9be0de6cf49e536ce1851f987bd21a43b771b09473c3549a6c853db37c1c"
+dependencies = [
+ "futures-core",
+ "futures-util",
+ "indexmap",
+ "pin-project",
+ "pin-project-lite",
+ "rand",
+ "slab",
+ "tokio",
+ "tokio-util",
+ "tower-layer",
+ "tower-service",
+ "tracing",
+]
+
+[[package]]
+name = "tower-http"
+version = "0.3.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3c530c8675c1dbf98facee631536fa116b5fb6382d7dd6dc1b118d970eafe3ba"
+dependencies = [
+ "bitflags",
+ "bytes",
+ "futures-core",
+ "futures-util",
+ "http",
+ "http-body",
+ "http-range-header",
+ "pin-project-lite",
+ "tower",
+ "tower-layer",
+ "tower-service",
+]
+
+[[package]]
+name = "tower-layer"
+version = "0.3.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c20c8dbed6283a09604c3e69b4b7eeb54e298b8a600d4d5ecb5ad39de609f1d0"
+
+[[package]]
+name = "tower-service"
+version = "0.3.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b6bc1c9ce2b5135ac7f93c72918fc37feb872bdc6a5533a8b85eb4b86bfdae52"
+
+[[package]]
+name = "tracing"
+version = "0.1.37"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8ce8c33a8d48bd45d624a6e523445fd21ec13d3653cd51f681abf67418f54eb8"
+dependencies = [
+ "cfg-if",
+ "log",
+ "pin-project-lite",
+ "tracing-attributes",
+ "tracing-core",
+]
+
+[[package]]
+name = "tracing-attributes"
+version = "0.1.23"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4017f8f45139870ca7e672686113917c71c7a6e02d4924eda67186083c03081a"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "tracing-core"
+version = "0.1.30"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "24eb03ba0eab1fd845050058ce5e616558e8f8d8fca633e6b163fe25c797213a"
+dependencies = [
+ "once_cell",
+]
+
+[[package]]
+name = "tracing-futures"
+version = "0.2.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "97d095ae15e245a057c8e8451bab9b3ee1e1f68e9ba2b4fbc18d0ac5237835f2"
+dependencies = [
+ "pin-project",
+ "tracing",
+]
+
+[[package]]
+name = "try-lock"
+version = "0.2.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "59547bce71d9c38b83d9c0e92b6066c4253371f15005def0c30d9657f50c7642"
+
+[[package]]
+name = "unicode-ident"
+version = "1.0.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6ceab39d59e4c9499d4e5a8ee0e2735b891bb7308ac83dfb4e80cad195c9f6f3"
+
+[[package]]
+name = "want"
+version = "0.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1ce8a968cb1cd110d136ff8b819a556d6fb6d919363c61534f6860c7eb172ba0"
+dependencies = [
+ "log",
+ "try-lock",
+]
+
+[[package]]
+name = "wasi"
+version = "0.11.0+wasi-snapshot-preview1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9c8d87e72b64a3b4db28d11ce29237c246188f4f51057d65a7eab63b7987e423"
+
+[[package]]
+name = "which"
+version = "4.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1c831fbbee9e129a8cf93e7747a82da9d95ba8e16621cae60ec2cdc849bacb7b"
+dependencies = [
+ "either",
+ "libc",
+ "once_cell",
+]
+
+[[package]]
+name = "winapi"
+version = "0.3.9"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5c839a674fcd7a98952e593242ea400abe93992746761e38641405d28b00f419"
+dependencies = [
+ "winapi-i686-pc-windows-gnu",
+ "winapi-x86_64-pc-windows-gnu",
+]
+
+[[package]]
+name = "winapi-i686-pc-windows-gnu"
+version = "0.4.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ac3b87c63620426dd9b991e5ce0329eff545bccbbb34f3be09ff6fb6ab51b7b6"
+
+[[package]]
+name = "winapi-x86_64-pc-windows-gnu"
+version = "0.4.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f"
+
+[[package]]
+name = "windows-sys"
+version = "0.42.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5a3e1820f08b8513f676f7ab6c1f99ff312fb97b553d30ff4dd86f9f15728aa7"
+dependencies = [
+ "windows_aarch64_gnullvm",
+ "windows_aarch64_msvc",
+ "windows_i686_gnu",
+ "windows_i686_msvc",
+ "windows_x86_64_gnu",
+ "windows_x86_64_gnullvm",
+ "windows_x86_64_msvc",
+]
+
+[[package]]
+name = "windows_aarch64_gnullvm"
+version = "0.42.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "41d2aa71f6f0cbe00ae5167d90ef3cfe66527d6f613ca78ac8024c3ccab9a19e"
+
+[[package]]
+name = "windows_aarch64_msvc"
+version = "0.42.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "dd0f252f5a35cac83d6311b2e795981f5ee6e67eb1f9a7f64eb4500fbc4dcdb4"
+
+[[package]]
+name = "windows_i686_gnu"
+version = "0.42.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fbeae19f6716841636c28d695375df17562ca208b2b7d0dc47635a50ae6c5de7"
+
+[[package]]
+name = "windows_i686_msvc"
+version = "0.42.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "84c12f65daa39dd2babe6e442988fc329d6243fdce47d7d2d155b8d874862246"
+
+[[package]]
+name = "windows_x86_64_gnu"
+version = "0.42.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bf7b1b21b5362cbc318f686150e5bcea75ecedc74dd157d874d754a2ca44b0ed"
+
+[[package]]
+name = "windows_x86_64_gnullvm"
+version = "0.42.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "09d525d2ba30eeb3297665bd434a54297e4170c7f1a44cad4ef58095b4cd2028"
+
+[[package]]
+name = "windows_x86_64_msvc"
+version = "0.42.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f40009d85759725a34da6d89a94e63d7bdc50a862acf0dbc7c8e488f1edcb6f5"
diff --git a/Cargo.toml b/Cargo.toml
new file mode 100644
index 0000000..55d67fc
--- /dev/null
+++ b/Cargo.toml
@@ -0,0 +1,17 @@
+[package]
+name = "gluster-dir-csi"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+tonic = "0.8"
+prost = "0.11"
+tokio = { version = "1.0", features = ["macros", "rt-multi-thread"] }
+tokio-stream = { version = "0.1", features = ["net"] }
+hostname = "0.3.1"
+prost-types = "0.11.2"
+
+[build-dependencies]
+tonic-build = "0.8"
\ No newline at end of file
diff --git a/Dockerfile b/Dockerfile
index d653c02..fcf091b 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -1,12 +1,27 @@
-FROM python:3.10-slim-bullseye
+FROM docker.io/rust:1.65.0-slim-bullseye as builder
 
 RUN apt-get update -yq && \
-    apt-get install -y --no-install-recommends glusterfs-client
+   apt install -y --no-install-recommends \
+   build-essential \
+   libssl-dev \
+   pkg-config \
+   protobuf-compiler \
+   libprotobuf-dev
+
+
+WORKDIR /src
+COPY . .
+
+RUN cargo build --release
+
+FROM docker.io/debian:bullseye-slim
+
+RUN apt-get update -yq && \
+   apt-get install -y --no-install-recommends glusterfs-client htop
+
+COPY --from=builder /src/target/release/gluster-dir-csi /usr/local/bin/gluster-dir-csi
+
+ENTRYPOINT ["/usr/local/bin/gluster-dir-csi"]
+
+
 
-COPY requirements.txt /
-RUN pip install --upgrade pip
-RUN pip install -r /requirements.txt
-RUN pip3 install -r /requirements.txt
-COPY *.py /
-RUN mkdir /csi
-CMD python3 -u /main.py
diff --git a/README.md b/README.md
deleted file mode 100644
index d98a68a..0000000
--- a/README.md
+++ /dev/null
@@ -1,6 +0,0 @@
-# Intro
-
-This is a super alpha implementation that supports the CSI spec for directories on a gluster volume.
-Each top level directory is treated as a volume.
-
-Currently tested on hashicorp nomad.
diff --git a/__pycache__/csi_pb2.cpython-310.pyc b/__pycache__/csi_pb2.cpython-310.pyc
deleted file mode 100644
index e38a390561de09190b44288a07da7247f4d8a0bc..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 31009
zcmeHw33wdUm2OL|wIs`O%Zn`U?R}GNdBGTCtfg%WYqJ)E3rt&5UE3{7YSAqj+YkbT
zY>;717$#v7m^fr5Bm|N`U?ybW2q6hsI{QXKGTA0WXOej@^Zs-0(pBBnlI?ll`@Z+S
zhd!VB>)dnBJ$J2pPu*(b)23Mg{P!d4I|HZs3Iac)8~1<JxY><=$+yoB1e|~!a0;Bl
z;ewGuJ6J$C2wY?rGcE!yu}c{j1DDz5j7xwmyP_Z<DjuwSC}2;6UMYB0_H<4!1Fp7b
zFfIoU*)@<YCfNsPI@Uu4_AIBuo-Jk#&2cK{2JBkg&E>mkxT|xj?0I}Q9e4AQwt(-d
zakmh6i}-E^?iS;23Ezcq7slOEzN^9AGN9$oOrRBvW&y1fD~DD&vw>DKZw}BJMzug|
z8O;S+C)Po(4ro22c|i4?Iv;2QqXj@487&0bBsM`~5l{o8#Xy@mbqUZGu?4ANpskFS
z0&U~eWk44(S`M^bY=_(mpo<x;1lqx970@Ltw;E_CqcuR6ic6uf7HAjq)&X6{Xg$zw
zu^XxNK#k1X0MsO!z$5>fnYR(Bh0!LUh={1vJ&efmUQTTQ+9&oQbu&;a^R@t8E-qIZ
z`<b^Dyf#MLfZ9bnQprjOBdVcJM&v;k%UuL?KpcSFcA#$2tu%TVkw!1eT@2L6Xa~?i
zaS(Es0A0aoC(xCgdMVH$M!SG)VJo?-n0Fa?SBtB`Bg==Gw;SjhMvXvGMomCR7&Qa+
zi+*Ud01YrN0yHQF!J~3GjL4qg)IC5)8SMo+#%LeVadBK}#F*C#-Vme9fli1MDs`B7
z`@tI#Bj8clMw!<J6c=$NH^#hn@UCUl0hAC4q*5Ct8IgbEjHneRSgsT3B%>~%>lhsX
zI>o3P=(ISktejy)R<376R&HRq9-vn->IJ%yQ6JE&865<=iP056H#52t=oUtYfL_DM
z2D+8eRY0$0bT!cH#OvSz)%fd~cNpjmjIIHCBcmwLZQ?dn8@Ds>2zYN2>xcf%=?A()
z)GKtSxCCebyt~AJ;@vH70U8AF9`Sm`yH}Jy_-1FOC>?ss(E_o;aUAhL;X^_DJ~8dV
zzZdsCRDhX`BxWfI!m|}#t)<0Epra22p?5#)-OqYt;r^k2FgE5Wy)|0Tek)7A)kxGT
ziM2-JZ7lINBQe+IN1ej!wKRJ=PjTxFcOB5N2a4d`18nU9<J|*8|LDSRH@VDLHa2J*
z_B&Yf9Y$h-lGtb@9%P9Jjl@DFK{d8W;RY?uo-S70&4#-P=s0`&5L<i5c=yoIKe_Nb
zO)g7Zxr7zoYV1+oOBHvU;cfwnaV}>$m$Sz5*`as2@WUpTWy;1y+J^mZ)_k{-Snl#;
zg~AtWX)f(b#ogiIu2S4f40k)w&;!M2t@m&q?=c>|XXw2y{5}_czwu+WvbR&)vp>LA
zK42u)C<&^YwF>Xj(&AE}6Wo&@VZBF8E{_a-(AZd~^e)qS_M<HQsF7Ij%B5c6MlCIN
z0}XR7A7Z@^nOr_J^kHLTgUg2QE6v766VM3Tc#Lg4W^6n*l<6NEm5mmyXMcpHKVov(
z<de%DEzK>bYiY0HMu0}S2R+W#9yfVEuJWd_|G2Bh8eF+-R=CyJ+XocqvOK}|o-p>F
z82YI3bc@S|u8;l3#^pe=K0d}aK4xru%vB#-m5ny7XMdcfKW=i_=E_BvyhBTKedy8L
z>EUXRx(v4+XpDRElbpws#-k@y%}^~p=^EKjx;(we<;Qjx);{%^eB3ikui<tBT}y2w
z4ge*%cAsKDo-%$sHS`HLc6o&q<ri7MSmocRt=mttrKe4;?QnT`iNaTCX|A=MihHHu
z9t28qFM5WpJ!5=%X6T<?_+Lyemns{Fv<>@{tocbJvCGGgtF*MRfyTKeo@KpfO)k%>
z9I3RIxoqgRK5T4U4K%?vKE*aZWo&%PRb#uAjcc@?{b`o|wDGi2NkomrXISDhMxsec
z95E7~Wr@!kiDs9lEea24Y0(dKl0E$#>wS*(sLy?F=<~)##AQSGVJOOVfTzC;!yN>=
zj$7^vZ21eu@)um={|m1A*rRees%_X`WX&%cKlUn#V@BdjEb%2HvCqfTn3fjDf#mrA
zGV6WW`1EDhsA^R<hP0mj6_);r$>nmNT!yu@IAL;mj`f~1xjg5}WxvaY?)Rg{#t6_U
zZkMmJjjtLTUmeQy^){Cc-7aIsM%?)EJllBQ*m&OMN4v6dt=6-@#?oIirR{L#qUYtL
zmgd&id5?RzdKQ{6+yu~Rp6y=XJYFy!y`biB>Ul4?`o{~d=R>FR<D|A{f1Ry--FVui
zB(5_O-(ZPv7>NT);*^p2CQE$NNOb#@_KcSHl=gZLSC{q%!#xcoOZy_{@uDg1i>}hX
z=ql}tuG01>KVGHn+23L--!h)|Dv2A7#J5@E+eV^KNxa%fe1|2zV<ZkLiJOeXcUj`Q
zM&b%3akG&~u|&#9T&W~(F%sWniSHSSLrUT`M&kP{@qHs<D~Vf;#1B~F2S(y5CGlD#
z@k5sQp^>;+NznYPXS&yGY4JKBIn(`!^?t;9)Zc#On&}QJ8*k8h_K#Wm$0nC+l*Aj2
z#7|h_Cq^Rb@<We|+qJZ~4M@&GKV`k28b5yO8kI+sjW=mM`)4fuGnSq;^mFG7_GrJr
z{_f|_^*}E%x&i2yA~^Ib=T#>P@2X0)i|IozKlp1=%UaWiegj;m@V^4jcj1K!{}%kk
z3jYo`tnlxFml1ZbuZ{k}!JanyN8r`KH-QpvVBElXGvm#SHx2!pbMxE)IJY1cBr(bF
z0DcYgZ#9_scMbi?d9C7Wtog5V@d*=u7w5H$aU<hK#?6eI88^9n(3o`hu*@Eo*~@q@
z<A_UMW0G%WnO2tB&v-xM%U$vslY9rubg)b(<4(q1jJp`OyL2@s-5!?dVVPdWy^ODb
z{OeUcXiV~lAag4yVVkkd_%Q1pW_%5F-=K6gCi%Nj=WkSejWz!^7oV`^>$V_y-4+h#
z<*<xkEEo^E%BV5fiLp$KWsbXKG$xs0mKkQ56D}EzNoI^?##koqlF^uCk}Q*CnQ_MB
zj3*dRFiyC1H74CNEOUlsu4jBb;~N;?!1%OFS7Xw>8GPMd8WaCD(7hFu@V&13*I4s)
zJriHoGvV7+yJ$@Ex3fRDv(4L#KW{=zC^PO}8v1wV@06~_e{}8;E26JBcY>y!yTnT1
zyFt^=Js91DR|DTG)&Rd5H0``atOdRgH0}JoSO<JRXxjM)u^#xXplRoA;ts}l06!q=
zf&URS?Yv#w$@os-cZdzZ4}zwhhr~wUe*#TA?-ZMW&w{3%cVTXM#d#Ps?YvuTX8va2
z_lPaP?*&ae?-N^r-w&F0J|MOMKLVO|J}52%eiStAd`N5u{xE3Tc}!dk{1MQ!^SIan
z`~+y)`KY)A_+y}H=i}lo#&-cfDRu%s1)6p~Aua`e8Z_-ZgZYQ>F5rI_mjV9^XxjOt
z*bV$FXxjOdXk^?7{Atky{25RxOEd6U(6sYe(E|KA(6sY;5dr=JD9P+$nLWVIh`qp1
zgQlG?ihaOe0!=$##=Jzh75FRSa^UAcNq0Z+S<tleRnZ3gJZReanrH`p0hDZZ06z^%
z_1p>kFevGE0iOj;J6{(EfWHBncD^aP8FvFegE@+Hdw}01dVwDXO*=1&KHzVGrk!t#
zgTUVbO*`KeR{*C#)6VzAmCU~q`1_c(UU7Z^ns$DOx$70@N1$ov$KopBpMa*FpNgx2
ze+Ei<9R_|FH0}IcTm$?I(6sZChywo-H0}IK907hAH0}Ia^aK9}H0}JW7y$k)XxjOm
zxSR3az`qxRz<&UxvOB<MK`Ac*{4i+R`J*@r{BNLX=TG7o@V|qmoma$h;4~=d#(>X)
zrky{FA>jW2O*?-PCxHJ7N;1PNGYtHnVg&eqfTo@QDMlHO0{>0Kf&UAX<i}WkESkQn
zzzK+Jqp#pvfGgb>iUi*WaizYHgzT3<NpGC>#(|#^6TnY{l1`C0$vVZj(tU}zj_*rx
zrTa2*ito#DrF%=9=KBg<DUUOp#~IG!dd}l|&f^Bo;|A8L6t7~PX}FS&Dsdy<Psf$+
ztHrDNeg>{|9}+k5eGRU3KU3Vy_p@-N``O|azMq3D-PekH)crktKNoW;)k__&ls-?~
z%J=herTYcqwS2!2SGr#$UdQ)~ai#ku;`MwV#+B}uihI@ly?nn+yn*kR<4Wl(#2fj3
zC9ZV8O5Dcxt8t~ezn$ylc1~L(-o$BZaV6Px;un0s9#^`r7ccSs23+ZWqxdD?Z^AY0
z+}MM4S5IJ7LqQ;LX3<_TDiZzU!dX0)h>yny<HL&wCXOBziN%9)N7TPeZ#P#Lq%21y
z2NSWe@puAv(=&I`v3PtKtkMyYO!glWB%2UNhsEG{EIvxI$<reP@!_b`Ki)skpCo}Q
zxB5T>IMc>s&>!y~8H<iFqw=~$|JayFB<Vi+yUl@sRX&)E)w7eK5`rf;)h#|2j~^Qr
z8<-2XH)IS;$+|_^5+)-hurOOdXDrjhv#ptX#dz27#Ie|D>*&#Vx43o!o`xSOux4c?
zB*)^TNfD~FibnfKL~X(1f>q_A*;ds_G3vw<(UT|*s-(7%`IlN{BmJYXqp(#QTpV0g
z(Xh5&ma5*@Y<;_uj*N~cPS<U)rg<2l3M+U*oK~4mvx-ml4^If0*N(#N1>uF(d}Ft{
zf2@BXHXIv|iKH%1r?ntYx++$^RXOO=Lr&y$t#(@0kg<F^{O+Jtoy`nwwo38h>||_E
zR!>F4;(Yq`JyLF8Ak<=2pNtPrjEJZ>HP%0BDzTzrRbK6btPs)i`vP@$7g(jrCfq0*
zKRqUWsA^cA*NT#_?}c#qfK^0S)O2ZI$NrAaD>|wJXx>nBXGd>$XIopOJK7WJKG@nE
zsV)dDvlbuhZ0l=}L>rr%BRxH>O|5OMy@#R@?&<ArZ0+dnsV=O$!J3}sXy_7;YwPp6
zmZc|MT<7PaWtDVxw6%7STkySe&mO)hY$}mig{!Q}u0(u5=&rECnx^hm)33IQ6A16g
z-c`|1S1-qm93dEX^-Y)q4pN5;|2k;ZG(&h?NC%b8tU<Bfs-nI$7#lwwP4tf*lO469
zVU{i~^&?8{ro_-ztLCKa0G=KwhmGlhGQ&&{3|(efWBmyXMZBR+))sjOnU9n8T}GM*
zS!fsa*1?1rPu3Q*w&`zv+C5T~RhxqMHx-0-ShKX>@zHTHIv!2NClcuUC71##8s_QJ
zD$k`%4~xM0y8gjI%&9RRsi-GRJh6lrfth4&sn<Ynd@Md3KX#gGTglXIvZiO3XNozZ
z4ny2sh$-ikpA}d&e!lOr%95k~W69(3ah{MW8rDow)cPJJD@%?6zr!k#^~Up;Ync0F
zRxf#4w{E#r<+T^8u`0AT(U>D=$hsv~rCTvH!z!0q8WA%*wpla1&8<eoLgOXP^c4+N
z-ZF-NSY%ZzhxNR98eO?~U^qT_Le<MMuTG}();E!qR7Z_KZ6rQ1I<6`tzgjy<8MW<J
zh3rJp5j@QCoFPA#=FPK_J6t<N>!w*1E)VK@tqPar&~&TxXfkT1&~mC{_Ah#Lxc^uZ
zUIy{#TV#b)oyxRhiTK1AJ5k;ge6XpY?vX;v%H$c^W)-oURGn3sxjnlM>oY3#<ZJk)
z0;`BX&dl7?+OfAS67A@0iA1mHZtab9V+x#S&2jU)BaJPXxiLc?sxA!GS+m>w+Im~1
zjyo+Fns3#*(v%HlwusESQYBQ0#i6h@*PW+Vx1^3LBecY-b<21xl(I+@8bviHRegA;
zHO)IuVy&TO2`4&mdR!#Amj$VHhGQeKamAzsNHF|{LaRhpEv->#V&&=Bt>+mOa@le*
zmNRN9rs?XGUc4;vb}BV0o287LO*bPK?=)D%{c+N1aJ^L{iyRvm7SVAv&#CFST4$=~
zzq&0}NOc!?&Qr{L;iy%kEx2aT&{C_Mt1}rJr=<cdcXDzhp)ss?MIs>_?)N@I;SsA$
zXAs(m$x$4W)3`LcFuNF7`$z$<I9ls@7*o#6_hVje5yN=y$;zNYVV&tS$+;hKG-zFO
zt&ait#ZN<aiyv|4{m8&_+G|)&rr|q-)<WtniTLoaNOVmM49Akkr}Q54&?p8z&DpYh
zZnkFV?rG*+HSOhJCsbQyw7iLr4xh#<p<q>6s5Se+zgaiY<UZzBQ0PF;fGOd6zW5w1
z=62`vt@8^U6dx?G7UeCidIa`b)5l~}MR{mrI*?uZk||3kE!3-)ri?I|$o`Jyo)3G<
zUjOL=YjMWmzES1b`FEoInbr?-TW!rPjlcQa_CMdo3NN*mOi~CnTK*EWmSDXd!=73V
zakFyBZ0Y=ldv8u}l%sy9F5#3`{bu$HT%Wi5tk2D`nA(x-)ooj*+2m?{+qoAicVfGs
zC&~YbMfWd*R(P_?QA2Yt;wACXqp`#Yo=b9py5(HzLyb%HL8(h?Jr&xKb8Ov9g;sec
zIhxa><P5O)LNYs#&L#V8{z?5xPv?^3xaER;%IaqqHl1ET&j>eKp|)63t>$&0hL_s?
zr=kMSN{n@G+G1M4A$pb=kBuI~BI$%sQKs<OLaWAOL-mdZt2ASP9{Xnf<|AFt({d<e
zS)-Vv-S+DS%r<Jge|#c|^>au~y9jryM>F|I+ktH+jDwEpAo!$WVHFK?OuO*X5}ivX
z%UwdhRV*EtV#5{MZk3=C;0AY8*HXr>O!BeN!}8%RRvj``iw}gsrg~=VpcQ)<+uwP<
zYO0c_@^^QZzZ-QmOkz}TciHc{!{<@`o6fuXWhsAKV1-a6W~ZUnl6mHQIr#Gr%Uzyf
zDF?9$4&-K&6OzfZACNoSoYnb-jJo$>@$7L#wI;fD|H=N?a6fHC^md7dUl2X7W~BdA
zY-D02dQ$F=lCd*7s5LJqT-G`|zHJNU@CgyR6q>Qo98FoC$uxOvgv0J7kMcS@vU`nt
zMUf+;N_Vkubk~FmGCfj-M9q5Rbofs}_b|vw$G8tB#s<|hXk~66&(Wyw?rKKB_THcs
z1VS{(9jsk<js|2v^!Y-+h-fV$I@sIyMxrf|wg@gVREyvM_V`_WO>M0``=Wgv8mZL6
zP_<Qwq+TW7QynDE-bin>xv{IU8R6aPB8nh*ZTECEcJ=J*?5!@w3|htdn$=TXLKd3a
zIy;OHrJ<RKn=2nE0Kt)oGA!n%MXu~>>}b)>mWLKw^WE-5l~$yMqZd8ZR%k9FP%;XQ
zxN}QuZ);~qb%hK!)L0gIuF6&^nUlpJrm={LioLtgnkB<xI^3prnYC8640GzSpo4BE
z2rTz%yEE%G`FJ+-fUn)$wRNb`GnvQ$uZfuZ8_9l{pJ&MPLMD`*=n)(d&s3Bebm5#h
zshPpFZ1}zct4!a}BbX+Z?BGsP1yD2lV81q?Ii)<b$(lAu-r(sQrFUVx<MoT__v$xt
z=#Z7PKR%5oe{>=#5PZQNIsA6K0FzsJ?Vj!cegW5ztF^OceP1KFt$p4*sak7xwrN@K
z^x&RJYXa@~1+A?@`Rh2V0w|_Xj(~pF%Y@Z>Ci8RUe?$52Km%o&R{d^E_Ug~f^S<(v
ztpC>Pwb{9J<+}>41(^p4zngQWT4{yO^HtHlOfAbvr9s#7q&eqSH{KEYgpy>$GVk){
zy!+@Ocht*UBdV?P#by^-b9jAiUWw`#L^2ds7JemY&F(;O3`^W&Q^x`K=SFhmFg5k(
zZ_6)$gIIVC7UFnej?GAa;uy}2jP;Knmy!Pqs#nbPS%b&CEYIUs&W0W_z3j-f48(2H
z9VCw>*+Z%K{5Jzs=i50hY@->TYt6|iiJJE=w`wV=Z<JbR>OPUD8TsiQo@dSVv86IP
zTO@N*VZ12^d3(OzXF?W~m!Gxs?|+z_-JMcS&c1`4o^!4f4yq%VxH6V*nYb~%(Jc!#
zXS!)AM-I(uB(MLu9d&<BM=fJpCI+3?*8go?RrR5)c2#|-#j2AXOa&CC>_k}&E4%3e
zYo4zamB|s=i?J(`<|!UvRs){bU-C2$@;E6scs!%Yg>0U2!t1T@DOrr{9Ay4@F<3l7
zr=~bWQqfSO=OXD%A0=IA+$4+xFBNV(D2~~{s(mZY3600c`-eGT5~TGx)^`q1)WOgS
z+>OS@d4X7!Iq2guS>K2B@EWU#uHLt=<yLXiq25Rj_Eb23(n_yjao{C<v84{YU_O;G
z9vVgc1EcZ82;87bF3X8H$~eS)Q;}xxnTd6WyJb7)+um;W-QF(H)lFR_XB!&+G`2Xt
zDR_tH+R~cPnXjzc%>KSWZf3W5HnS@xb%0dmHul4K!<~Ef2;116-p0KVY*ppeY-6#7
z%xvzWNTkz7xm(Df?*_4G>b+pG6q$#&t#W(W-r3jD8{OO8+1FJq-)EbR;!G<<6@!*>
zAD>HFH6E@S53Uz_a=^{EW+Jkpc9J*@h*PPfu%<ff`9*`mPZr8&qj#Z|_uZ)PV9#BT
z%2-XFqf2?_hX2M>Cz5%_$OVjvh){+46wSM~Ey2MgI(u=R8{cq)e4=~pt5(aiMs4^j
z_O7iC0?jzd73#32p$}vZQikU1&hKHXO=O)Jn^~!9;tqt4y3Sv^XM~VB9Ah-y$=bd-
z^p{7<<g?8x=F@PYnc83XVYxcf?w%ua;XuQ4<(8G%bA<LI&cjgvIe&)CsRuV#J7=oK
zn`nH3G51^aj4?Mi$Cx+K7#p_cWc>6zi$i99$|In&@QLbq40Q{WTf&-~F_!ffHIzAD
zXQJ_0B05L2dCqIhmFI+2m;a4f$e7A6qjNP8s>wu6QTJIDw4as@j&~!v|G1diu;~q+
zG`A&mQ|iWaMkiy*#muqfNi&u_)vrW!z}T<)vqW?*rp_|epCf7V#1RPDk9E8yWCpjF
zudSN{G1<v(lit`)#-x{@V=_D0n8f_#iGF0}Cl6a2G)2ftHTGf%`<Y(so;E{f>hVw4
zIrt1dw;5Oe9>kejlNH)QO)+8J;d~NxCMNRZE29cSZ@U^&#a0nLVL~|cL04B?A!HgX
zD?#V7NPCi#ZmP?+W>BJMZyGYE!*i0fWzXWvqwK05W!p0)d2M@=d~Ih*7{8Cmg-q5o
z6*6@%Js<Nq&{SvY-dD!taM&!MWV`YnCFCi%X><4frOx9+wumu*g;h=YySrA%(_Zcr
zT{WJD@d_Bjs%En01#it{C2I4Yn#qwdIbeb%*C9Yl%gnUsVrq+Kg7u_nOFK4MR{!wW
z@qWBkpBTZ&&pzND0lRaIg67HEvt_hP*|F2A&ZtCB^4q*6zKVEQOo%M)2Ft?N9?>Kp
zsKexyo#CFC7<RPIJ7tcWar~2=JW7dEDJeHEvZhHTb%+CPo1Is?{BlR<rWChYm0EH9
zc-+Al&())ZEH#r~QhvYTlb_mYc@>+A?I3Dopk$0bL)si$Rul-NT#b^-sqNTO7Rgj&
z%3VDvZ?RLJ!stZhW6JjvpOpXiJt^;pH>pWKt4U4%QB5l63z?MuMkST~Wk|~Nkw(h<
ziAKurql;Ab2LLJ0@&1(G+5J@3>G_oBn0(6jBz!98n0v~7cs%7kI-YVJ_)d9`FQ?RT
z<dn}5-jv?~-IO_0oAMrzP5GUEP5B-?O-*s?G&R*3$dun%#nhAs5mQs2@=Hy9#4mLY
zC&5yg!&)hy^F%4X^FgN7`It#cp1(;=az-XK*+H0;&-sy*-x&*cwdKtEyiIpkTaJXB
z&E2l##B@@0q9En};yRV*HEqhge@*$n@J!`-&zSOk$(ZtgDVLi3)tI}V`aN$`dEWJ;
z^1Td5<$V>9${*O5N?A)G*)Xh>m7*GCk~nT^vgoXI1kLPP_o(N2ifv{msr=kgPd$xd
zc`M_MM$;!KAic@gul!?yDWB+8$}hGhTf*CRvg)`cya}o#9Q3pK;})BPtf^9Z+|ehp
zg((Xm)#mQjuHMe>loh2fd?s)*DY`nCsKGb8i6cb%>FeF1#2mu4M2-+qT>M0FAh95u
zyNDQzz1-r&QerG4vfP^#OsvXgtj%WR<iU&_y^UVIVrkjmOIGHjBc#P83MRICEfgiT
z6XRkpHz>JBh^zE+3^jUHiexqAh-FzWPH+)?N@trmnC%J**}S3J(~&GjcD(#a76NTA
zu=U%{WDxg=*x5c`QgIq~W_JE>i|o9g6xsTd+Ce=qY`=qOcFy@B+jVTn_6h$cOQgr-
znBT7S<x@z1`3@p?gT!_ffZ&I%1F_vit|4-S$fHCaBXS6p5Nkrs#J)k~79uYaIY0@^
ziCje_M&tyMcM*9Hk$X_Ju}wq<h&V*vLgW<ujIAQlPNb8_7?CqXK1AdrL}rwO#7jYL
zAaWy-uM>HZNFk-pF9WF|)Jde9h>hO~kF6kbHIYvcd4|ZE3XuOKw4TssiF}^O4~YDj
zNPHSdg2>`3klzqmO6VmbzammG9i)m#=?oBy$R9%>w-fpkp)HsNViys)Y9`2ig#Lrb
zUx^$h-rYprOys&*AhU=hh@2sEY&OUck(ro3VzY^CC$fXc{Y2hI<c_%@e<Fn6lR=i4
zXJU5~`gk44Q$*54{zBx=c_8-?*@)2;Yanttk#-^*F?3>^i9Ac>J|dqX^38=H-y*UB
z^HZ#W$jT)ktBEubX(4h4k-LbzpU4M^e0?d%H;Me7$RCMp#Z(r%h)6GygG4?`<l{s(
zE(h66<TFIxO5}4y{)<S#3Xlav77@9Y$T*RYtpxcbp+^b*jnI>Xo+I)+ktWPru?UeH
zSA*O{<S`;o5P5VB-4c2A29R5bT-|^f{LiV<Xw-=hMx*xhtX)_F10i5nL^Hp9kO&f|
z+Qs4DXh;+hyDX~qfr(<Nm-(%RM2XbP`n?9bv_%~4pBNsuOQT4NIs=JP5?m=Afm=A<
zL3=iQ2+lVdPongsN?>&0XX5io(;2iR|L_9~my_`Fe8T#-8Q8Er1HW*K6<!P<!kiJ#
zo)|tHJ3{Jn8r!<|HAW*HeeKabt&ujIhwN)_igeo{oZt}r`vFNDp^MV5G$b$*1NH)!
z#=*w6zKBOJfk6qY%{{I7z#oS@d%dZZlv*n-$n4yi(m2Mi?#twM{1O1Yu=5CDJO}K#
zTA+7dXNxx-qudx!KQQ1Gp#SNBJxjGKf0b*BXU~e_MPOH3-`>`a){Z@$-H`)*k)B?A
zb~d}G3qMQ{v1g8=F>rLBzAw!fS>`VtZEx&o-2-zG`~bosdqGBu&cpH#9<)Y!be0SA
zC9AAwM5UWX_mDj|hoygE!CsP^Bwt1HA=w@rbhW2NySh8k?5fCB`c@Y;D$nUkH7&Kw
zj~nf3>~3twLE-KmS=1%IQnGU>k(ugfE&VzKlzKY*x|<{RQa^6goClUdOMHc-pUTdx
zEC);-N-0+zF3`qwlN^dRwRJY{mx5@tY>g<t%T>wqbCc!oS+wJYzFlPwK6f{E?2TZ8
zP-=AwXl<&4D^)j{8SU-t>TK)Wdx+}1wL8*|>aoiW*Pde_T6-_0nktpYwPhx{#g?c;
z+#aqPs7i5GmWZmYMf7VN>Zd!@*=dgvd)*WQ-dq}{l9tA~L+Hv_oL@&dxn(K|eeBy~
z7ai0T%^YO+7Os9u5pVIrlgTS*!%@thtt~iNuga=BoogQ0I<<^nw`n*Bwd`TK;T&{4
zgBHVc68}{p*PnwB)zzNX?)FHFz5Bex{fd6+`B})Wg_<aRB_JEb%*HdlOjWcceq7}e
zog(S$vFm(A<g_@?)kW~w@%Fd*{)sB*)sv-qJ*c4viT>h3&jL$*m^st-Os|kBbY`q5
z%h}H^ci+zuQD)rbQ;%uaH0&PeIjK<urSM3W&m;XX$dt^N?;V^g{FQTRU`~#l^1j?W
zgy4vrW^*0!<$E2OlcTIMn8p1@+cf<!?92AroSiLWYMeT@%cSIE;YZ7ng{~eYznt;*
z$F-BEdtGopD!j&&FLUHKH*_2;I~zXxmXqK+Z7<7X#p}$Pd{Q!J&x4>gS5|pEms8Zy
zF|W^cen}oR-^b;8R`W~pE$oW?;+{!)U4A*A0!!bsoKU{cQ{~D^l}qCJ{)tLenl+Oe
zAF0zLRGQ6BQ;L;p^6I07KXzrtW%)UlZIsPq;d)j|pYqK(v)SXE*#uKGcRBf6WX9|v
zo@Ht{4Hn(Iftg;W@?3TuZ*P}XwVdUBQoQ|C_AsxQvK^xLtXaE^g}F<5z1`_O)D^K;
z<fhBY<Q!<pA7weSeAbJPL+Ur!Xw8b%Ef%iJU1L9|{-~a$r5WzF!zs(wUVBmgx|KS3
z9jJa#5eLHf_Y~FZRXV?Em#Uit!ZZPUdbc=+1405nuFb!lm_XbnAfvYk$^<AB6G$Kc
z6L1A^5m*T%5J?Fn5JU+i5H(RTTm(k~iA?Yok&i$kOa$=`cjy*Ti9iCeh=2^QBJL1K
zAmk88tR=FJ$a*66L=b@p$e`vXLWo5K5}S!^A+nXoHX;`h$pl+>(CsBeb`rUi$Sxw6
z5!p?okw_DfW+E*_B1HBO*-K;}kyav?6WLFsjYvC@4kDdIx`-Sg(oLj?NH38-A_s|F
zLF7szhltojt|D?Zk;5Q%wR#zx+4h!4TU+of!FQdAuVmH;b}{z>I~48fiA0<6z|&#)
z9=pPIP{5v{n>V7v4t6!AyUzpImF_qFc9rT0>fN|KtzEd@vD;PZg_ce(i^k=l1iJ=D
z33MdHFst~WK&C)dd`cm6KOH}fhd1~c#tgR=L}e1=_H;K3KV<pdK;kIX8IiwUvY`*z
zCO7ntItj4>9exNu`<dJjA48Odf5vXZvEd2o;Om`OVm)46Y*4Q+>c>u}%67_E78C&v
zBtM0qQc<w7K>w8mEBUS}SQNAhiVFPyS%nr-{@?qnEGWcZ+25?<%EHP*!X<wzECJ`w
zRwZhPIWjd@uCml6{|BpvYxDv%biPyB%a-%Vziid17Ik@`HT+BDm+Hqm*OL3``tkDH
z%U7aI+qfl4{!lm*EyX3TDyZ_bmd@8LU*^+BTFzZVe!Ps&e#lQl^QQ73V^3?ieVIJf
zPs5LwYejpdubiiEAIj)vkj_JE>+AVh$=Ex8q&@JjtBk$L<m8;D=RtifDJ&^)|7pIy
zW~b?UO83LWn<`D)_LI}R?CWHCxn&7w-)r6fe?7k%C@YYEZY|Bz*U8ef%(-64mRGj2
MAaHZw=AwuH7p35n-v9sr

diff --git a/__pycache__/csi_pb2_grpc.cpython-310.pyc b/__pycache__/csi_pb2_grpc.cpython-310.pyc
deleted file mode 100644
index 4f564266b5af8910c4d6443137c5b84f39bcda9c..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 15872
zcmdU0|8FG8RiAGjkLQa${xV*#*I#D$Zuic6yW<=QB#PkJ!?$;AxHX&e?EynzGM?)7
zju}t;s@s=aGe_X|l0e822q6TB(4Cb0;QYi-@GBBO@CSfU)QW@@en}K5zbsKCD-nF&
z>+b66neG|GtVEbm*Hpb%UGLLXuU@@+)nk@Q`2;@yp8wYFgRdnL|3L-)lR@DIF6$qW
zh(tXhk|Nbf)|333s;6H{h_uMOlMopr^DteXKzTxBQO<HXD<(zmokV>S^eK@CJ<s$U
z$^}tGxya=yluKe7<!LVG#f&K9z5?j8Vh;2<rWaA37YisaaJhtXMJ%Gc$mMBqPAuWR
z8PLy*Wzd(IUKXjH#Kwi=n_Hc>(Y341uBcjue8Z5{R;OuMhE;8uQX1Bw*%j^XUez|M
zhtjmo-J^Tgg>kRlHQXE8EyJpP51o<NZc(a#QYhTO^=Ju+kw7OU>M4<|r$tJn0V*Rh
z05RbdZwX*%+Yff^qutYw+-_SIi3AL@)o$95B+S;)0qQjEw%G-;11eP8-D-_NRqwSs
zMy*Bi{14?PaBbnTUP01J?qjg*<bG;DjWn}AAyV(Adx=JtIYgUePEK*An3Dk~&zyqd
z6vYIPXHRc!nO)14M=jfwwS2zneV&(l)<;!|h^_n0ZrA91wEBE?Pad{vTW-0gDxI!v
zwybvTjc03qXKcP?*mpWdd+qM6?mhD)RiBf_>qmxVH!x7`W~Y5@$a=*cBFkt9BOsq%
ziEnJHdDz@-ciMK_uuc~T>fMp%uCcvQatcS?rhL%g)X4!`qj9+VGtNQ?)hjL{XLiSj
z^s2dION^dV>8nVZWEoEWMQI**RZ5{M&WbAP7=00|F<h_RK%9QFQ{?CI+bDS@@16-R
zo}`?NWpwU2linbmB;+y_=JdwqU396niMb(-P1M~tTDG-m9vWTCJd!PAbFXt`*@nC>
z+VVPjh&q!xslh{h_`u0E8trb|ZZry{g=<JM*;F!%Z|*0ViT+&iC&v|k@M$L0{JXbL
zCa9@y^T22{oP48kV2Yy-<%^BR>qpIw$C+$2Fi{!}xdKW23|ex5XlW!lT#vGx$s~&@
zro~QO>uFSsp1NWJQy8{QOyV~ya+nZPPFXzwj0tRmlw>hmB-j5?o~|uikE%#|srM4@
zynH{Iq*6vCDQ8cJ<iq6K$&(Z}a(wQ#Vc$1JwQFMP9~^cJG6IIUc#^H>EW>WJOkp?~
z>ic?r2d3i4+5)9sy1RYr_MMk+-oCm0>dhDG1*$3xyV>qo&iuA%-wK+#DWxe-(vs|z
zGwDq?=!FS6Z`%ExSw^kPxVST?Q~6{rdA!#D{57SvG>c<9LOzLxB()~5P_jV@X`!3&
z;LW4>43VxOIldAvNuL2@NnC`WXO+ao0f{_+wl^jvskU6Fq)N#}N~n7zVV2a4_AvZd
z{6tTHaS4}2i*7EFN#;_yY%wc|9<t`7M3cBkXRLiBc49x-OYEoYG+A<_+5Jh8d^hdU
zbD&HyJs+YMKrb@A<kCgzYw5RAcH+Hhk?y75Pra4yCEuIrrSGu@iUgE8vklw3;3-4M
z%+}|X^$l$AM!N6Gk7xP}`$kzlg-3AKGz;5+);11UzZ+N@L<cj6JCH1gEK)K<$uuP;
zO1NidDK|$6_wfSdDoC95a9dVm&*;KLxBSMPrKS*yNWwj-)=7qDlRJ5xEakAw%n!n|
z>N9<9YC}w;>#UK8ew}I9Caqs+^dqRl<|UKLuuaUsCJyGZKg`T#l9~T1r{o85M+;Zz
zqdYQF3*Ax~nW@xN8s7}3$ic%RUkpa2J`u?!-;B8M)gtaCe~q}4A`P`DIywK@*gWym
zZ@<`L|ItH8c^WoS+eb8ONj=|7_27)a7130;m+GZ^6TM6?+nem=dQ<P0AR)Ca$xLtL
zTy-fLZysU@*$wJQYFY-$!79PZLGn)W@+y9utlgA*hV4w6hvYa}^?7fJYqX@nK3B72
z)yu7BrxT*&+E}VvN78T#@U;%1<rZ$QPk*Y3#q6Fb8`5Zs2hOAoH0F`*<e+U$(S)=<
zlSL}LgX<A#aIruuAJ&{?=Euj%nDiOQxbBlbix#L$X!-KGME)G|T2Jt7;GW<q!4u}g
zRHY9UO&vk>UqBL=>;Or~fR02og;rt^@q}bVG%MXH9EFHx?-A8tMAN=v)m#T9=jzt>
zi`)1>QiQd2iWWJ?EqB`YSs?BC1Kax{h`WQ!x`BjjZz`2ar;_@&_@h+$EVS~EB(*j$
zHOU93)+J@&=TF01wx!vDaU=i6bq$E;e<-h<_Sce++i7QaegdvWiQV~W<<8GACksxQ
zIkSp0$DB!U=9#mgI2GpPz*%I@ImKCG&J;N3nX{}o7nqX=XN5VdinGR?0yyi;sVdGz
z<`luX#GEG-=Sk+2z`4wvD~j_JbEd(0nmHSab5+d1vXmwD^69$o{RiW+xrM218?Tui
z?6)K>xskPAFgk``>-1_=Gis#o9PM`6)_u3d(`!TP-t8WSYG042{Tg;YFf|@TeWnIm
zDD8P(Zd<l1+lu7FJ)<^S*nN%w=hakur;8Eb+}_*iHV>`)rhOV!#qBy(r5e!+VfHIn
zryCJ9f(N|$<{{h#uXok9FW_$mSv-JSZ+qjJz-l`4`jC4&C3Z2Kg)qn6HL($MiaN`g
z*Y&~QY%PR|-kz(dQ=PQ{T}V&-Hr8YLUUTPSDmc}E(Wg~@+ZTt_@LE3~TgAB;uZO;X
zOT(&o5|-oZICGlr`fbjKXkH@)jp)p28m;aM(fqqKqTXE|+1GQw4XwKdY7BN)Ulpek
zo*90li~VG;rRgx;sf1^Zy1k$5-yWtr3!xe1-(BgWdN-FsWM?(d0e!Cdjc6JiW_ztI
zM&Ir%2Xyq6J1_k<FGTXZ2InJ~@*E7cw#xJ7ih=;2$7Q{ZWLVrGDi-m$X^3rTQ#Bmj
zkgH+zfsb+njL#AC5+ziM^)akB!PVXWAja4qs1Q>KSWJq%DBw3IilT(yDKRZ(@S7K9
zF^k`Vm=p8(Es6zE!EZ?{igWm#7E9therLq8xPafXSiyq2>dXbhvU8@;$60p#<e&W;
zE_cVT8AD%0O*g}1ZS~1Z|MpN(y5Sy6)N2s)9VP1OV8_)0QfO5eOX_bx;&+wQYk`QM
zFO|>Iw_=PX_Y;u$110x*gxvTgU@XB62>nkbShG{=fwg60EJ?eNaynF!w;Yg{HI^g;
zQWDq~xD#UdAoeXmW68Y_u~{WoTMAWQh8L`{g#8YL6^9B7FK=TB>q6L^5~g`g>d8XO
z;aIX>hpZ(fYa?PR1SEYi9ZRSUp=(O$l|X`ez<{Jy;_Z#us9m-sgDlBZN-|=SY>K1_
zE@`q!ng^0pRFb|(8b?X}E9t={0nygzV3nhd|G(hk0|Gw^n#&G;5gDbr1CddRdr*kU
zs^d8yS7g*{XBuIu8IG8iLy^>3(C3&wAEGaSUSaxTh<*<AC8nPb(U(EL!1R?6eHHXI
zrmu(SRnRXo{Zfej1n5sP{c?zY1@xzw{&a}G0s2*@KjYF72`+IY_?i|8zTOuJme<kE
z8>O-J;CR-H2?x5jQR6V5tU-d?K1cVqsmPJ6U!@$!l2`#hPDMJ{bXD<H%H5@emGajp
z_v@6fde$lTo0PDk{ubqan-W&pPg1T)2`ex8Sd!yotj71KxJL;qbenSfl(1@dD0e^!
zE4fLzLrPfPCFLwiHYxc4CC^gA+OMX7Q>9RG&=>yH41&d%q1o0KaOdz~aZ~{LanrK@
zl-cqE(r*CJfJdqV(q92)-6M?%Dz6U>NU!tD0&xN9b$)?>1JaQ#)9VDp%|&wQ<pSbP
zMRMt71LET4gn>Z#I=_HG+(IOmUPmA<USx>4mtIaFZYh#WFDnoiFFi!uOD`}GcP5g1
zL98&h9LZf3Ys{VH;C<D}2ikU~@V$yZKaVkwiT3hb<r&Izb%qo@D%#7d2$aK(_G<g0
zusc68@cc{hP}n*!6gCmDP{@=#jD!+$_eVmZ<tL_B*fKE`HczooXhr?9f^sPspV;ld
zNK`MxqhbTesMt!zq9SYh4Tb8-NL2mXg^{>!#^Yj3&A8ZH$KoQh{`U&kWewMm?Zil6
zFUAAoHG_fi!VwFM7MOolz_jp3P2X;eMDkKRl23x=E`&|W#Ui1#?OTyZ^zFz<B)^Pi
zVpN+~O70V0E@P3<vid!RBwC63w<{xY-HOM>OE%-;bvqUpt?#D_mlo~x43Qs%jy=>=
zR`Fx;VAx?`F#D(!KV0Np6jHub)WP&^cSiQiuf&64cZI<m3<X2J&58oEq)o5zc4#D)
zm*cURgn+TI!xTG8<XBx-ShUTjW*9@;rIDa+$Ae;zjX|;777L2pyXO=rExMqAQrju{
z90{C@+*17_SY!Lsnm?(WO8F_YY(l%O9Fp-)IL~?#`qN$yC$-co13oJTGI0Z!e^Q&<
z#+y@TIHUbn+{0&$kL|@uZtef{j8^0k&@H$pq$~c}8}-Mg+bPYx(DA5xZ&Ovdi&sKb
zrQpy}@k24qQ*{8S_<im~Z~&`nsEI|dxml;H11NQK5Fw#&tvOv9XaF_neYNe4744*O
zkpMuX-vQovg?m_dZh+|?Sh(kfGksiVi3p*d@=rg`M{vBekJ$m1+fJxQL+$i&^mall
zXW4D~P(Oe6Te=X*^Uq@<m<~Tfc$ECcSWrL9Yio|$3iBN9SA9JFhPVgA46m6oHKTLf
zr$fW~ak<|PKivRNf4V-V<HIBk@ms;0lnmXad3P5yV(b~!4vddQTcXE%Muih6R+qD$
zHPQLe9a_*XksYK`td(T6`p$m*vnH6Fd8bI-<;OnUw`0=4;eRMk*A}j`oE|+yz0cAU
zT|?%0MQ^;ug<vL+6=D4>n*V~5vo;_nG|R`5^hc2Nr6H0+Q+g~(6l(gal2na&rjVr=
zOV$@5>u;5;^#NI7gD{q;FG1ATm8jJLQM%C>OVD3H&^MK!!T#$rDPzg{DrEhglEr4x
zpG2(Zkmasr#YhK~rimmSmZV;iMqbj8Na`#}4<boIq>K4iU_69qYXO<T&^-e7RAV4u
zUj&h6vGpA!|K9`l2%P6QaK5Sq&etLX=Q(-C&OR=9@p017jdd+D&JA#6{14D~?r!pJ
z%JH6shw&XMeuferP=0~n52?sQ`+3U!F(o|6?^5nhDB<D$Q_B4rB|PwdPPs2r!Yc3;
z%KarJo0NQjlBjU@GKI7C$rS{$|ADlHf;^8qke&T@=BgK#{%bVf!WH_cur!^Y>Wf!I
zxU@1fEL|BImaYs9OIP?`ZWP3g3QJe`KX1g13QJe`KXAm23QJdphNUa~FFCrm$N}I*
zCqv`&KMVanK!?Uef>;?@1z8zqP%|?0OX~Z5sDK;#T_6ktYw^hK`*A!D)_umo6Cf4`
zO_U!i9PHRLj__JN63OqzBjIVsNO<nWBB422O8Y$$APKMKBa!stk?@RXBs}e7k&t;<
zQ%HCn@%kjZ){n&URy>w>!E#L%+niV|Uqro4g@yM3{#xd~E5<v&(Q&!oi-*Fdj=P2J
zT`Ux`i#HUMic;B-uQ0MtJ{=E)jVuFUOB)M>Eb_+{kYIfJeTk7+em@=yTX@F8W<C}R
zEeE>_3vamm@gZNs4S1Cz{S6LyJ;eS0Tc_i1aPN0%8TmRgKmBnn#GD8*-l(`p5B(Gp
z{H4zQrzHP_#mSnx^w&!MCnEp%i~s4v|0$3+=$<1==&+TeSG+l6$4b&l$E`<sXHM?t
w-9Jh`hZQejRgvHyX84a;IbB}PEtZ$cA1=R~d!_ub#HY)<<qzgQwD9bI13!m(SpWb4

diff --git a/bin/build.sh b/bin/build.sh
deleted file mode 100755
index b2565c3..0000000
--- a/bin/build.sh
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/usr/bin/env bash
-
-docker build -t ahelberg/gluster-dir-csi .
diff --git a/bin/gen-protos.sh b/bin/gen-protos.sh
deleted file mode 100755
index b484485..0000000
--- a/bin/gen-protos.sh
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/usr/bin/env bash
-
-python -m grpc_tools.protoc -Icsi-spec/  --python_out=. --grpc_python_out=. csi-spec/csi.proto
diff --git a/bin/push.sh b/bin/push.sh
deleted file mode 100755
index 516d449..0000000
--- a/bin/push.sh
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/usr/bin/env bash
-
-docker push ahelberg/gluster-dir-csi 
diff --git a/bin/test_part1.sh b/bin/test_part1.sh
deleted file mode 100755
index 7abb078..0000000
--- a/bin/test_part1.sh
+++ /dev/null
@@ -1,2 +0,0 @@
-#!/usr/bin/env bash
-./build.sh && docker run --rm -ti --privileged -v "$PWD/docker-csi:/csi" ahelberg/gluster-dir-csi
diff --git a/build.rs b/build.rs
new file mode 100644
index 0000000..e2a18d6
--- /dev/null
+++ b/build.rs
@@ -0,0 +1,4 @@
+fn main() -> Result<(), Box<dyn std::error::Error>> {
+    tonic_build::compile_protos("csi-spec/csi.proto")?;
+    Ok(())
+}
diff --git a/csi-spec b/csi-spec
index ad238e5..1de425b 160000
--- a/csi-spec
+++ b/csi-spec
@@ -1 +1 @@
-Subproject commit ad238e5cad5a27188fcdae1ff3ace3f612638ca5
+Subproject commit 1de425b860085fa0e987d8ece6fe36ed47cdebb3
diff --git a/main.py b/main.py
deleted file mode 100644
index e7f3f6d..0000000
--- a/main.py
+++ /dev/null
@@ -1,138 +0,0 @@
-from concurrent import futures
-
-import logging
-
-import socket
-import os
-
-import grpc
-import csi_pb2
-import csi_pb2_grpc
-
-import subprocess
-
-
-gluster_host = os.environ["GLUSTER_HOST"]
-gluster_volume = os.environ["GLUSTER_VOLUME"]
-
-csi_sock_full_path = os.environ.get("CSI_PATH", "/csi/") + "csi.sock"
-
-
-def unmount(path):
-    print("Unmounting", path)
-    return subprocess.run(["umount", path])
-
-
-def mount(volume, path):
-    print("Mounting", volume, "at", path)
-    p = subprocess.run(["mount", "-t", "glusterfs", "%s:/%s/%s" %
-                       (gluster_host, gluster_volume, volume), path])
-    if p.returncode == 0:
-        return True
-
-    # Might be a stale mount, unmount and try again
-    if p.returncode == 32:
-        return True
-
-    print("Mounting failed with return code:", p.returncode)
-    return p
-
-
-class Identity(csi_pb2_grpc.Identity):
-
-    def GetPluginInfo(self, request, context):
-        return csi_pb2.GetPluginInfoResponse(name='gluster-dir-csi', vendor_version="1")
-
-    def Probe(self, request, context):
-        return csi_pb2.ProbeResponse()
-
-    def GetPluginCapabilities(self, request, context):
-        return csi_pb2.GetPluginCapabilitiesResponse(
-            capabilities=[
-                csi_pb2.PluginCapability(
-                    service=csi_pb2.PluginCapability.Service(
-                        type=csi_pb2.PluginCapability.Service.Type.CONTROLLER_SERVICE)
-                )
-            ])
-
-
-class Controller(csi_pb2_grpc.Controller):
-
-    def ControllerGetCapabilities(self, request, context):
-        return csi_pb2.ControllerGetCapabilitiesResponse(capabilities=[
-            csi_pb2.ControllerServiceCapability(rpc=csi_pb2.ControllerServiceCapability.RPC(
-                type=csi_pb2.ControllerServiceCapability.RPC.Type.CREATE_DELETE_VOLUME)),
-        ])
-
-    def CreateVolume(self, request, context):
-        name = request.name
-        print("CreateVolume", name)
-        p = subprocess.run(["mkdir", "-p", "/mnt/main/%s" % name])
-        volume = csi_pb2.Volume(volume_id=name)
-        return csi_pb2.CreateVolumeResponse(volume=volume)
-
-
-class Node(csi_pb2_grpc.Node):
-
-    def NodeGetInfo(self, request, context):
-        node_id = os.getenv("HOSTNAME")
-        return csi_pb2.NodeGetInfoResponse(node_id=node_id)
-
-    def NodeGetCapabilities(self, request, context):
-        return csi_pb2.NodeGetCapabilitiesResponse(capabilities=[
-            csi_pb2.NodeServiceCapability(rpc=csi_pb2.NodeServiceCapability.RPC(
-                type=csi_pb2.NodeServiceCapability.RPC.Type.STAGE_UNSTAGE_VOLUME))
-        ])
-
-    def NodePublishVolume(self, request, context):
-        volume_id = request.volume_id
-        path = request.target_path
-        print("Node Publish Volume", path)
-        p = subprocess.run(["mkdir", "-p", path], check=True)
-        res = mount(volume_id, path)
-        if res is True:
-            return csi_pb2.NodePublishVolumeResponse()
-        print(res)
-
-    def NodeUnpublishVolume(self, request, context):
-        path = request.target_path
-        print("NodeUnpublishVolume", path)
-        p = subprocess.run(["umount", path])
-        return csi_pb2.NodeUnpublishVolumeResponse()
-
-    def NodeStageVolume(self, request, context):
-        volume_id = request.volume_id
-        path = request.staging_target_path
-        print("Node Stage Volume", path)
-        res = mount(volume_id, path)
-        if res is True:
-            return csi_pb2.NodeStageVolumeResponse()
-        print(res)
-
-    def NodeUnstageVolume(self, request, context):
-        path = request.staging_target_path
-        print("NodeUnstageVolume", path)
-        p = subprocess.run(["umount", path])
-        return csi_pb2.NodeUnstageVolumeResponse()
-
-
-def serve():
-    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
-    csi_pb2_grpc.add_IdentityServicer_to_server(Identity(), server)
-    csi_pb2_grpc.add_ControllerServicer_to_server(Controller(), server)
-    csi_pb2_grpc.add_NodeServicer_to_server(Node(), server)
-
-    print("About to start listening on", csi_sock_full_path)
-    server.add_insecure_port(f'unix://%s' % csi_sock_full_path)
-    server.start()
-    print("Waiting for termination")
-    server.wait_for_termination()
-
-
-if __name__ == '__main__':
-    p = subprocess.run(["mkdir", "-p", "/mnt/main"])
-    p = subprocess.run(["mount", "-t", "glusterfs", "%s:/%s" %
-                       (gluster_host, gluster_volume), "/mnt/main"], check=True)
-
-    logging.basicConfig()
-    serve()
diff --git a/requirements.txt b/requirements.txt
deleted file mode 100644
index 5c38c41..0000000
--- a/requirements.txt
+++ /dev/null
@@ -1,5 +0,0 @@
-grpcio==1.47.0
-grpcio-tools==1.47.0
-protobuf==3.20.1
-googleapis-common-protos==1.53.0
-six==1.16.0
diff --git a/src/main.rs b/src/main.rs
new file mode 100644
index 0000000..55385f9
--- /dev/null
+++ b/src/main.rs
@@ -0,0 +1,454 @@
+use std::io::Error;
+use std::process::Command;
+
+use tonic::{transport::Server, Request, Response, Status};
+
+pub mod csi {
+    tonic::include_proto!("csi.v1");
+}
+
+use tokio::net::UnixListener;
+use tokio_stream::wrappers::UnixListenerStream;
+
+use csi::controller_server::{Controller, ControllerServer};
+use csi::identity_server::{Identity, IdentityServer};
+use csi::node_server::{Node, NodeServer};
+
+fn mount_volume(volume_id: String, target_path: String) -> Result<(), Status> {
+    std::fs::create_dir_all(&target_path).unwrap();
+
+    // Mount gluster volume to target path
+    let output = std::process::Command::new("mount")
+        .arg("-t")
+        .arg("glusterfs")
+        .arg(format!(
+            "{}:/{}/{}",
+            std::env::var("GLUSTER_HOST").unwrap(),
+            std::env::var("GLUSTER_VOLUME").unwrap(),
+            volume_id
+        ))
+        .arg(&target_path)
+        .output()
+        .expect("failed to execute process");
+
+    // Check if mount was successful
+    // Code 0 means success
+    // Code 32 means already mounted
+    if output.status.code() != Some(0) && output.status.code() != Some(32) {
+        println!(
+            "Mount failed with code: {:?} {}",
+            output.status.code(),
+            String::from_utf8_lossy(&output.stderr)
+        );
+
+        return Err(Status::internal(format!(
+            "Mount failed with code: {:?}",
+            output.status.code(),
+        )));
+    }
+
+    return Ok(());
+}
+
+fn unmount_volume(target_path: String) -> Result<(), Status> {
+    // Unmount gluster volume
+    let output = std::process::Command::new("umount")
+        .arg("-l") //TODO: Think about this
+        .arg(target_path)
+        .output()
+        .expect("failed to execute process");
+
+    // Check if unmount was successful
+    // Code 0 means success
+    // Code 32 means already unmounted
+    if output.status.code() != Some(0) && output.status.code() != Some(32) {
+        println!(
+            "Unmount failed with code: {:?} {}",
+            output.status.code(),
+            String::from_utf8_lossy(&output.stderr)
+        );
+
+        return Err(Status::internal(format!(
+            "Unmount failed with code: {:?}",
+            output.status.code(),
+        )));
+    }
+
+    return Ok(());
+}
+
+#[derive(Debug, Default)]
+struct GlusterNode {}
+
+#[tonic::async_trait]
+impl Node for GlusterNode {
+    async fn node_get_info(
+        &self,
+        request: Request<csi::NodeGetInfoRequest>,
+    ) -> Result<Response<csi::NodeGetInfoResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        // Get hostname of system
+        let hostname = hostname::get().unwrap().into_string().unwrap();
+
+        let reply = csi::NodeGetInfoResponse {
+            node_id: hostname,
+            max_volumes_per_node: 0,
+            accessible_topology: None,
+        };
+        Ok(Response::new(reply))
+    }
+
+    async fn node_get_capabilities(
+        &self,
+        request: Request<csi::NodeGetCapabilitiesRequest>,
+    ) -> Result<Response<csi::NodeGetCapabilitiesResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        let reply = csi::NodeGetCapabilitiesResponse {
+            capabilities: vec![csi::NodeServiceCapability {
+                r#type: Some(csi::node_service_capability::Type::Rpc(
+                    csi::node_service_capability::Rpc {
+                        r#type: csi::node_service_capability::rpc::Type::StageUnstageVolume as i32,
+                    },
+                )),
+            }],
+        };
+        Ok(Response::new(reply))
+    }
+
+    async fn node_publish_volume(
+        &self,
+        request: Request<csi::NodePublishVolumeRequest>,
+    ) -> Result<Response<csi::NodePublishVolumeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        let volume_id = request.get_ref().volume_id.clone();
+        let target_path = request.get_ref().target_path.clone();
+
+        // Mount gluster volume to target path
+        mount_volume(volume_id, target_path)?;
+
+        let reply = csi::NodePublishVolumeResponse {};
+        Ok(Response::new(reply))
+    }
+
+    async fn node_unpublish_volume(
+        &self,
+        request: Request<csi::NodeUnpublishVolumeRequest>,
+    ) -> Result<Response<csi::NodeUnpublishVolumeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        let target_path = request.get_ref().target_path.clone();
+
+        // Unmount gluster volume
+        unmount_volume(target_path)?;
+
+        let reply = csi::NodeUnpublishVolumeResponse {};
+        Ok(Response::new(reply))
+    }
+
+    async fn node_stage_volume(
+        &self,
+        request: Request<csi::NodeStageVolumeRequest>,
+    ) -> Result<Response<csi::NodeStageVolumeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        let volume_id = request.get_ref().volume_id.clone();
+        let target_path = request.get_ref().staging_target_path.clone();
+
+        // Mount gluster volume to target path
+        mount_volume(volume_id, target_path)?;
+
+        let reply = csi::NodeStageVolumeResponse {};
+        Ok(Response::new(reply))
+    }
+
+    async fn node_unstage_volume(
+        &self,
+        request: Request<csi::NodeUnstageVolumeRequest>,
+    ) -> Result<Response<csi::NodeUnstageVolumeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        let target_path = request.get_ref().staging_target_path.clone();
+
+        // Unmount gluster volume
+        unmount_volume(target_path)?;
+
+        let reply = csi::NodeUnstageVolumeResponse {};
+        Ok(Response::new(reply))
+    }
+
+    async fn node_expand_volume(
+        &self,
+        request: Request<csi::NodeExpandVolumeRequest>,
+    ) -> Result<Response<csi::NodeExpandVolumeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("Not implemented"))
+    }
+
+    async fn node_get_volume_stats(
+        &self,
+        request: Request<csi::NodeGetVolumeStatsRequest>,
+    ) -> Result<Response<csi::NodeGetVolumeStatsResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("Not implemented"))
+    }
+}
+
+#[derive(Debug, Default)]
+struct GlusterController {}
+
+#[tonic::async_trait]
+impl Controller for GlusterController {
+    async fn controller_get_capabilities(
+        &self,
+        request: Request<csi::ControllerGetCapabilitiesRequest>,
+    ) -> Result<Response<csi::ControllerGetCapabilitiesResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        // Return CREATE_DELETE_VOLUME capability
+        let reply = csi::ControllerGetCapabilitiesResponse {
+            capabilities: vec![csi::ControllerServiceCapability {
+                r#type: Some(csi::controller_service_capability::Type::Rpc(
+                    csi::controller_service_capability::Rpc {
+                        r#type: csi::controller_service_capability::rpc::Type::CreateDeleteVolume
+                            as i32,
+                    },
+                )),
+            }],
+        };
+
+        Ok(Response::new(reply))
+    }
+
+    async fn create_volume(
+        &self,
+        request: Request<csi::CreateVolumeRequest>,
+    ) -> Result<Response<csi::CreateVolumeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        let name = request.into_inner().name;
+
+        std::fs::create_dir_all(std::path::Path::new("/mnt/main/").join(&name))?;
+
+        let reply = csi::CreateVolumeResponse {
+            volume: Some(csi::Volume {
+                capacity_bytes: 0,
+                volume_id: name,
+                volume_context: Default::default(),
+                content_source: None,
+                accessible_topology: Default::default(),
+            }),
+        };
+        Ok(Response::new(reply))
+    }
+
+    async fn delete_volume(
+        &self,
+        request: Request<csi::DeleteVolumeRequest>,
+    ) -> Result<Response<csi::DeleteVolumeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        // let name = request.into_inner().volume_id;
+
+        // std::fs::remove_dir_all(std::path::Path::new("/mnt/glusterfs").join(&name))?;
+
+        let reply = csi::DeleteVolumeResponse {};
+        Ok(Response::new(reply))
+    }
+
+    async fn controller_publish_volume(
+        &self,
+        request: Request<csi::ControllerPublishVolumeRequest>,
+    ) -> Result<Response<csi::ControllerPublishVolumeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("not implemented"))
+    }
+
+    async fn controller_unpublish_volume(
+        &self,
+        request: Request<csi::ControllerUnpublishVolumeRequest>,
+    ) -> Result<Response<csi::ControllerUnpublishVolumeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("not implemented"))
+    }
+
+    async fn validate_volume_capabilities(
+        &self,
+        request: Request<csi::ValidateVolumeCapabilitiesRequest>,
+    ) -> Result<Response<csi::ValidateVolumeCapabilitiesResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("not implemented"))
+    }
+
+    async fn list_volumes(
+        &self,
+        request: Request<csi::ListVolumesRequest>,
+    ) -> Result<Response<csi::ListVolumesResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("not implemented"))
+    }
+
+    async fn get_capacity(
+        &self,
+        request: Request<csi::GetCapacityRequest>,
+    ) -> Result<Response<csi::GetCapacityResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("not implemented"))
+    }
+
+    async fn controller_get_volume(
+        &self,
+        request: Request<csi::ControllerGetVolumeRequest>,
+    ) -> Result<Response<csi::ControllerGetVolumeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("not implemented"))
+    }
+
+    async fn create_snapshot(
+        &self,
+        request: Request<csi::CreateSnapshotRequest>,
+    ) -> Result<Response<csi::CreateSnapshotResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("not implemented"))
+    }
+
+    async fn delete_snapshot(
+        &self,
+        request: Request<csi::DeleteSnapshotRequest>,
+    ) -> Result<Response<csi::DeleteSnapshotResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("not implemented"))
+    }
+
+    async fn list_snapshots(
+        &self,
+        request: Request<csi::ListSnapshotsRequest>,
+    ) -> Result<Response<csi::ListSnapshotsResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("not implemented"))
+    }
+
+    async fn controller_expand_volume(
+        &self,
+        request: Request<csi::ControllerExpandVolumeRequest>,
+    ) -> Result<Response<csi::ControllerExpandVolumeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        Err(Status::unimplemented("not implemented"))
+    }
+}
+
+#[derive(Debug, Default)]
+struct GlusterIdentity {}
+
+#[tonic::async_trait]
+impl Identity for GlusterIdentity {
+    async fn get_plugin_info(
+        &self,
+        request: Request<csi::GetPluginInfoRequest>,
+    ) -> Result<Response<csi::GetPluginInfoResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        let reply = csi::GetPluginInfoResponse {
+            name: "glusterf-dir-csi".to_string(),
+            vendor_version: "0.1.0".to_string(),
+            ..Default::default()
+        };
+
+        Ok(Response::new(reply))
+    }
+
+    async fn get_plugin_capabilities(
+        &self,
+        request: Request<csi::GetPluginCapabilitiesRequest>,
+    ) -> Result<Response<csi::GetPluginCapabilitiesResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        let reply = csi::GetPluginCapabilitiesResponse {
+            capabilities: vec![csi::PluginCapability {
+                r#type: Some(csi::plugin_capability::Type::Service(
+                    csi::plugin_capability::Service {
+                        r#type: csi::plugin_capability::service::Type::ControllerService as i32,
+                    },
+                )),
+            }],
+        };
+
+        Ok(Response::new(reply))
+    }
+
+    async fn probe(
+        &self,
+        request: Request<csi::ProbeRequest>,
+    ) -> Result<Response<csi::ProbeResponse>, Status> {
+        println!("Got a request: {:?}", request);
+
+        let reply = csi::ProbeResponse { ready: Some(true) };
+
+        Ok(Response::new(reply))
+    }
+}
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    std::fs::create_dir_all("/mnt/main")?;
+    // Mount glusterfs main
+    let res = Command::new("mount")
+        .arg("-t")
+        .arg("glusterfs")
+        .arg(format!(
+            "{}:{}/",
+            std::env::var("GLUSTER_HOST")?,
+            std::env::var("GLUSTER_VOLUME")?
+        ))
+        .arg("/mnt/main")
+        .output()
+        .expect("failed to mount glusterfs");
+
+    if res.status.success() {
+        println!("Glusterfs mounted");
+    } else {
+        println!(
+            "Glusterfs mount failed: {}",
+            String::from_utf8_lossy(&res.stderr)
+        );
+        return Err("Glusterfs mount failed".into());
+    }
+
+    let identity = GlusterIdentity::default();
+    let controller = GlusterController::default();
+    let node = GlusterNode::default();
+
+    println!("Starting server...");
+    let csi_sock_base = std::env::var("CSI_PATH")
+        .or_else(|_| Ok::<String, Error>("/csi/".to_owned()))
+        .unwrap();
+
+    std::fs::create_dir_all(&csi_sock_base)?;
+    let csi_sock: String = csi_sock_base + "csi.sock";
+
+    let uds = UnixListener::bind(csi_sock)?;
+    let uds_stream = UnixListenerStream::new(uds);
+
+    Server::builder()
+        .add_service(IdentityServer::new(identity))
+        .add_service(ControllerServer::new(controller))
+        .add_service(NodeServer::new(node))
+        .serve_with_incoming(uds_stream)
+        .await?;
+
+    Ok(())
+}