# frozen_string_literal: true
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: google/cloud/visionai/v1/streaming_service.proto

require 'google/protobuf'

require 'google/api/annotations_pb'
require 'google/api/client_pb'
require 'google/cloud/visionai/v1/streaming_resources_pb'
require 'google/protobuf/duration_pb'
require 'google/protobuf/timestamp_pb'


descriptor_data = "\n0google/cloud/visionai/v1/streaming_service.proto\x12\x18google.cloud.visionai.v1\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a\x32google/cloud/visionai/v1/streaming_resources.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\xb5\x03\n\x14ReceiveEventsRequest\x12T\n\rsetup_request\x18\x01 \x01(\x0b\x32;.google.cloud.visionai.v1.ReceiveEventsRequest.SetupRequestH\x00\x12\x41\n\x0e\x63ommit_request\x18\x02 \x01(\x0b\x32\'.google.cloud.visionai.v1.CommitRequestH\x00\x1a\xf8\x01\n\x0cSetupRequest\x12\x0f\n\x07\x63luster\x18\x01 \x01(\t\x12\x0e\n\x06stream\x18\x02 \x01(\t\x12\x10\n\x08receiver\x18\x03 \x01(\t\x12\x41\n\x0f\x63ontrolled_mode\x18\x04 \x01(\x0b\x32(.google.cloud.visionai.v1.ControlledMode\x12\x35\n\x12heartbeat_interval\x18\x05 \x01(\x0b\x32\x19.google.protobuf.Duration\x12;\n\x18writes_done_grace_period\x18\x06 \x01(\x0b\x32\x19.google.protobuf.DurationB\t\n\x07request\"}\n\x0b\x45ventUpdate\x12\x0e\n\x06stream\x18\x01 \x01(\t\x12\r\n\x05\x65vent\x18\x02 \x01(\t\x12\x0e\n\x06series\x18\x03 \x01(\t\x12/\n\x0bupdate_time\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x0e\n\x06offset\x18\x05 \x01(\x03\"]\n\x1cReceiveEventsControlResponse\x12\x13\n\theartbeat\x18\x01 \x01(\x08H\x00\x12\x1d\n\x13writes_done_request\x18\x02 \x01(\x08H\x00\x42\t\n\x07\x63ontrol\"\xad\x01\n\x15ReceiveEventsResponse\x12=\n\x0c\x65vent_update\x18\x01 \x01(\x0b\x32%.google.cloud.visionai.v1.EventUpdateH\x00\x12I\n\x07\x63ontrol\x18\x02 \x01(\x0b\x32\x36.google.cloud.visionai.v1.ReceiveEventsControlResponseH\x00\x42\n\n\x08response\"\x9c\x01\n\x05Lease\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0e\n\x06series\x18\x02 \x01(\t\x12\r\n\x05owner\x18\x03 \x01(\t\x12/\n\x0b\x65xpire_time\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x37\n\nlease_type\x18\x05 \x01(\x0e\x32#.google.cloud.visionai.v1.LeaseType\"\x96\x01\n\x13\x41\x63quireLeaseRequest\x12\x0e\n\x06series\x18\x01 \x01(\t\x12\r\n\x05owner\x18\x02 \x01(\t\x12\'\n\x04term\x18\x03 \x01(\x0b\x32\x19.google.protobuf.Duration\x12\x37\n\nlease_type\x18\x04 \x01(\x0e\x32#.google.cloud.visionai.v1.LeaseType\"g\n\x11RenewLeaseRequest\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0e\n\x06series\x18\x02 \x01(\t\x12\r\n\x05owner\x18\x03 \x01(\t\x12\'\n\x04term\x18\x04 \x01(\x0b\x32\x19.google.protobuf.Duration\"@\n\x13ReleaseLeaseRequest\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0e\n\x06series\x18\x02 \x01(\t\x12\r\n\x05owner\x18\x03 \x01(\t\"\x16\n\x14ReleaseLeaseResponse\"\x90\x01\n\x0fRequestMetadata\x12\x0e\n\x06stream\x18\x01 \x01(\t\x12\r\n\x05\x65vent\x18\x02 \x01(\t\x12\x0e\n\x06series\x18\x03 \x01(\t\x12\x10\n\x08lease_id\x18\x04 \x01(\t\x12\r\n\x05owner\x18\x05 \x01(\t\x12-\n\nlease_term\x18\x06 \x01(\x0b\x32\x19.google.protobuf.Duration\"\x92\x01\n\x12SendPacketsRequest\x12\x32\n\x06packet\x18\x01 \x01(\x0b\x32 .google.cloud.visionai.v1.PacketH\x00\x12=\n\x08metadata\x18\x02 \x01(\x0b\x32).google.cloud.visionai.v1.RequestMetadataH\x00\x42\t\n\x07request\"\x15\n\x13SendPacketsResponse\"\xb1\x04\n\x15ReceivePacketsRequest\x12U\n\rsetup_request\x18\x06 \x01(\x0b\x32<.google.cloud.visionai.v1.ReceivePacketsRequest.SetupRequestH\x00\x12\x41\n\x0e\x63ommit_request\x18\x07 \x01(\x0b\x32\'.google.cloud.visionai.v1.CommitRequestH\x00\x1a\xf2\x02\n\x0cSetupRequest\x12\x41\n\x12\x65\x61ger_receive_mode\x18\x03 \x01(\x0b\x32#.google.cloud.visionai.v1.EagerModeH\x00\x12K\n\x17\x63ontrolled_receive_mode\x18\x04 \x01(\x0b\x32(.google.cloud.visionai.v1.ControlledModeH\x00\x12;\n\x08metadata\x18\x01 \x01(\x0b\x32).google.cloud.visionai.v1.RequestMetadata\x12\x10\n\x08receiver\x18\x02 \x01(\t\x12\x35\n\x12heartbeat_interval\x18\x05 \x01(\x0b\x32\x19.google.protobuf.Duration\x12;\n\x18writes_done_grace_period\x18\x06 \x01(\x0b\x32\x19.google.protobuf.DurationB\x0f\n\rconsumer_modeB\t\n\x07request\"^\n\x1dReceivePacketsControlResponse\x12\x13\n\theartbeat\x18\x01 \x01(\x08H\x00\x12\x1d\n\x13writes_done_request\x18\x02 \x01(\x08H\x00\x42\t\n\x07\x63ontrol\"\xa4\x01\n\x16ReceivePacketsResponse\x12\x32\n\x06packet\x18\x01 \x01(\x0b\x32 .google.cloud.visionai.v1.PacketH\x00\x12J\n\x07\x63ontrol\x18\x03 \x01(\x0b\x32\x37.google.cloud.visionai.v1.ReceivePacketsControlResponseH\x00\x42\n\n\x08response\"\x0b\n\tEagerMode\"h\n\x0e\x43ontrolledMode\x12!\n\x17starting_logical_offset\x18\x01 \x01(\tH\x00\x12 \n\x18\x66\x61llback_starting_offset\x18\x02 \x01(\tB\x11\n\x0fstarting_offset\"\x1f\n\rCommitRequest\x12\x0e\n\x06offset\x18\x01 \x01(\x03*U\n\tLeaseType\x12\x1a\n\x16LEASE_TYPE_UNSPECIFIED\x10\x00\x12\x15\n\x11LEASE_TYPE_READER\x10\x01\x12\x15\n\x11LEASE_TYPE_WRITER\x10\x02\x32\xe3\x07\n\x10StreamingService\x12p\n\x0bSendPackets\x12,.google.cloud.visionai.v1.SendPacketsRequest\x1a-.google.cloud.visionai.v1.SendPacketsResponse\"\x00(\x01\x30\x01\x12y\n\x0eReceivePackets\x12/.google.cloud.visionai.v1.ReceivePacketsRequest\x1a\x30.google.cloud.visionai.v1.ReceivePacketsResponse\"\x00(\x01\x30\x01\x12v\n\rReceiveEvents\x12..google.cloud.visionai.v1.ReceiveEventsRequest\x1a/.google.cloud.visionai.v1.ReceiveEventsResponse\"\x00(\x01\x30\x01\x12\xaf\x01\n\x0c\x41\x63quireLease\x12-.google.cloud.visionai.v1.AcquireLeaseRequest\x1a\x1f.google.cloud.visionai.v1.Lease\"O\x82\xd3\xe4\x93\x02I\"D/v1/{series=projects/*/locations/*/clusters/*/series/*}:acquireLease:\x01*\x12\xa9\x01\n\nRenewLease\x12+.google.cloud.visionai.v1.RenewLeaseRequest\x1a\x1f.google.cloud.visionai.v1.Lease\"M\x82\xd3\xe4\x93\x02G\"B/v1/{series=projects/*/locations/*/clusters/*/series/*}:renewLease:\x01*\x12\xbe\x01\n\x0cReleaseLease\x12-.google.cloud.visionai.v1.ReleaseLeaseRequest\x1a..google.cloud.visionai.v1.ReleaseLeaseResponse\"O\x82\xd3\xe4\x93\x02I\"D/v1/{series=projects/*/locations/*/clusters/*/series/*}:releaseLease:\x01*\x1aK\xca\x41\x17visionai.googleapis.com\xd2\x41.https://www.googleapis.com/auth/cloud-platformB\xc5\x01\n\x1c\x63om.google.cloud.visionai.v1B\x15StreamingServiceProtoP\x01Z8cloud.google.com/go/visionai/apiv1/visionaipb;visionaipb\xaa\x02\x18Google.Cloud.VisionAI.V1\xca\x02\x18Google\\Cloud\\VisionAI\\V1\xea\x02\x1bGoogle::Cloud::VisionAI::V1b\x06proto3"

