Bootstrap deviceplugin implementation

Adds an initial deviceplugin implementation based on the
k8s-deviceplugin crate.

Signed-off-by: hasheddan <[email protected]>

Author: hasheddan

plugin/Cargo.toml

@@ -0,0 +1,14 @@
+[package]
+name = "plugin"
+version = "0.1.0"
+authors = ["hasheddan <[email protected]>"]
+edition = "2018"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+k8s-deviceplugin = { path = "../k8s-deviceplugin" }
+tonic = "0.4"
+prost = "0.7"
+tokio = { version = "1.0", features = ["macros", "rt-multi-thread"] }
+tower = { version = "0.4" }

plugin/src/main.rs

@@ -0,0 +1,27 @@
+use k8s_deviceplugin::v1beta1::registration_client::RegistrationClient;
+use k8s_deviceplugin::v1beta1;
+use tokio::net::UnixStream;
+use std::convert::TryFrom;
+use tonic::transport::{Endpoint, Uri};
+use tower::service_fn;
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    let channel = Endpoint::try_from("http://[::]:50051")?
+        .connect_with_connector(service_fn(|_: Uri| {
+            UnixStream::connect(v1beta1::KUBELET_SOCKET)
+        }))
+        .await?;
+    let mut client = RegistrationClient::new(channel);
+    let request = tonic::Request::new(v1beta1::RegisterRequest {
+        endpoint: format!("{}/fpgk8s.sock", v1beta1::KUBELET_SOCKET),
+        resource_name: "fpgk8s.io/fpga".into(),
+        version: v1beta1::VERSION.into(),
+        options: None,
+    });
+
+    let response = client.register(request).await?;
+
+    println!("RESPONSE={:?}", response);
+    Ok(())
+}