Socket overhaul

Cargo.toml

@@ -45,14 +45,15 @@ bytes = "*"
 ceph = {git = "https://github.com/mzhong1/ceph-rust"}#"~3.0"
 chrono = "~0.4"
 clap = "~2"
+crossbeam = "~0.7"  
 daemonize = "~0.4"
 derive-error = "0.0.4"
 dirs = "~2.0"
 dmi = {git = "https://github.com/cholcombe973/dmi"}
 fstab = "~0.3"
 gluster = "~1.0"
 goji = { git = "https://github.com/cholcombe973/goji.git" }
-gpt = { git = "https://github.com/mzhong1/gpt"}
+gpt = { git = "https://github.com/Quyzi/gpt"}
 hashicorp_vault = { git = "https://github.com/cholcombe973/vault-rs.git" }
 hostname = "~0.1"
 init-daemon = "~0.1"
@@ -83,7 +84,7 @@ tempdir = "~0.3"
 time = "~0.1"
 uname = "~0.1"
 uuid = { version="~0.7", features = ["serde", "v4"]}
-zmq = {version="~0.8"}
+zmq = {version="~0.9"}
 
 
 

api/protos/service.proto

@@ -80,6 +80,8 @@ message OpBoolResult {
   optional bool value = 2;
   // error_msg is set if ERR
   optional string error_msg = 3;
+  // the type of the operation
+  required Op op_type = 4;
 }
 
 message OpStringResult {
@@ -88,6 +90,8 @@ message OpStringResult {
   optional string value = 2;
   // error_msg is set if ERR
   optional string error_msg = 3;
+  // the type of the operation
+  required Op op_type = 4;
 }
 
 message OpOutcomeResult{
@@ -98,6 +102,10 @@ message OpOutcomeResult{
   optional bool value = 3;
   // error_msg set if ERR
   optional string error_msg = 4;
+  // the type of the operation
+  required Op op_type = 5;
+  // the disk/partition the operation was performed on
+  optional string disk = 6;
 }
 
 enum OpOutcome {