Merge pull request elastic#436 from Tom-Artale/config-update-anubis-g…

…odispatch In-process creating beans
harper-carroll · Oct 28, 2015 · 59546f3 · 59546f3
2 parents 4188ef8 + 8f6b597
commit 59546f3
Show file tree

Hide file tree

Showing 4 changed files with 37 additions and 4 deletions.
diff --git a/protofiles/configelements/AnubisConfig.proto b/protofiles/configelements/AnubisConfig.proto
@@ -17,8 +17,8 @@ message AnubisConfig {
    }
 
    message RelayConfig {
-      optional string mediatorQueue = 1; 
-      optional int32 mediatorQueueSize = 2;
+      optional string inputQueue = 1; 
+      optional int32 inputQueueSize = 2;
       optional int32 timeoutReceiveMs = 3;
    }
 

diff --git a/protofiles/configelements/ConfigType.proto b/protofiles/configelements/ConfigType.proto
@@ -32,9 +32,9 @@ message ConfigTypeMsg {
       ClusterNodeConfig = 21;
       ElasticSearchServerConfig = 22;
       HeartThrobConfig = 23;
-      AnubisConfig = 24;
+//      AnubisConfig = 24;
       AnubisClientConfig = 25;
       GoDispatchConfig = 26;
-      GoDispatchClientConfig = 27;
+//      GoDispatchClientConfig = 27;
    }
 }
diff --git a/protofiles/configelements/ux/AnubisClientConfigUX.proto b/protofiles/configelements/ux/AnubisClientConfigUX.proto
@@ -0,0 +1,13 @@
+package configelements.ux;
+
+import "ConfigUX.proto";
+
+option java_package = "com.logrhythm.configelements.ux";
+option java_outer_classname = "AnubisClientConfigUXMsg";
+
+message AnubisClientConfigUX {
+
+   optional ConfigUX inputQueue = 1;
+   optional ConfigUX ackQueue = 2;
+
+}
diff --git a/protofiles/configelements/ux/GoDispatchConfigUX.proto b/protofiles/configelements/ux/GoDispatchConfigUX.proto
@@ -0,0 +1,20 @@
+package configelements.ux;
+
+import "ConfigUX.proto";
+
+option java_package = "com.logrhythm.configelements.ux";
+option java_outer_classname = "GoDispatchConfigUXMsg";
+
+
+message GoDispatchConfigUX {
+
+  message Endpoint {
+    optional ConfigUX queue = 1;
+    optional ConfigUX queueSize = 2;
+  }
+
+  optional Endpoint inputQueue = 1;
+  optional ConfigUX receiveLogTimeoutMs = 2;
+  optional ConfigUX maxInFlightBatches = 3;
+  optional ConfigUX sendToRecorder = 4;
+}