streaming_pb.rb in google-cloud-dataflow-v1beta3-0.6.0

- old
+ new
@@ -1,85 +1,35 @@
+# frozen_string_literal: true
 # Generated by the protocol buffer compiler.  DO NOT EDIT!
 # source: google/dataflow/v1beta3/streaming.proto
 
 require 'google/protobuf'
 
-Google::Protobuf::DescriptorPool.generated_pool.build do
-  add_file("google/dataflow/v1beta3/streaming.proto", :syntax => :proto3) do
-    add_message "google.dataflow.v1beta3.TopologyConfig" do
-      repeated :computations, :message, 1, "google.dataflow.v1beta3.ComputationTopology"
-      repeated :data_disk_assignments, :message, 2, "google.dataflow.v1beta3.DataDiskAssignment"
-      map :user_stage_to_computation_name_map, :string, :string, 3
-      optional :forwarding_key_bits, :int32, 4
-      optional :persistent_state_version, :int32, 5
+
+descriptor_data = "\n\'google/dataflow/v1beta3/streaming.proto\x12\x17google.dataflow.v1beta3\"\x9d\x03\n\x0eTopologyConfig\x12\x42\n\x0c\x63omputations\x18\x01 \x03(\x0b\x32,.google.dataflow.v1beta3.ComputationTopology\x12J\n\x15\x64\x61ta_disk_assignments\x18\x02 \x03(\x0b\x32+.google.dataflow.v1beta3.DataDiskAssignment\x12v\n\"user_stage_to_computation_name_map\x18\x03 \x03(\x0b\x32J.google.dataflow.v1beta3.TopologyConfig.UserStageToComputationNameMapEntry\x12\x1b\n\x13\x66orwarding_key_bits\x18\x04 \x01(\x05\x12 \n\x18persistent_state_version\x18\x05 \x01(\x05\x1a\x44\n\"UserStageToComputationNameMapEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xb0\x01\n\x0ePubsubLocation\x12\r\n\x05topic\x18\x01 \x01(\t\x12\x14\n\x0csubscription\x18\x02 \x01(\t\x12\x17\n\x0ftimestamp_label\x18\x03 \x01(\t\x12\x10\n\x08id_label\x18\x04 \x01(\t\x12\x16\n\x0e\x64rop_late_data\x18\x05 \x01(\x08\x12\x1d\n\x15tracking_subscription\x18\x06 \x01(\t\x12\x17\n\x0fwith_attributes\x18\x07 \x01(\x08\"+\n\x16StreamingStageLocation\x12\x11\n\tstream_id\x18\x01 \x01(\t\"?\n\x1aStreamingSideInputLocation\x12\x0b\n\x03tag\x18\x01 \x01(\t\x12\x14\n\x0cstate_family\x18\x02 \x01(\t\"(\n\x14\x43ustomSourceLocation\x12\x10\n\x08stateful\x18\x01 \x01(\x08\"\xda\x02\n\x0eStreamLocation\x12S\n\x18streaming_stage_location\x18\x01 \x01(\x0b\x32/.google.dataflow.v1beta3.StreamingStageLocationH\x00\x12\x42\n\x0fpubsub_location\x18\x02 \x01(\x0b\x32\'.google.dataflow.v1beta3.PubsubLocationH\x00\x12R\n\x13side_input_location\x18\x03 \x01(\x0b\x32\x33.google.dataflow.v1beta3.StreamingSideInputLocationH\x00\x12O\n\x16\x63ustom_source_location\x18\x04 \x01(\x0b\x32-.google.dataflow.v1beta3.CustomSourceLocationH\x00\x42\n\n\x08location\":\n\x11StateFamilyConfig\x12\x14\n\x0cstate_family\x18\x01 \x01(\t\x12\x0f\n\x07is_read\x18\x02 \x01(\x08\"\xbe\x02\n\x13\x43omputationTopology\x12\x19\n\x11system_stage_name\x18\x01 \x01(\t\x12\x16\n\x0e\x63omputation_id\x18\x05 \x01(\t\x12=\n\nkey_ranges\x18\x02 \x03(\x0b\x32).google.dataflow.v1beta3.KeyRangeLocation\x12\x37\n\x06inputs\x18\x03 \x03(\x0b\x32\'.google.dataflow.v1beta3.StreamLocation\x12\x38\n\x07outputs\x18\x04 \x03(\x0b\x32\'.google.dataflow.v1beta3.StreamLocation\x12\x42\n\x0estate_families\x18\x07 \x03(\x0b\x32*.google.dataflow.v1beta3.StateFamilyConfig\"\x89\x01\n\x10KeyRangeLocation\x12\r\n\x05start\x18\x01 \x01(\t\x12\x0b\n\x03\x65nd\x18\x02 \x01(\t\x12\x19\n\x11\x64\x65livery_endpoint\x18\x03 \x01(\t\x12\x11\n\tdata_disk\x18\x05 \x01(\t\x12+\n\x1f\x64\x65precated_persistent_directory\x18\x04 \x01(\tB\x02\x18\x01\"$\n\x0fMountedDataDisk\x12\x11\n\tdata_disk\x18\x01 \x01(\t\"=\n\x12\x44\x61taDiskAssignment\x12\x13\n\x0bvm_instance\x18\x01 \x01(\t\x12\x12\n\ndata_disks\x18\x02 \x03(\t\"K\n\x1aKeyRangeDataDiskAssignment\x12\r\n\x05start\x18\x01 \x01(\t\x12\x0b\n\x03\x65nd\x18\x02 \x01(\t\x12\x11\n\tdata_disk\x18\x03 \x01(\t\"\x84\x01\n\x1aStreamingComputationRanges\x12\x16\n\x0e\x63omputation_id\x18\x01 \x01(\t\x12N\n\x11range_assignments\x18\x02 \x03(\x0b\x32\x33.google.dataflow.v1beta3.KeyRangeDataDiskAssignment\"V\n StreamingApplianceSnapshotConfig\x12\x13\n\x0bsnapshot_id\x18\x01 \x01(\t\x12\x1d\n\x15import_state_endpoint\x18\x02 \x01(\tB\xd1\x01\n\x1b\x63om.google.dataflow.v1beta3B\x0eStreamingProtoP\x01Z=cloud.google.com/go/dataflow/apiv1beta3/dataflowpb;dataflowpb\xaa\x02\x1dGoogle.Cloud.Dataflow.V1Beta3\xca\x02\x1dGoogle\\Cloud\\Dataflow\\V1beta3\xea\x02 Google::Cloud::Dataflow::V1beta3b\x06proto3"
+
+pool = Google::Protobuf::DescriptorPool.generated_pool
+
+begin
+  pool.add_serialized_file(descriptor_data)
+rescue TypeError => e
+  # Compatibility code: will be removed in the next major version.
+  require 'google/protobuf/descriptor_pb'
+  parsed = Google::Protobuf::FileDescriptorProto.decode(descriptor_data)
+  parsed.clear_dependency
+  serialized = parsed.class.encode(parsed)
+  file = pool.add_serialized_file(serialized)
+  warn "Warning: Protobuf detected an import path issue while loading generated file #{__FILE__}"
+  imports = [
+  ]
+  imports.each do |type_name, expected_filename|
+    import_file = pool.lookup(type_name).file_descriptor
+    if import_file.name != expected_filename
+      warn "- #{file.name} imports #{expected_filename}, but that import was loaded as #{import_file.name}"
     end
