Merge pull request elastic#431 from Lucas-Caballero/fix-gd-protos

Updated go-dispatch protos to reflect discussions around endpoints.
harper-carroll · Oct 27, 2015 · cf1dfbd · cf1dfbd
2 parents fdf59ef + 147328d
commit cf1dfbd
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 9 deletions.
diff --git a/protofiles/configelements/GoDispatchClientConfig.proto b/protofiles/configelements/GoDispatchClientConfig.proto
@@ -6,5 +6,4 @@ option java_outer_classname = "GoDispatchClientConfigMsg";
 
 message GoDispatchClientConfig {
   optional string batchingQueue = 1;
-  optional int32 batchingQueueSize = 2;
 }
diff --git a/protofiles/configelements/GoDispatchConfig.proto b/protofiles/configelements/GoDispatchConfig.proto
@@ -15,17 +15,20 @@ message GoDispatchConfig {
   }
 
   message Endpoint {
-
+    optional string queue = 1;
+    optional int32 queueSize = 2;
+    optional bool isOwner = 3;
   }
 
   optional Stats stats = 1;
+  optional Endpoint inputQueue = 2;
 
-  optional int32 batchingReportPeriodSec = 2;
-  optional int32 receiveLogTimeoutMs = 3;
-  optional int32 batchingCapturePeriodMs = 4;
-  optional int32 maxBatchSize = 5;
-  optional int32 maxInFlightBatches = 6;
+  optional int32 batchingReportPeriodSec = 3;
+  optional int32 receiveLogTimeoutMs = 4;
+  optional int32 batchingCapturePeriodMs = 5;
+  optional int32 maxBatchSize = 6;
+  optional int32 maxInFlightBatches = 7;
 
-  optional bool sendToRecorder = 7;
-  optional int32 indexRetryBackoffDurationMs = 8;
+  optional bool sendToRecorder = 8;
+  optional int32 indexRetryBackoffDurationMs = 9;
 }