gateway_pb.rb in zeebe-client-0.3.0

- old
+ new

@@ -2,77 +2,43 @@
 # source: proto/gateway.proto
 
 require 'google/protobuf'
 
 Google::Protobuf::DescriptorPool.generated_pool.build do
-  add_message "gateway_protocol.TopologyRequest" do
+  add_message "gateway_protocol.ActivateJobsRequest" do
+    optional :type, :string, 1
+    optional :worker, :string, 2
+    optional :timeout, :int64, 3
+    optional :amount, :int32, 4
+    repeated :fetchVariable, :string, 5
   end
-  add_message "gateway_protocol.Partition" do
-    optional :partitionId, :int32, 1
-    optional :role, :enum, 3, "gateway_protocol.Partition.PartitionBrokerRole"
+  add_message "gateway_protocol.ActivateJobsResponse" do
+    repeated :jobs, :message, 1, "gateway_protocol.ActivatedJob"
   end
-  add_enum "gateway_protocol.Partition.PartitionBrokerRole" do
-    value :LEADER, 0
-    value :FOLLOWER, 1
-  end
-  add_message "gateway_protocol.BrokerInfo" do
-    optional :nodeId, :int32, 1
-    optional :host, :string, 2
-    optional :port, :int32, 3
-    repeated :partitions, :message, 4, "gateway_protocol.Partition"
-  end
-  add_message "gateway_protocol.TopologyResponse" do
-    repeated :brokers, :message, 1, "gateway_protocol.BrokerInfo"
-    optional :clusterSize, :int32, 2
-    optional :partitionsCount, :int32, 3
-    optional :replicationFactor, :int32, 4
-  end
-  add_message "gateway_protocol.WorkflowRequestObject" do
-    optional :name, :string, 1
-    optional :type, :enum, 2, "gateway_protocol.WorkflowRequestObject.ResourceType"
-    optional :definition, :bytes, 3
-  end
-  add_enum "gateway_protocol.WorkflowRequestObject.ResourceType" do
-    value :FILE, 0
-    value :BPMN, 1
-    value :YAML, 2
-  end
-  add_message "gateway_protocol.DeployWorkflowRequest" do
-    repeated :workflows, :message, 1, "gateway_protocol.WorkflowRequestObject"
-  end
-  add_message "gateway_protocol.WorkflowMetadata" do
-    optional :bpmnProcessId, :string, 1
-    optional :version, :int32, 2
-    optional :workflowKey, :int64, 3
-    optional :resourceName, :string, 4
-  end
-  add_message "gateway_protocol.DeployWorkflowResponse" do
+  add_message "gateway_protocol.ActivatedJob" do
     optional :key, :int64, 1
-    repeated :workflows, :message, 2, "gateway_protocol.WorkflowMetadata"
+    optional :type, :string, 2
+    optional :jobHeaders, :message, 3, "gateway_protocol.JobHeaders"
+    optional :customHeaders, :string, 4
+    optional :worker, :string, 5
+    optional :retries, :int32, 6
+    optional :deadline, :int64, 7
+    optional :payload, :string, 8
   end
-  add_message "gateway_protocol.PublishMessageRequest" do
-    optional :name, :string, 1
-    optional :correlationKey, :string, 2
-    optional :timeToLive, :int64, 3
-    optional :messageId, :string, 4
-    optional :payload, :string, 5
+  add_message "gateway_protocol.JobHeaders" do
+    optional :workflowInstanceKey, :int64, 1
+    optional :bpmnProcessId, :string, 2
+    optional :workflowDefinitionVersion, :int32, 3
+    optional :workflowKey, :int64, 4
+    optional :elementId, :string, 5
+    optional :elementInstanceKey, :int64, 6
   end
-  add_message "gateway_protocol.PublishMessageResponse" do
+  add_message "gateway_protocol.CancelWorkflowInstanceRequest" do
+    optional :workflowInstanceKey, :int64, 1
   end
-  add_message "gateway_protocol.UpdateJobRetriesRequest" do
-    optional :jobKey, :int64, 1
-    optional :retries, :int32, 2
+  add_message "gateway_protocol.CancelWorkflowInstanceResponse" do
   end
-  add_message "gateway_protocol.UpdateJobRetriesResponse" do
-  end
-  add_message "gateway_protocol.FailJobRequest" do
-    optional :jobKey, :int64, 1
-    optional :retries, :int32, 2
-    optional :errorMessage, :string, 3
-  end
-  add_message "gateway_protocol.FailJobResponse" do
-  end
   add_message "gateway_protocol.CompleteJobRequest" do
     optional :jobKey, :int64, 1
     optional :payload, :string, 2
   end
   add_message "gateway_protocol.CompleteJobResponse" do
@@ -87,27 +53,40 @@
     optional :workflowKey, :int64, 1
     optional :bpmnProcessId, :string, 2
     optional :version, :int32, 3
     optional :workflowInstanceKey, :int64, 5
   end
-  add_message "gateway_protocol.CancelWorkflowInstanceRequest" do
-    optional :workflowInstanceKey, :int64, 1
+  add_message "gateway_protocol.DeployWorkflowRequest" do
+    repeated :workflows, :message, 1, "gateway_protocol.WorkflowRequestObject"
   end
