lib/google/dataflow/v1beta3/environment_pb.rb in google-cloud-dataflow-v1beta3-0.5.0 vs lib/google/dataflow/v1beta3/environment_pb.rb in google-cloud-dataflow-v1beta3-0.6.0
- old
+ new
@@ -1,147 +1,41 @@
+# frozen_string_literal: true
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: google/dataflow/v1beta3/environment.proto
require 'google/protobuf'
require 'google/api/field_behavior_pb'
require 'google/protobuf/any_pb'
require 'google/protobuf/struct_pb'
-Google::Protobuf::DescriptorPool.generated_pool.build do
- add_file("google/dataflow/v1beta3/environment.proto", :syntax => :proto3) do
- add_message "google.dataflow.v1beta3.Environment" do
- optional :temp_storage_prefix, :string, 1
- optional :cluster_manager_api_service, :string, 2
- repeated :experiments, :string, 3
- repeated :service_options, :string, 16
- optional :service_kms_key_name, :string, 12
- repeated :worker_pools, :message, 4, "google.dataflow.v1beta3.WorkerPool"
- optional :user_agent, :message, 5, "google.protobuf.Struct"
- optional :version, :message, 6, "google.protobuf.Struct"
- optional :dataset, :string, 7
- optional :sdk_pipeline_options, :message, 8, "google.protobuf.Struct"
- optional :internal_experiments, :message, 9, "google.protobuf.Any"
- optional :service_account_email, :string, 10
- optional :flex_resource_scheduling_goal, :enum, 11, "google.dataflow.v1beta3.FlexResourceSchedulingGoal"
- optional :worker_region, :string, 13
- optional :worker_zone, :string, 14
- optional :shuffle_mode, :enum, 15, "google.dataflow.v1beta3.ShuffleMode"
- optional :debug_options, :message, 17, "google.dataflow.v1beta3.DebugOptions"
+
+descriptor_data = "\n)google/dataflow/v1beta3/environment.proto\x12\x17google.dataflow.v1beta3\x1a\x1fgoogle/api/field_behavior.proto\x1a\x19google/protobuf/any.proto\x1a\x1cgoogle/protobuf/struct.proto\"\xcf\x05\n\x0b\x45nvironment\x12\x1b\n\x13temp_storage_prefix\x18\x01 \x01(\t\x12#\n\x1b\x63luster_manager_api_service\x18\x02 \x01(\t\x12\x13\n\x0b\x65xperiments\x18\x03 \x03(\t\x12\x17\n\x0fservice_options\x18\x10 \x03(\t\x12\x1c\n\x14service_kms_key_name\x18\x0c \x01(\t\x12\x39\n\x0cworker_pools\x18\x04 \x03(\x0b\x32#.google.dataflow.v1beta3.WorkerPool\x12+\n\nuser_agent\x18\x05 \x01(\x0b\x32\x17.google.protobuf.Struct\x12(\n\x07version\x18\x06 \x01(\x0b\x32\x17.google.protobuf.Struct\x12\x0f\n\x07\x64\x61taset\x18\x07 \x01(\t\x12\x35\n\x14sdk_pipeline_options\x18\x08 \x01(\x0b\x32\x17.google.protobuf.Struct\x12\x32\n\x14internal_experiments\x18\t \x01(\x0b\x32\x14.google.protobuf.Any\x12\x1d\n\x15service_account_email\x18\n \x01(\t\x12Z\n\x1d\x66lex_resource_scheduling_goal\x18\x0b \x01(\x0e\x32\x33.google.dataflow.v1beta3.FlexResourceSchedulingGoal\x12\x15\n\rworker_region\x18\r \x01(\t\x12\x13\n\x0bworker_zone\x18\x0e \x01(\t\x12?\n\x0cshuffle_mode\x18\x0f \x01(\x0e\x32$.google.dataflow.v1beta3.ShuffleModeB\x03\xe0\x41\x03\x12<\n\rdebug_options\x18\x11 \x01(\x0b\x32%.google.dataflow.v1beta3.DebugOptions\")\n\x07Package\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x10\n\x08location\x18\x02 \x01(\t\"?\n\x04\x44isk\x12\x0f\n\x07size_gb\x18\x01 \x01(\x05\x12\x11\n\tdisk_type\x18\x02 \x01(\t\x12\x13\n\x0bmount_point\x18\x03 \x01(\t\"\xa1\x01\n\x0eWorkerSettings\x12\x10\n\x08\x62\x61se_url\x18\x01 \x01(\t\x12\x19\n\x11reporting_enabled\x18\x02 \x01(\x08\x12\x14\n\x0cservice_path\x18\x03 \x01(\t\x12\x1c\n\x14shuffle_service_path\x18\x04 \x01(\t\x12\x11\n\tworker_id\x18\x05 \x01(\t\x12\x1b\n\x13temp_storage_prefix\x18\x06 \x01(\t\"\xa4\x04\n\x12TaskRunnerSettings\x12\x11\n\ttask_user\x18\x01 \x01(\t\x12\x12\n\ntask_group\x18\x02 \x01(\t\x12\x14\n\x0coauth_scopes\x18\x03 \x03(\t\x12\x10\n\x08\x62\x61se_url\x18\x04 \x01(\t\x12\x1c\n\x14\x64\x61taflow_api_version\x18\x05 \x01(\t\x12I\n\x18parallel_worker_settings\x18\x06 \x01(\x0b\x32\'.google.dataflow.v1beta3.WorkerSettings\x12\x15\n\rbase_task_dir\x18\x07 \x01(\t\x12\x1d\n\x15\x63ontinue_on_exception\x18\x08 \x01(\x08\x12\x1c\n\x14log_to_serialconsole\x18\t \x01(\x08\x12\x17\n\x0f\x61lsologtostderr\x18\n \x01(\x08\x12\x1b\n\x13log_upload_location\x18\x0b \x01(\t\x12\x0f\n\x07log_dir\x18\x0c \x01(\t\x12\x1b\n\x13temp_storage_prefix\x18\r \x01(\t\x12\x17\n\x0fharness_command\x18\x0e \x01(\t\x12\x1a\n\x12workflow_file_name\x18\x0f \x01(\t\x12\x1e\n\x16\x63ommandlines_file_name\x18\x10 \x01(\t\x12\r\n\x05vm_id\x18\x11 \x01(\t\x12\x15\n\rlanguage_hint\x18\x12 \x01(\t\x12#\n\x1bstreaming_worker_main_class\x18\x13 \x01(\t\"p\n\x13\x41utoscalingSettings\x12@\n\talgorithm\x18\x01 \x01(\x0e\x32-.google.dataflow.v1beta3.AutoscalingAlgorithm\x12\x17\n\x0fmax_num_workers\x18\x02 \x01(\x05\"\x88\x01\n\x18SdkHarnessContainerImage\x12\x17\n\x0f\x63ontainer_image\x18\x01 \x01(\t\x12%\n\x1duse_single_core_per_container\x18\x02 \x01(\x08\x12\x16\n\x0e\x65nvironment_id\x18\x03 \x01(\t\x12\x14\n\x0c\x63\x61pabilities\x18\x04 \x03(\t\"\xf2\x07\n\nWorkerPool\x12\x0c\n\x04kind\x18\x01 \x01(\t\x12\x13\n\x0bnum_workers\x18\x02 \x01(\x05\x12\x32\n\x08packages\x18\x03 \x03(\x0b\x32 .google.dataflow.v1beta3.Package\x12G\n\x13\x64\x65\x66\x61ult_package_set\x18\x04 \x01(\x0e\x32*.google.dataflow.v1beta3.DefaultPackageSet\x12\x14\n\x0cmachine_type\x18\x05 \x01(\t\x12@\n\x0fteardown_policy\x18\x06 \x01(\x0e\x32\'.google.dataflow.v1beta3.TeardownPolicy\x12\x14\n\x0c\x64isk_size_gb\x18\x07 \x01(\x05\x12\x11\n\tdisk_type\x18\x10 \x01(\t\x12\x19\n\x11\x64isk_source_image\x18\x08 \x01(\t\x12\x0c\n\x04zone\x18\t \x01(\t\x12H\n\x13taskrunner_settings\x18\n \x01(\x0b\x32+.google.dataflow.v1beta3.TaskRunnerSettings\x12\x1b\n\x13on_host_maintenance\x18\x0b \x01(\t\x12\x31\n\ndata_disks\x18\x0c \x03(\x0b\x32\x1d.google.dataflow.v1beta3.Disk\x12\x43\n\x08metadata\x18\r \x03(\x0b\x32\x31.google.dataflow.v1beta3.WorkerPool.MetadataEntry\x12J\n\x14\x61utoscaling_settings\x18\x0e \x01(\x0b\x32,.google.dataflow.v1beta3.AutoscalingSettings\x12\'\n\tpool_args\x18\x0f \x01(\x0b\x32\x14.google.protobuf.Any\x12\x0f\n\x07network\x18\x11 \x01(\t\x12\x12\n\nsubnetwork\x18\x13 \x01(\t\x12&\n\x1eworker_harness_container_image\x18\x12 \x01(\t\x12\x1e\n\x16num_threads_per_worker\x18\x14 \x01(\x05\x12O\n\x10ip_configuration\x18\x15 \x01(\x0e\x32\x35.google.dataflow.v1beta3.WorkerIPAddressConfiguration\x12W\n\x1csdk_harness_container_images\x18\x16 \x03(\x0b\x32\x31.google.dataflow.v1beta3.SdkHarnessContainerImage\x1a/\n\rMetadataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\".\n\x0c\x44\x65\x62ugOptions\x12\x1e\n\x16\x65nable_hot_key_logging\x18\x01 \x01(\x08*K\n\x07JobType\x12\x14\n\x10JOB_TYPE_UNKNOWN\x10\x00\x12\x12\n\x0eJOB_TYPE_BATCH\x10\x01\x12\x16\n\x12JOB_TYPE_STREAMING\x10\x02*k\n\x1a\x46lexResourceSchedulingGoal\x12\x16\n\x12\x46LEXRS_UNSPECIFIED\x10\x00\x12\x1a\n\x16\x46LEXRS_SPEED_OPTIMIZED\x10\x01\x12\x19\n\x15\x46LEXRS_COST_OPTIMIZED\x10\x02*o\n\x0eTeardownPolicy\x12\x1b\n\x17TEARDOWN_POLICY_UNKNOWN\x10\x00\x12\x13\n\x0fTEARDOWN_ALWAYS\x10\x01\x12\x17\n\x13TEARDOWN_ON_SUCCESS\x10\x02\x12\x12\n\x0eTEARDOWN_NEVER\x10\x03*\x90\x01\n\x11\x44\x65\x66\x61ultPackageSet\x12\x1f\n\x1b\x44\x45\x46\x41ULT_PACKAGE_SET_UNKNOWN\x10\x00\x12\x1c\n\x18\x44\x45\x46\x41ULT_PACKAGE_SET_NONE\x10\x01\x12\x1c\n\x18\x44\x45\x46\x41ULT_PACKAGE_SET_JAVA\x10\x02\x12\x1e\n\x1a\x44\x45\x46\x41ULT_PACKAGE_SET_PYTHON\x10\x03*z\n\x14\x41utoscalingAlgorithm\x12!\n\x1d\x41UTOSCALING_ALGORITHM_UNKNOWN\x10\x00\x12\x1e\n\x1a\x41UTOSCALING_ALGORITHM_NONE\x10\x01\x12\x1f\n\x1b\x41UTOSCALING_ALGORITHM_BASIC\x10\x02*f\n\x1cWorkerIPAddressConfiguration\x12\x19\n\x15WORKER_IP_UNSPECIFIED\x10\x00\x12\x14\n\x10WORKER_IP_PUBLIC\x10\x01\x12\x15\n\x11WORKER_IP_PRIVATE\x10\x02*L\n\x0bShuffleMode\x12\x1c\n\x18SHUFFLE_MODE_UNSPECIFIED\x10\x00\x12\x0c\n\x08VM_BASED\x10\x01\x12\x11\n\rSERVICE_BASED\x10\x02\x42\xd3\x01\n\x1b\x63om.google.dataflow.v1beta3B\x10\x45nvironmentProtoP\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 = [
+ ["google.protobuf.Struct", "google/protobuf/struct.proto"],
+ ["google.protobuf.Any", "google/protobuf/any.proto"],
+ ]
+ 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.Package" do
- optional :name, :string, 1
- optional :location, :string, 2
- end
- add_message "google.dataflow.v1beta3.Disk" do
- optional :size_gb, :int32, 1
- optional :disk_type, :string, 2
- optional :mount_point, :string, 3
- end
- add_message "google.dataflow.v1beta3.WorkerSettings" do
- optional :base_url, :string, 1
- optional :reporting_enabled, :bool, 2
- optional :service_path, :string, 3
- optional :shuffle_service_path, :string, 4
- optional :worker_id, :string, 5
- optional :temp_storage_prefix, :string, 6
- end
- add_message "google.dataflow.v1beta3.TaskRunnerSettings" do
- optional :task_user, :string, 1
- optional :task_group, :string, 2
- repeated :oauth_scopes, :string, 3
- optional :base_url, :string, 4
- optional :dataflow_api_version, :string, 5
- optional :parallel_worker_settings, :message, 6, "google.dataflow.v1beta3.WorkerSettings"
- optional :base_task_dir, :string, 7
- optional :continue_on_exception, :bool, 8
- optional :log_to_serialconsole, :bool, 9
- optional :alsologtostderr, :bool, 10
- optional :log_upload_location, :string, 11
- optional :log_dir, :string, 12
- optional :temp_storage_prefix, :string, 13
- optional :harness_command, :string, 14
- optional :workflow_file_name, :string, 15
- optional :commandlines_file_name, :string, 16
- optional :vm_id, :string, 17
- optional :language_hint, :string, 18
- optional :streaming_worker_main_class, :string, 19
- end
- add_message "google.dataflow.v1beta3.AutoscalingSettings" do
- optional :algorithm, :enum, 1, "google.dataflow.v1beta3.AutoscalingAlgorithm"
- optional :max_num_workers, :int32, 2
- end
- add_message "google.dataflow.v1beta3.SdkHarnessContainerImage" do
- optional :container_image, :string, 1
- optional :use_single_core_per_container, :bool, 2
- optional :environment_id, :string, 3
- repeated :capabilities, :string, 4
- end
- add_message "google.dataflow.v1beta3.WorkerPool" do
- optional :kind, :string, 1
- optional :num_workers, :int32, 2
- repeated :packages, :message, 3, "google.dataflow.v1beta3.Package"
- optional :default_package_set, :enum, 4, "google.dataflow.v1beta3.DefaultPackageSet"
- optional :machine_type, :string, 5
- optional :teardown_policy, :enum, 6, "google.dataflow.v1beta3.TeardownPolicy"
- optional :disk_size_gb, :int32, 7
- optional :disk_type, :string, 16
- optional :disk_source_image, :string, 8
- optional :zone, :string, 9
- optional :taskrunner_settings, :message, 10, "google.dataflow.v1beta3.TaskRunnerSettings"
- optional :on_host_maintenance, :string, 11
- repeated :data_disks, :message, 12, "google.dataflow.v1beta3.Disk"
- map :metadata, :string, :string, 13
- optional :autoscaling_settings, :message, 14, "google.dataflow.v1beta3.AutoscalingSettings"
- optional :pool_args, :message, 15, "google.protobuf.Any"
- optional :network, :string, 17
- optional :subnetwork, :string, 19
- optional :worker_harness_container_image, :string, 18
- optional :num_threads_per_worker, :int32, 20
- optional :ip_configuration, :enum, 21, "google.dataflow.v1beta3.WorkerIPAddressConfiguration"
- repeated :sdk_harness_container_images, :message, 22, "google.dataflow.v1beta3.SdkHarnessContainerImage"
- end
- add_message "google.dataflow.v1beta3.DebugOptions" do
- optional :enable_hot_key_logging, :bool, 1
- end
- add_enum "google.dataflow.v1beta3.JobType" do
- value :JOB_TYPE_UNKNOWN, 0
- value :JOB_TYPE_BATCH, 1
- value :JOB_TYPE_STREAMING, 2
- end
- add_enum "google.dataflow.v1beta3.FlexResourceSchedulingGoal" do
- value :FLEXRS_UNSPECIFIED, 0
- value :FLEXRS_SPEED_OPTIMIZED, 1
- value :FLEXRS_COST_OPTIMIZED, 2
- end
- add_enum "google.dataflow.v1beta3.TeardownPolicy" do
- value :TEARDOWN_POLICY_UNKNOWN, 0
- value :TEARDOWN_ALWAYS, 1
- value :TEARDOWN_ON_SUCCESS, 2
- value :TEARDOWN_NEVER, 3
- end
- add_enum "google.dataflow.v1beta3.DefaultPackageSet" do
- value :DEFAULT_PACKAGE_SET_UNKNOWN, 0
- value :DEFAULT_PACKAGE_SET_NONE, 1
- value :DEFAULT_PACKAGE_SET_JAVA, 2
- value :DEFAULT_PACKAGE_SET_PYTHON, 3
- end
- add_enum "google.dataflow.v1beta3.AutoscalingAlgorithm" do
- value :AUTOSCALING_ALGORITHM_UNKNOWN, 0
- value :AUTOSCALING_ALGORITHM_NONE, 1
- value :AUTOSCALING_ALGORITHM_BASIC, 2
- end
- add_enum "google.dataflow.v1beta3.WorkerIPAddressConfiguration" do
- value :WORKER_IP_UNSPECIFIED, 0
- value :WORKER_IP_PUBLIC, 1
- value :WORKER_IP_PRIVATE, 2
- end
- add_enum "google.dataflow.v1beta3.ShuffleMode" do
- value :SHUFFLE_MODE_UNSPECIFIED, 0
- value :VM_BASED, 1
- value :SERVICE_BASED, 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