# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: google/pubsub/v1/pubsub.proto

require 'google/api/annotations_pb'
require 'google/api/client_pb'
require 'google/api/field_behavior_pb'
require 'google/api/resource_pb'
require 'google/protobuf/duration_pb'
require 'google/protobuf/empty_pb'
require 'google/protobuf/field_mask_pb'
require 'google/protobuf/timestamp_pb'
require 'google/pubsub/v1/schema_pb'
require 'google/protobuf'

Google::Protobuf::DescriptorPool.generated_pool.build do
  add_file("google/pubsub/v1/pubsub.proto", :syntax => :proto3) do
    add_message "google.pubsub.v1.MessageStoragePolicy" do
      repeated :allowed_persistence_regions, :string, 1
    end
    add_message "google.pubsub.v1.SchemaSettings" do
      optional :schema, :string, 1
      optional :encoding, :enum, 2, "google.pubsub.v1.Encoding"
    end
    add_message "google.pubsub.v1.Topic" do
      optional :name, :string, 1
      map :labels, :string, :string, 2
      optional :message_storage_policy, :message, 3, "google.pubsub.v1.MessageStoragePolicy"
      optional :kms_key_name, :string, 5
      optional :schema_settings, :message, 6, "google.pubsub.v1.SchemaSettings"
      optional :satisfies_pzs, :bool, 7
      optional :message_retention_duration, :message, 8, "google.protobuf.Duration"
    end
    add_message "google.pubsub.v1.PubsubMessage" do
      optional :data, :bytes, 1
      map :attributes, :string, :string, 2
      optional :message_id, :string, 3
      optional :publish_time, :message, 4, "google.protobuf.Timestamp"
      optional :ordering_key, :string, 5
    end
    add_message "google.pubsub.v1.GetTopicRequest" do
      optional :topic, :string, 1
    end
    add_message "google.pubsub.v1.UpdateTopicRequest" do
      optional :topic, :message, 1, "google.pubsub.v1.Topic"
      optional :update_mask, :message, 2, "google.protobuf.FieldMask"
    end
    add_message "google.pubsub.v1.PublishRequest" do
      optional :topic, :string, 1
      repeated :messages, :message, 2, "google.pubsub.v1.PubsubMessage"
    end
    add_message "google.pubsub.v1.PublishResponse" do
      repeated :message_ids, :string, 1
    end
    add_message "google.pubsub.v1.ListTopicsRequest" do
      optional :project, :string, 1
      optional :page_size, :int32, 2
      optional :page_token, :string, 3
    end
    add_message "google.pubsub.v1.ListTopicsResponse" do
      repeated :topics, :message, 1, "google.pubsub.v1.Topic"
      optional :next_page_token, :string, 2
    end
    add_message "google.pubsub.v1.ListTopicSubscriptionsRequest" do
      optional :topic, :string, 1
      optional :page_size, :int32, 2
      optional :page_token, :string, 3
    end
    add_message "google.pubsub.v1.ListTopicSubscriptionsResponse" do
      repeated :subscriptions, :string, 1
      optional :next_page_token, :string, 2
    end
    add_message "google.pubsub.v1.ListTopicSnapshotsRequest" do
      optional :topic, :string, 1
      optional :page_size, :int32, 2
      optional :page_token, :string, 3
    end
    add_message "google.pubsub.v1.ListTopicSnapshotsResponse" do
      repeated :snapshots, :string, 1
      optional :next_page_token, :string, 2
    end
    add_message "google.pubsub.v1.DeleteTopicRequest" do
      optional :topic, :string, 1
    end
    add_message "google.pubsub.v1.DetachSubscriptionRequest" do
      optional :subscription, :string, 1
    end
    add_message "google.pubsub.v1.DetachSubscriptionResponse" do
    end
    add_message "google.pubsub.v1.Subscription" do
      optional :name, :string, 1
      optional :topic, :string, 2
      optional :push_config, :message, 4, "google.pubsub.v1.PushConfig"
      optional :ack_deadline_seconds, :int32, 5
      optional :retain_acked_messages, :bool, 7
      optional :message_retention_duration, :message, 8, "google.protobuf.Duration"
      map :labels, :string, :string, 9
      optional :enable_message_ordering, :bool, 10
      optional :expiration_policy, :message, 11, "google.pubsub.v1.ExpirationPolicy"
      optional :filter, :string, 12
      optional :dead_letter_policy, :message, 13, "google.pubsub.v1.DeadLetterPolicy"
      optional :retry_policy, :message, 14, "google.pubsub.v1.RetryPolicy"
      optional :detached, :bool, 15
      optional :enable_exactly_once_delivery, :bool, 16
      optional :topic_message_retention_duration, :message, 17, "google.protobuf.Duration"
    end
    add_message "google.pubsub.v1.RetryPolicy" do
      optional :minimum_backoff, :message, 1, "google.protobuf.Duration"
      optional :maximum_backoff, :message, 2, "google.protobuf.Duration"
    end
    add_message "google.pubsub.v1.DeadLetterPolicy" do
      optional :dead_letter_topic, :string, 1
      optional :max_delivery_attempts, :int32, 2
    end
    add_message "google.pubsub.v1.ExpirationPolicy" do
      optional :ttl, :message, 1, "google.protobuf.Duration"
    end
    add_message "google.pubsub.v1.PushConfig" do
      optional :push_endpoint, :string, 1
      map :attributes, :string, :string, 2
      oneof :authentication_method do
        optional :oidc_token, :message, 3, "google.pubsub.v1.PushConfig.OidcToken"
      end
    end
    add_message "google.pubsub.v1.PushConfig.OidcToken" do
      optional :service_account_email, :string, 1
      optional :audience, :string, 2
    end
    add_message "google.pubsub.v1.ReceivedMessage" do
      optional :ack_id, :string, 1
      optional :message, :message, 2, "google.pubsub.v1.PubsubMessage"
      optional :delivery_attempt, :int32, 3
    end
    add_message "google.pubsub.v1.GetSubscriptionRequest" do
      optional :subscription, :string, 1
    end
    add_message "google.pubsub.v1.UpdateSubscriptionRequest" do
      optional :subscription, :message, 1, "google.pubsub.v1.Subscription"
      optional :update_mask, :message, 2, "google.protobuf.FieldMask"
    end
    add_message "google.pubsub.v1.ListSubscriptionsRequest" do
      optional :project, :string, 1
      optional :page_size, :int32, 2
      optional :page_token, :string, 3
    end
    add_message "google.pubsub.v1.ListSubscriptionsResponse" do
      repeated :subscriptions, :message, 1, "google.pubsub.v1.Subscription"
      optional :next_page_token, :string, 2
    end
    add_message "google.pubsub.v1.DeleteSubscriptionRequest" do
      optional :subscription, :string, 1
    end
    add_message "google.pubsub.v1.ModifyPushConfigRequest" do
      optional :subscription, :string, 1
      optional :push_config, :message, 2, "google.pubsub.v1.PushConfig"
    end
    add_message "google.pubsub.v1.PullRequest" do
      optional :subscription, :string, 1
      optional :return_immediately, :bool, 2
      optional :max_messages, :int32, 3
    end
    add_message "google.pubsub.v1.PullResponse" do
      repeated :received_messages, :message, 1, "google.pubsub.v1.ReceivedMessage"
    end
    add_message "google.pubsub.v1.ModifyAckDeadlineRequest" do
      optional :subscription, :string, 1
      repeated :ack_ids, :string, 4
      optional :ack_deadline_seconds, :int32, 3
    end
    add_message "google.pubsub.v1.AcknowledgeRequest" do
      optional :subscription, :string, 1
      repeated :ack_ids, :string, 2
    end
    add_message "google.pubsub.v1.StreamingPullRequest" do
      optional :subscription, :string, 1
      repeated :ack_ids, :string, 2
      repeated :modify_deadline_seconds, :int32, 3
      repeated :modify_deadline_ack_ids, :string, 4
      optional :stream_ack_deadline_seconds, :int32, 5
      optional :client_id, :string, 6
      optional :max_outstanding_messages, :int64, 7
      optional :max_outstanding_bytes, :int64, 8
    end
    add_message "google.pubsub.v1.StreamingPullResponse" do
      repeated :received_messages, :message, 1, "google.pubsub.v1.ReceivedMessage"
      optional :acknowledge_confirmation, :message, 5, "google.pubsub.v1.StreamingPullResponse.AcknowledgeConfirmation"
      optional :modify_ack_deadline_confirmation, :message, 3, "google.pubsub.v1.StreamingPullResponse.ModifyAckDeadlineConfirmation"
      optional :subscription_properties, :message, 4, "google.pubsub.v1.StreamingPullResponse.SubscriptionProperties"
    end
    add_message "google.pubsub.v1.StreamingPullResponse.AcknowledgeConfirmation" do
      repeated :ack_ids, :string, 1
      repeated :invalid_ack_ids, :string, 2
      repeated :unordered_ack_ids, :string, 3
    end
    add_message "google.pubsub.v1.StreamingPullResponse.ModifyAckDeadlineConfirmation" do
      repeated :ack_ids, :string, 1
      repeated :invalid_ack_ids, :string, 2
    end
    add_message "google.pubsub.v1.StreamingPullResponse.SubscriptionProperties" do
      optional :exactly_once_delivery_enabled, :bool, 1
      optional :message_ordering_enabled, :bool, 2
    end
    add_message "google.pubsub.v1.CreateSnapshotRequest" do
      optional :name, :string, 1
      optional :subscription, :string, 2
      map :labels, :string, :string, 3
    end
    add_message "google.pubsub.v1.UpdateSnapshotRequest" do
      optional :snapshot, :message, 1, "google.pubsub.v1.Snapshot"
      optional :update_mask, :message, 2, "google.protobuf.FieldMask"
    end
    add_message "google.pubsub.v1.Snapshot" do
      optional :name, :string, 1
      optional :topic, :string, 2
      optional :expire_time, :message, 3, "google.protobuf.Timestamp"
      map :labels, :string, :string, 4
    end
    add_message "google.pubsub.v1.GetSnapshotRequest" do
      optional :snapshot, :string, 1
    end
    add_message "google.pubsub.v1.ListSnapshotsRequest" do
      optional :project, :string, 1
      optional :page_size, :int32, 2
      optional :page_token, :string, 3
    end
    add_message "google.pubsub.v1.ListSnapshotsResponse" do
      repeated :snapshots, :message, 1, "google.pubsub.v1.Snapshot"
      optional :next_page_token, :string, 2
    end
    add_message "google.pubsub.v1.DeleteSnapshotRequest" do
      optional :snapshot, :string, 1
    end
    add_message "google.pubsub.v1.SeekRequest" do
      optional :subscription, :string, 1
      oneof :target do
        optional :time, :message, 2, "google.protobuf.Timestamp"
        optional :snapshot, :string, 3
      end
    end
    add_message "google.pubsub.v1.SeekResponse" do
    end
  end
