# 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
    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
end

module Google
  module Cloud
    module Dataflow
      module V1beta3
        TopologyConfig = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.TopologyConfig").msgclass
        PubsubLocation = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.PubsubLocation").msgclass
        StreamingStageLocation = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.StreamingStageLocation").msgclass
        StreamingSideInputLocation = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.StreamingSideInputLocation").msgclass
        CustomSourceLocation = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.CustomSourceLocation").msgclass
        StreamLocation = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.StreamLocation").msgclass
        StateFamilyConfig = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.StateFamilyConfig").msgclass
        ComputationTopology = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.ComputationTopology").msgclass
        KeyRangeLocation = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.KeyRangeLocation").msgclass
        MountedDataDisk = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.MountedDataDisk").msgclass
        DataDiskAssignment = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.DataDiskAssignment").msgclass
        KeyRangeDataDiskAssignment = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.KeyRangeDataDiskAssignment").msgclass
        StreamingComputationRanges = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.StreamingComputationRanges").msgclass
        StreamingApplianceSnapshotConfig = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.dataflow.v1beta3.StreamingApplianceSnapshotConfig").msgclass
      end
    end
  end
end