incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [2/5] Thrift generated code updates.
Date Fri, 31 Oct 2014 14:37:11 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/0238b4a9/distribution/src/main/scripts/interface/gen-rb/blur.rb
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-rb/blur.rb b/distribution/src/main/scripts/interface/gen-rb/blur.rb
index 126cb59..706ff09 100644
--- a/distribution/src/main/scripts/interface/gen-rb/blur.rb
+++ b/distribution/src/main/scripts/interface/gen-rb/blur.rb
@@ -45,13 +45,13 @@ module Blur
         raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT,
'execute failed: unknown result')
       end
 
-      def reconnect(executionId)
-        send_reconnect(executionId)
+      def reconnect(instanceExecutionId)
+        send_reconnect(instanceExecutionId)
         return recv_reconnect()
       end
 
-      def send_reconnect(executionId)
-        send_message('reconnect', Reconnect_args, :executionId => executionId)
+      def send_reconnect(instanceExecutionId)
+        send_message('reconnect', Reconnect_args, :instanceExecutionId => instanceExecutionId)
       end
 
       def recv_reconnect()
@@ -78,13 +78,13 @@ module Blur
         raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT,
'commandStatusList failed: unknown result')
       end
 
-      def commandStatus(executionId)
-        send_commandStatus(executionId)
+      def commandStatus(commandExecutionId)
+        send_commandStatus(commandExecutionId)
         return recv_commandStatus()
       end
 
-      def send_commandStatus(executionId)
-        send_message('commandStatus', CommandStatus_args, :executionId => executionId)
+      def send_commandStatus(commandExecutionId)
+        send_message('commandStatus', CommandStatus_args, :commandExecutionId => commandExecutionId)
       end
 
       def recv_commandStatus()
@@ -94,13 +94,13 @@ module Blur
         raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT,
'commandStatus failed: unknown result')
       end
 
-      def commandCancel(executionId)
-        send_commandCancel(executionId)
+      def commandCancel(commandExecutionId)
+        send_commandCancel(commandExecutionId)
         recv_commandCancel()
       end
 
-      def send_commandCancel(executionId)
-        send_message('commandCancel', CommandCancel_args, :executionId => executionId)
+      def send_commandCancel(commandExecutionId)
+        send_message('commandCancel', CommandCancel_args, :commandExecutionId => commandExecutionId)
       end
 
       def recv_commandCancel()
@@ -818,7 +818,7 @@ module Blur
         args = read_args(iprot, Reconnect_args)
         result = Reconnect_result.new()
         begin
-          result.success = @handler.reconnect(args.executionId)
+          result.success = @handler.reconnect(args.instanceExecutionId)
         rescue ::Blur::BlurException => bex
           result.bex = bex
         rescue ::Blur::TimeoutException => tex
@@ -842,7 +842,7 @@ module Blur
         args = read_args(iprot, CommandStatus_args)
         result = CommandStatus_result.new()
         begin
-          result.success = @handler.commandStatus(args.executionId)
+          result.success = @handler.commandStatus(args.commandExecutionId)
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
@@ -853,7 +853,7 @@ module Blur
         args = read_args(iprot, CommandCancel_args)
         result = CommandCancel_result.new()
         begin
-          @handler.commandCancel(args.executionId)
+          @handler.commandCancel(args.commandExecutionId)
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
@@ -1413,10 +1413,10 @@ module Blur
 
     class Reconnect_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      EXECUTIONID = 1
+      INSTANCEEXECUTIONID = 1
 
       FIELDS = {
-        EXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'executionId'}
+        INSTANCEEXECUTIONID => {:type => ::Thrift::Types::I64, :name => 'instanceExecutionId'}
       }
 
       def struct_fields; FIELDS; end
@@ -1490,10 +1490,10 @@ module Blur
 
     class CommandStatus_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      EXECUTIONID = 1
+      COMMANDEXECUTIONID = 1
 
       FIELDS = {
-        EXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'executionId'}
+        COMMANDEXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'commandExecutionId'}
       }
 
       def struct_fields; FIELDS; end
@@ -1524,10 +1524,10 @@ module Blur
 
     class CommandCancel_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      EXECUTIONID = 1