end

module Google
  module Cloud
    module PubSub
      module V1
        MessageStoragePolicy = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.MessageStoragePolicy").msgclass
        SchemaSettings = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.SchemaSettings").msgclass
        Topic = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.Topic").msgclass
        PubsubMessage = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.PubsubMessage").msgclass
        GetTopicRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.GetTopicRequest").msgclass
        UpdateTopicRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.UpdateTopicRequest").msgclass
        PublishRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.PublishRequest").msgclass
        PublishResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.PublishResponse").msgclass
        ListTopicsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ListTopicsRequest").msgclass
        ListTopicsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ListTopicsResponse").msgclass
        ListTopicSubscriptionsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ListTopicSubscriptionsRequest").msgclass
        ListTopicSubscriptionsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ListTopicSubscriptionsResponse").msgclass
        ListTopicSnapshotsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ListTopicSnapshotsRequest").msgclass
        ListTopicSnapshotsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ListTopicSnapshotsResponse").msgclass
        DeleteTopicRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.DeleteTopicRequest").msgclass
        DetachSubscriptionRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.DetachSubscriptionRequest").msgclass
        DetachSubscriptionResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.DetachSubscriptionResponse").msgclass
        Subscription = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.Subscription").msgclass
        RetryPolicy = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.RetryPolicy").msgclass
        DeadLetterPolicy = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.DeadLetterPolicy").msgclass
        ExpirationPolicy = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ExpirationPolicy").msgclass
        PushConfig = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.PushConfig").msgclass
        PushConfig::OidcToken = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.PushConfig.OidcToken").msgclass
        ReceivedMessage = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ReceivedMessage").msgclass
        GetSubscriptionRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.GetSubscriptionRequest").msgclass
        UpdateSubscriptionRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.UpdateSubscriptionRequest").msgclass
        ListSubscriptionsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ListSubscriptionsRequest").msgclass
        ListSubscriptionsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ListSubscriptionsResponse").msgclass
        DeleteSubscriptionRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.DeleteSubscriptionRequest").msgclass
        ModifyPushConfigRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ModifyPushConfigRequest").msgclass
        PullRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.PullRequest").msgclass
        PullResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.PullResponse").msgclass
        ModifyAckDeadlineRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ModifyAckDeadlineRequest").msgclass
        AcknowledgeRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.AcknowledgeRequest").msgclass
        StreamingPullRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.StreamingPullRequest").msgclass
        StreamingPullResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.StreamingPullResponse").msgclass
        StreamingPullResponse::AcknowledgeConfirmation = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.StreamingPullResponse.AcknowledgeConfirmation").msgclass
        StreamingPullResponse::ModifyAckDeadlineConfirmation = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.StreamingPullResponse.ModifyAckDeadlineConfirmation").msgclass
        StreamingPullResponse::SubscriptionProperties = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.StreamingPullResponse.SubscriptionProperties").msgclass
        CreateSnapshotRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.CreateSnapshotRequest").msgclass
        UpdateSnapshotRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.UpdateSnapshotRequest").msgclass
        Snapshot = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.Snapshot").msgclass
        GetSnapshotRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.GetSnapshotRequest").msgclass
        ListSnapshotsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ListSnapshotsRequest").msgclass
        ListSnapshotsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.ListSnapshotsResponse").msgclass
        DeleteSnapshotRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.DeleteSnapshotRequest").msgclass
        SeekRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.SeekRequest").msgclass
        SeekResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.pubsub.v1.SeekResponse").msgclass
      end
    end
  end
end