-  add_message "gateway_protocol.CancelWorkflowInstanceResponse" do
+  add_message "gateway_protocol.WorkflowRequestObject" do
+    optional :name, :string, 1
+    optional :type, :enum, 2, "gateway_protocol.WorkflowRequestObject.ResourceType"
+    optional :definition, :bytes, 3
   end
-  add_message "gateway_protocol.UpdateWorkflowInstancePayloadRequest" do
-    optional :elementInstanceKey, :int64, 1
-    optional :payload, :string, 2
+  add_enum "gateway_protocol.WorkflowRequestObject.ResourceType" do
+    value :FILE, 0
+    value :BPMN, 1
+    value :YAML, 2
   end
-  add_message "gateway_protocol.UpdateWorkflowInstancePayloadResponse" do
+  add_message "gateway_protocol.DeployWorkflowResponse" do
+    optional :key, :int64, 1
+    repeated :workflows, :message, 2, "gateway_protocol.WorkflowMetadata"
   end
-  add_message "gateway_protocol.ListWorkflowsRequest" do
+  add_message "gateway_protocol.WorkflowMetadata" do
     optional :bpmnProcessId, :string, 1
+    optional :version, :int32, 2
+    optional :workflowKey, :int64, 3
+    optional :resourceName, :string, 4
   end
-  add_message "gateway_protocol.ListWorkflowsResponse" do
-    repeated :workflows, :message, 1, "gateway_protocol.WorkflowMetadata"
+  add_message "gateway_protocol.FailJobRequest" do
+    optional :jobKey, :int64, 1
+    optional :retries, :int32, 2
+    optional :errorMessage, :string, 3
   end
+  add_message "gateway_protocol.FailJobResponse" do
+  end
   add_message "gateway_protocol.GetWorkflowRequest" do
     optional :workflowKey, :int64, 1
     optional :version, :int32, 2
     optional :bpmnProcessId, :string, 3
   end
@@ -116,75 +95,97 @@
     optional :version, :int32, 2
     optional :bpmnProcessId, :string, 3
     optional :resourceName, :string, 4
     optional :bpmnXml, :string, 5
   end
-  add_message "gateway_protocol.ActivateJobsRequest" do
-    optional :type, :string, 1
-    optional :worker, :string, 2
-    optional :timeout, :int64, 3
-    optional :amount, :int32, 4
+  add_message "gateway_protocol.ListWorkflowsRequest" do
+    optional :bpmnProcessId, :string, 1
   end
-  add_message "gateway_protocol.JobHeaders" do
-    optional :workflowInstanceKey, :int64, 1
-    optional :bpmnProcessId, :string, 2
-    optional :workflowDefinitionVersion, :int32, 3
-    optional :workflowKey, :int64, 4
-    optional :elementId, :string, 5
-    optional :elementInstanceKey, :int64, 6
+  add_message "gateway_protocol.ListWorkflowsResponse" do
+    repeated :workflows, :message, 1, "gateway_protocol.WorkflowMetadata"
   end
-  add_message "gateway_protocol.ActivatedJob" do
-    optional :key, :int64, 1
-    optional :type, :string, 2
-    optional :jobHeaders, :message, 3, "gateway_protocol.JobHeaders"
-    optional :customHeaders, :string, 4
-    optional :worker, :string, 5
-    optional :retries, :int32, 6
-    optional :deadline, :int64, 7
-    optional :payload, :string, 8
+  add_message "gateway_protocol.PublishMessageRequest" do
+    optional :name, :string, 1
+    optional :correlationKey, :string, 2
+    optional :timeToLive, :int64, 3
+    optional :messageId, :string, 4
+    optional :payload, :string, 5
   end
-  add_message "gateway_protocol.ActivateJobsResponse" do
-    repeated :jobs, :message, 1, "gateway_protocol.ActivatedJob"
+  add_message "gateway_protocol.PublishMessageResponse" do
   end
   add_message "gateway_protocol.ResolveIncidentRequest" do
     optional :incidentKey, :int64, 1
   end
   add_message "gateway_protocol.ResolveIncidentResponse" do
   end
+  add_message "gateway_protocol.TopologyRequest" do
+  end
+  add_message "gateway_protocol.TopologyResponse" do
+    repeated :brokers, :message, 1, "gateway_protocol.BrokerInfo"
+    optional :clusterSize, :int32, 2
+    optional :partitionsCount, :int32, 3
+    optional :replicationFactor, :int32, 4
+  end
+  add_message "gateway_protocol.BrokerInfo" do
+    optional :nodeId, :int32, 1
+    optional :host, :string, 2
+    optional :port, :int32, 3
+    repeated :partitions, :message, 4, "gateway_protocol.Partition"
+  end
+  add_message "gateway_protocol.Partition" do
+    optional :partitionId, :int32, 1
+    optional :role, :enum, 3, "gateway_protocol.Partition.PartitionBrokerRole"
+  end
+  add_enum "gateway_protocol.Partition.PartitionBrokerRole" do
+    value :LEADER, 0
+    value :FOLLOWER, 1
+  end
+  add_message "gateway_protocol.UpdateJobRetriesRequest" do
+    optional :jobKey, :int64, 1
+    optional :retries, :int32, 2
+  end
+  add_message "gateway_protocol.UpdateJobRetriesResponse" do
+  end
+  add_message "gateway_protocol.UpdateWorkflowInstancePayloadRequest" do
+    optional :elementInstanceKey, :int64, 1
+    optional :payload, :string, 2
+  end
+  add_message "gateway_protocol.UpdateWorkflowInstancePayloadResponse" do
+  end
 end
 
 module Zeebe::Client::GatewayProtocol
