Merge pull request elastic#421 from Lucas-Caballero/go-dispatch-protos

Go dispatch protos

protofiles/ESDataMsg.proto

@@ -5,7 +5,6 @@ option java_outer_classname = "ESDataMsg";
 
 
 
-
 message ESData {
    enum RequestType {
       INSERT = 1;
@@ -21,4 +20,5 @@ message ESData {
    optional string json = 7;
    optional RequestType requestType = 8;
    optional bool shouldPercolate = 9;
+   optional string returnPath = 10;
 }

protofiles/anubis/Acknowledgements.proto

@@ -0,0 +1,8 @@
+package protoMsg;
+
+option java_package = "com.logrhythm.nm.message";
+option java_outer_classname = "AcknowledgementsMsg";
+
+message Acknowledgements {
+  repeated string ids = 1;
+}

protofiles/configelements/GoDispatchConfig.proto

@@ -0,0 +1,34 @@
+package configelements;
+
+option java_package = "com.logrhythm.configelements";
+option java_outer_classname = "GoDispatchConfigMsg";
+
+
+message GoDispatchConfig {
+
+  message Endpoint {
+    optional string protoHostAndPort = 1;
+    optional bool isOwner = 2;
+  }
+
+  message Stats {
+    optional string countKey = 1;
+    optional string failedKey = 2;
+    optional string finishedKey = 3;
+    optional string requestKey = 4;
+    optional string retryKey = 5;
+  }
+
+  optional Endpoint inputQueue = 1;
+  optional Endpoint confirmQueue = 2;
+  optional Stats stats = 3;
+
+  optional int32 batchingReportPeriodSec = 4;
+  optional int32 receiveLogTimeoutMs = 5;
+  optional int32 batchingCapturePeriodMs = 6;
+  optional int32 maxBatchSize = 7;
+  optional int32 maxInFlightBatches = 8;
+
+  optional bool sendToRecorder = 9;
+  optional int32 indexRetryBackoffDurationMs = 10;
+}