-    add_message "google.dataflow.v1beta3.PubsubLocation" do
-      optional :topic, :string, 1
-      optional :subscription, :string, 2
-      optional :timestamp_label, :string, 3
-      optional :id_label, :string, 4
-      optional :drop_late_data, :bool, 5
-      optional :tracking_subscription, :string, 6
-      optional :with_attributes, :bool, 7
-    end
-    add_message "google.dataflow.v1beta3.StreamingStageLocation" do
-      optional :stream_id, :string, 1
-    end
-    add_message "google.dataflow.v1beta3.StreamingSideInputLocation" do
-      optional :tag, :string, 1
-      optional :state_family, :string, 2
-    end
-    add_message "google.dataflow.v1beta3.CustomSourceLocation" do
-      optional :stateful, :bool, 1
-    end
-    add_message "google.dataflow.v1beta3.StreamLocation" do
-      oneof :location do
-        optional :streaming_stage_location, :message, 1, "google.dataflow.v1beta3.StreamingStageLocation"
-        optional :pubsub_location, :message, 2, "google.dataflow.v1beta3.PubsubLocation"
-        optional :side_input_location, :message, 3, "google.dataflow.v1beta3.StreamingSideInputLocation"
-        optional :custom_source_location, :message, 4, "google.dataflow.v1beta3.CustomSourceLocation"
-      end
-    end
-    add_message "google.dataflow.v1beta3.StateFamilyConfig" do
-      optional :state_family, :string, 1
-      optional :is_read, :bool, 2
-    end
-    add_message "google.dataflow.v1beta3.ComputationTopology" do
-      optional :system_stage_name, :string, 1
-      optional :computation_id, :string, 5
-      repeated :key_ranges, :message, 2, "google.dataflow.v1beta3.KeyRangeLocation"
-      repeated :inputs, :message, 3, "google.dataflow.v1beta3.StreamLocation"
-      repeated :outputs, :message, 4, "google.dataflow.v1beta3.StreamLocation"
-      repeated :state_families, :message, 7, "google.dataflow.v1beta3.StateFamilyConfig"
-    end
-    add_message "google.dataflow.v1beta3.KeyRangeLocation" do
-      optional :start, :string, 1
-      optional :end, :string, 2
-      optional :delivery_endpoint, :string, 3
-      optional :data_disk, :string, 5
-      optional :deprecated_persistent_directory, :string, 4
-    end
-    add_message "google.dataflow.v1beta3.MountedDataDisk" do
-      optional :data_disk, :string, 1
-    end
-    add_message "google.dataflow.v1beta3.DataDiskAssignment" do
-      optional :vm_instance, :string, 1
-      repeated :data_disks, :string, 2
-    end
-    add_message "google.dataflow.v1beta3.KeyRangeDataDiskAssignment" do
-      optional :start, :string, 1
-      optional :end, :string, 2
-      optional :data_disk, :string, 3
-    end
-    add_message "google.dataflow.v1beta3.StreamingComputationRanges" do
-      optional :computation_id, :string, 1
-      repeated :range_assignments, :message, 2, "google.dataflow.v1beta3.KeyRangeDataDiskAssignment"
-    end
-    add_message "google.dataflow.v1beta3.StreamingApplianceSnapshotConfig" do
-      optional :snapshot_id, :string, 1
-      optional :import_state_endpoint, :string, 2
-    end
   end
+  warn "Each proto file must use a consistent fully-qualified name."
+  warn "This will become an error in the next major version."
 end
 
 module Google
   module Cloud
     module Dataflow