-  TopologyRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.TopologyRequest").msgclass
-  Partition = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.Partition").msgclass
-  Partition::PartitionBrokerRole = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.Partition.PartitionBrokerRole").enummodule
-  BrokerInfo = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.BrokerInfo").msgclass
-  TopologyResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.TopologyResponse").msgclass
+  ActivateJobsRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ActivateJobsRequest").msgclass
+  ActivateJobsResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ActivateJobsResponse").msgclass
+  ActivatedJob = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ActivatedJob").msgclass
+  JobHeaders = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.JobHeaders").msgclass
+  CancelWorkflowInstanceRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CancelWorkflowInstanceRequest").msgclass
+  CancelWorkflowInstanceResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CancelWorkflowInstanceResponse").msgclass
+  CompleteJobRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CompleteJobRequest").msgclass
+  CompleteJobResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CompleteJobResponse").msgclass
+  CreateWorkflowInstanceRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CreateWorkflowInstanceRequest").msgclass
+  CreateWorkflowInstanceResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CreateWorkflowInstanceResponse").msgclass
+  DeployWorkflowRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.DeployWorkflowRequest").msgclass
   WorkflowRequestObject = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.WorkflowRequestObject").msgclass
   WorkflowRequestObject::ResourceType = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.WorkflowRequestObject.ResourceType").enummodule
-  DeployWorkflowRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.DeployWorkflowRequest").msgclass
-  WorkflowMetadata = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.WorkflowMetadata").msgclass
   DeployWorkflowResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.DeployWorkflowResponse").msgclass
-  PublishMessageRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.PublishMessageRequest").msgclass
-  PublishMessageResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.PublishMessageResponse").msgclass
-  UpdateJobRetriesRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.UpdateJobRetriesRequest").msgclass
-  UpdateJobRetriesResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.UpdateJobRetriesResponse").msgclass
+  WorkflowMetadata = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.WorkflowMetadata").msgclass
   FailJobRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.FailJobRequest").msgclass
   FailJobResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.FailJobResponse").msgclass
-  CompleteJobRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CompleteJobRequest").msgclass
-  CompleteJobResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CompleteJobResponse").msgclass
-  CreateWorkflowInstanceRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CreateWorkflowInstanceRequest").msgclass
-  CreateWorkflowInstanceResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CreateWorkflowInstanceResponse").msgclass
-  CancelWorkflowInstanceRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CancelWorkflowInstanceRequest").msgclass
-  CancelWorkflowInstanceResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.CancelWorkflowInstanceResponse").msgclass
-  UpdateWorkflowInstancePayloadRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.UpdateWorkflowInstancePayloadRequest").msgclass
-  UpdateWorkflowInstancePayloadResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.UpdateWorkflowInstancePayloadResponse").msgclass
-  ListWorkflowsRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ListWorkflowsRequest").msgclass
-  ListWorkflowsResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ListWorkflowsResponse").msgclass
   GetWorkflowRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.GetWorkflowRequest").msgclass
   GetWorkflowResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.GetWorkflowResponse").msgclass
-  ActivateJobsRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ActivateJobsRequest").msgclass
-  JobHeaders = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.JobHeaders").msgclass
-  ActivatedJob = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ActivatedJob").msgclass
-  ActivateJobsResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ActivateJobsResponse").msgclass
+  ListWorkflowsRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ListWorkflowsRequest").msgclass
+  ListWorkflowsResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ListWorkflowsResponse").msgclass
+  PublishMessageRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.PublishMessageRequest").msgclass
+  PublishMessageResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.PublishMessageResponse").msgclass
   ResolveIncidentRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ResolveIncidentRequest").msgclass
   ResolveIncidentResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.ResolveIncidentResponse").msgclass
+  TopologyRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.TopologyRequest").msgclass
+  TopologyResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.TopologyResponse").msgclass
+  BrokerInfo = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.BrokerInfo").msgclass
+  Partition = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.Partition").msgclass
+  Partition::PartitionBrokerRole = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.Partition.PartitionBrokerRole").enummodule
+  UpdateJobRetriesRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.UpdateJobRetriesRequest").msgclass
+  UpdateJobRetriesResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.UpdateJobRetriesResponse").msgclass
+  UpdateWorkflowInstancePayloadRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.UpdateWorkflowInstancePayloadRequest").msgclass
+  UpdateWorkflowInstancePayloadResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("gateway_protocol.UpdateWorkflowInstancePayloadResponse").msgclass
 end