[WIP] Santi/grpc agent 2nd try. CI

agents/grpc/proto/BUILD

@@ -0,0 +1 @@
+~/software/protobuf/src/protoc --cpp_out=./agents/grpc/src/proto/ --grpc-cpp_out=./agents/grpc/src/proto/ --plugin="protoc-gen-grpc-cpp=./out/Release/grpc_cpp_plugin" --proto_path=agents/grpc/proto/ agents/grpc/proto/*.proto

agents/grpc/proto/asset.proto

@@ -0,0 +1,10 @@
+syntax = "proto3";
+
+import "common.proto";
+
+package grpcagent;
+
+message Asset {
+  CommonResponse common = 1;
+  string data = 2;
+}

agents/grpc/proto/blocked_loop.proto

@@ -0,0 +1,43 @@
+// I want to define here RuntimeResponse message which will be oneOf many other types of messages
+// For example:
+// - InfoResponse
+// - PackagesResponse
+
+syntax = "proto3";
+
+import "common.proto";
+
+package grpcagent;
+
+message Stack {
+  bool is_eval = 1;
+  string script_name = 2;
+  string function_name = 3;
+  int32 line_number = 4;
+  int32 column = 5;
+}
+
+message BlockedLoopBody {
+  int64 thread_id = 1;
+  int32 blocked_for = 2;
+  int32 loop_id = 3;
+  int32 callback_cntr = 4;
+  repeated Stack stack = 5;
+}
+
+message BlockedLoopEvent {
+  CommonResponse common = 1;
+  BlockedLoopBody body = 2;
+}
+
+message UnblockedLoopBody {
+  int64 thread_id = 1;
+  int32 blocked_for = 2;
+  int32 loop_id = 3;
+  int32 callback_cntr = 4;
+}
+
+message UnblockedLoopEvent {
+  CommonResponse common = 1;
+  UnblockedLoopBody body = 2;
+}

agents/grpc/proto/command.proto

@@ -0,0 +1,30 @@
+// I want to define here RuntimeResponse message which will be oneOf many other types of messages
+// For example:
+// - InfoResponse
+// - PackagesResponse
+
+syntax = "proto3";
+
+import "cpu_profile.proto";
+import "reconfigure.proto";
+
+package grpcagent;
+
+message CommandArgs {
+  oneof args {
+    ReconfigureBody reconfigure = 1;
+    CPUProfileArgs cpu_profile = 2;
+  }
+}
+
+message CommandRequest {
+  string requestId = 1;
+  uint32 version = 2;
+  string id = 3;
+  string command = 4;
+  CommandArgs args = 5;
+}
+
+message CommandResponse {
+  string error_message = 1;
+}

agents/grpc/proto/common.proto

@@ -0,0 +1,14 @@
+syntax = "proto3";
+
+package grpcagent;
+
+message Time {
+  uint64 seconds = 1;
+  uint64 nanoseconds = 2;
+}
+
+message CommonResponse {
+  string requestId = 1;
+  string command = 2;
+  Time recorded = 3;
+}

agents/grpc/proto/cpu_profile.proto

@@ -0,0 +1,11 @@
+syntax = "proto3";
+
+// import "common.proto";
+
+package grpcagent;
+
+message CPUProfileArgs {
+  uint64 thread_id = 1;
+  uint64 duration = 2;
+  map<string, string> metadata = 3;
+}

agents/grpc/proto/info.proto

@@ -0,0 +1,28 @@
+syntax = "proto3";
+
+import "common.proto";
+
+package grpcagent;
+
+message InfoBody {
+  string app = 1;
+  string arch = 2;
+  uint32 cpuCores = 3;
+  string cpuModel = 4;
+  string execPath = 5;
+  string hostname = 6;
+  string id = 7;
+  string main = 8;
+  string nodeEnv = 9;
+  uint32 pid = 10;
+  string platform = 11;
+  uint64 processStart = 12;
+  repeated string tags = 13;
+  uint64 totalMem = 14;
+  map<string, string> versions = 15;
+}
+
+message InfoEvent {
+  CommonResponse common = 1;
+  InfoBody body = 2;
+}

agents/grpc/proto/nsolid_service.proto

@@ -0,0 +1,24 @@
+syntax = "proto3";
+
+import "asset.proto";
+import "blocked_loop.proto";
+import "command.proto";
+import "info.proto";
+import "packages.proto";
+import "reconfigure.proto";
+
+package grpcagent;
+
+service NSolidService {
+  rpc Command (stream CommandResponse) returns (stream CommandRequest) {}
+  rpc ExportAsset (stream Asset) returns (EventResponse) {}
+  rpc ExportInfo (InfoEvent) returns (EventResponse) {}
+  rpc ExportPackages (PackagesEvent) returns (EventResponse) {}
+  rpc ExportBlockedLoop (BlockedLoopEvent) returns (EventResponse) {}
+  rpc ExportUnblockedLoop (UnblockedLoopEvent) returns (EventResponse) {}
+  rpc ExportReconfigure (ReconfigureEvent) returns (EventResponse) {}
+}
+
+message EventResponse {
+  string error_message = 1;
+}

agents/grpc/proto/packages.proto

@@ -0,0 +1,28 @@
+// I want to define here RuntimeResponse message which will be oneOf many other types of messages
+// For example:
+// - InfoResponse
+// - PackagesResponse
+
+syntax = "proto3";
+
+import "common.proto";
+
+package grpcagent;
+
+message PackagesEvent {
+  CommonResponse common = 1;
+  PackagesBody body = 2;
+}
+
+message PackagesBody {
+  repeated Package packages = 1;
+}
+
+message Package {
+  string path = 1;
+  string name = 2;
+  string version = 3;
+  string main = 4;
+  repeated string dependencies = 5;
+  bool required = 6;
+}

agents/grpc/proto/reconfigure.proto

@@ -0,0 +1,24 @@
+syntax = "proto3";
+
+import "common.proto";
+
+package grpcagent;
+
+message ReconfigureBody {
+  optional uint64 blockedLoopThreshold = 1;
+  optional uint64 interval = 2;
+  optional bool pauseMetrics = 3;
+  optional bool promiseTracking = 4;
+  optional bool redactSnapshots = 5;
+  optional string statsd = 6;
+  optional string statsdBucket = 7;
+  optional string statsdTags = 8;
+  repeated string tags = 9;
+  optional bool tracingEnabled = 10;
+  optional uint32 tracingModulesBlacklist = 11;
+}
+
+message ReconfigureEvent {
+  CommonResponse common = 1;
+  ReconfigureBody body = 2;
+}