# frozen_string_literal: true
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: google/dataflow/v1beta3/streaming.proto

require 'google/protobuf'


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