pool = Google::Protobuf::DescriptorPool.generated_pool

begin
  pool.add_serialized_file(descriptor_data)
rescue TypeError
  # 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.Duration", "google/protobuf/duration.proto"],
    ["google.protobuf.Timestamp", "google/protobuf/timestamp.proto"],
    ["google.cloud.visionai.v1.Packet", "google/cloud/visionai/v1/streaming_resources.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
  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 VisionAI
      module V1
        ReceiveEventsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.ReceiveEventsRequest").msgclass
        ReceiveEventsRequest::SetupRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.ReceiveEventsRequest.SetupRequest").msgclass
        EventUpdate = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.EventUpdate").msgclass
        ReceiveEventsControlResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.ReceiveEventsControlResponse").msgclass
        ReceiveEventsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.ReceiveEventsResponse").msgclass
        Lease = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.Lease").msgclass
        AcquireLeaseRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.AcquireLeaseRequest").msgclass
        RenewLeaseRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.RenewLeaseRequest").msgclass
        ReleaseLeaseRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.ReleaseLeaseRequest").msgclass
        ReleaseLeaseResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.ReleaseLeaseResponse").msgclass
        RequestMetadata = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.RequestMetadata").msgclass
        SendPacketsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.SendPacketsRequest").msgclass
        SendPacketsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.SendPacketsResponse").msgclass
        ReceivePacketsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.ReceivePacketsRequest").msgclass
        ReceivePacketsRequest::SetupRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.ReceivePacketsRequest.SetupRequest").msgclass
        ReceivePacketsControlResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.ReceivePacketsControlResponse").msgclass
        ReceivePacketsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.ReceivePacketsResponse").msgclass
        EagerMode = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.EagerMode").msgclass
        ControlledMode = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.ControlledMode").msgclass
        CommitRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.CommitRequest").msgclass
        LeaseType = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.visionai.v1.LeaseType").enummodule
      end
    end
  end
end