+      COMMANDEXECUTIONID = 1
 
       FIELDS = {
-        EXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'executionId'}
+        COMMANDEXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'commandExecutionId'}
       }
 
       def struct_fields; FIELDS; end

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/0238b4a9/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-rb/blur_types.rb b/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
index dedac6c..1a824fc 100644
--- a/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
+++ b/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
@@ -132,17 +132,10 @@ module Blur
 # happens so that the client can reconnect.
   class TimeoutException < ::Thrift::Exception
     include ::Thrift::Struct, ::Thrift::Struct_Union
-    def initialize(message=nil)
-      super()
-      self.executionId = message
-    end
-
-    def message; executionId end
-
-    EXECUTIONID = 1
+    INSTANCEEXECUTIONID = 1
 
     FIELDS = {
-      EXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'executionId'}
+      INSTANCEEXECUTIONID => {:type => ::Thrift::Types::I64, :name => 'instanceExecutionId'}
     }
 
     def struct_fields; FIELDS; end

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/0238b4a9/docs/Blur.html
----------------------------------------------------------------------
diff --git a/docs/Blur.html b/docs/Blur.html
index 121e460..ab7b47d 100644
--- a/docs/Blur.html
+++ b/docs/Blur.html
@@ -309,7 +309,7 @@ Logging level enum used to change the logging levels at runtime.
 trace (if any).
 <br/></p></section><section><div class="page-header"><h3
id="Struct_TimeoutException">Exception: TimeoutException</h3></div><p class="lead">
 <table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default
value</th></thead>
-<tr><td>1</td><td>executionId</td><td><code>string</code></td><td></td><td>default</td><td></td></tr>
+<tr><td>1</td><td>instanceExecutionId</td><td><code>i64</code></td><td></td><td>default</td><td></td></tr>
 </table><br/>TimeoutException occurs before the network connection timeout
 happens so that the client can reconnect.
 <br/></p></section><section><div class="page-header"><h3
id="Struct_User">Struct: User</h3></div><p class="lead">
@@ -742,7 +742,7 @@ throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
 throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>,
<code><a href="Blur.html#Struct_TimeoutException">TimeoutException</a></code>
 </pre>Executes the given command by name on the table with the provided arguments.
 <br/></p></section><section><div class="page-header"><h4
id="Fn_Blur_reconnect">Function: Blur.reconnect</h4></div><p class="lead">
-<pre><code><a href="Blur.html#Struct_Response">Response</a></code>
reconnect(<code>string</code> executionId)
+<pre><code><a href="Blur.html#Struct_Response">Response</a></code>
reconnect(<code>i64</code> instanceExecutionId)
 throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>,
<code><a href="Blur.html#Struct_TimeoutException">TimeoutException</a></code>
 </pre>If the execute command times out due to command taking longer than the configured
 network tcp timeout this method allows the client to reconnect to the already
@@ -754,13 +754,13 @@ executing command.
 throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
 </pre>Fetches the command status ids in the order they were submitted.
 <br/></p></section><section><div class="page-header"><h4
id="Fn_Blur_commandStatus">Function: Blur.commandStatus</h4></div><p class="lead">
-<pre><code><a href="Blur.html#Struct_CommandStatus">CommandStatus</a></code>
commandStatus(<code>string</code> executionId)
+<pre><code><a href="Blur.html#Struct_CommandStatus">CommandStatus</a></code>
commandStatus(<code>string</code> commandExecutionId)
 throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
-</pre>Retrieves the command status by the given execution id.
+</pre>Retrieves the command status by the given command execution id.
 <br/></p></section><section><div class="page-header"><h4
id="Fn_Blur_commandCancel">Function: Blur.commandCancel</h4></div><p class="lead">
-<pre><code>void</code> commandCancel(<code>string</code> executionId)
+<pre><code>void</code> commandCancel(<code>string</code> commandExecutionId)
 throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
-</pre>Cancels the command with the given execution id.
+</pre>Cancels the command with the given command execution id.
 <br/></p></section><section><div class="page-header"><h4
id="Fn_Blur_refresh">Function: Blur.refresh</h4></div><p class="lead">
 <pre><code>void</code> refresh()
 </pre>Releases and refreshes the read snapshots of the indexes in the session for the


Mime
View raw message