defmodule Google.Pubsub.V1.Subscription.State do
  @moduledoc false

  use Protobuf, enum: true, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :STATE_UNSPECIFIED, 0
  field :ACTIVE, 1
  field :RESOURCE_ERROR, 2
end

defmodule Google.Pubsub.V1.BigQueryConfig.State do
  @moduledoc false

  use Protobuf, enum: true, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :STATE_UNSPECIFIED, 0
  field :ACTIVE, 1
  field :PERMISSION_DENIED, 2
  field :NOT_FOUND, 3
  field :SCHEMA_MISMATCH, 4
end

defmodule Google.Pubsub.V1.CloudStorageConfig.State do
  @moduledoc false

  use Protobuf, enum: true, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :STATE_UNSPECIFIED, 0
  field :ACTIVE, 1
  field :PERMISSION_DENIED, 2
  field :NOT_FOUND, 3
end

defmodule Google.Pubsub.V1.MessageStoragePolicy do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :allowed_persistence_regions, 1,
    repeated: true,
    type: :string,
    json_name: "allowedPersistenceRegions"
end

defmodule Google.Pubsub.V1.SchemaSettings do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :schema, 1, type: :string, deprecated: false
  field :encoding, 2, type: Google.Pubsub.V1.Encoding, enum: true
  field :first_revision_id, 3, type: :string, json_name: "firstRevisionId"
  field :last_revision_id, 4, type: :string, json_name: "lastRevisionId"
end

defmodule Google.Pubsub.V1.Topic.LabelsEntry do
  @moduledoc false

  use Protobuf, map: true, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :key, 1, type: :string
  field :value, 2, type: :string
end

defmodule Google.Pubsub.V1.Topic do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :name, 1, type: :string, deprecated: false
  field :labels, 2, repeated: true, type: Google.Pubsub.V1.Topic.LabelsEntry, map: true

  field :message_storage_policy, 3,
    type: Google.Pubsub.V1.MessageStoragePolicy,
    json_name: "messageStoragePolicy"

  field :kms_key_name, 5, type: :string, json_name: "kmsKeyName"
  field :schema_settings, 6, type: Google.Pubsub.V1.SchemaSettings, json_name: "schemaSettings"
  field :satisfies_pzs, 7, type: :bool, json_name: "satisfiesPzs"

  field :message_retention_duration, 8,
    type: Google.Protobuf.Duration,
    json_name: "messageRetentionDuration"
end

defmodule Google.Pubsub.V1.PubsubMessage.AttributesEntry do
  @moduledoc false

  use Protobuf, map: true, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :key, 1, type: :string
  field :value, 2, type: :string
end

defmodule Google.Pubsub.V1.PubsubMessage do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :data, 1, type: :bytes

  field :attributes, 2,
    repeated: true,
    type: Google.Pubsub.V1.PubsubMessage.AttributesEntry,
    map: true

  field :message_id, 3, type: :string, json_name: "messageId"
  field :publish_time, 4, type: Google.Protobuf.Timestamp, json_name: "publishTime"
  field :ordering_key, 5, type: :string, json_name: "orderingKey"
end

defmodule Google.Pubsub.V1.GetTopicRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :topic, 1, type: :string, deprecated: false
end

defmodule Google.Pubsub.V1.UpdateTopicRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :topic, 1, type: Google.Pubsub.V1.Topic, deprecated: false

  field :update_mask, 2,
    type: Google.Protobuf.FieldMask,
    json_name: "updateMask",
    deprecated: false
end

defmodule Google.Pubsub.V1.PublishRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :topic, 1, type: :string, deprecated: false
  field :messages, 2, repeated: true, type: Google.Pubsub.V1.PubsubMessage, deprecated: false
end

defmodule Google.Pubsub.V1.PublishResponse do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :message_ids, 1, repeated: true, type: :string, json_name: "messageIds"
end

defmodule Google.Pubsub.V1.ListTopicsRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :project, 1, type: :string, deprecated: false
  field :page_size, 2, type: :int32, json_name: "pageSize"
  field :page_token, 3, type: :string, json_name: "pageToken"
end

defmodule Google.Pubsub.V1.ListTopicsResponse do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :topics, 1, repeated: true, type: Google.Pubsub.V1.Topic
  field :next_page_token, 2, type: :string, json_name: "nextPageToken"
end

defmodule Google.Pubsub.V1.ListTopicSubscriptionsRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :topic, 1, type: :string, deprecated: false
  field :page_size, 2, type: :int32, json_name: "pageSize"
  field :page_token, 3, type: :string, json_name: "pageToken"
end

defmodule Google.Pubsub.V1.ListTopicSubscriptionsResponse do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :subscriptions, 1, repeated: true, type: :string, deprecated: false
  field :next_page_token, 2, type: :string, json_name: "nextPageToken"
end

defmodule Google.Pubsub.V1.ListTopicSnapshotsRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :topic, 1, type: :string, deprecated: false
  field :page_size, 2, type: :int32, json_name: "pageSize"
  field :page_token, 3, type: :string, json_name: "pageToken"
end

defmodule Google.Pubsub.V1.ListTopicSnapshotsResponse do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :snapshots, 1, repeated: true, type: :string
  field :next_page_token, 2, type: :string, json_name: "nextPageToken"
end

defmodule Google.Pubsub.V1.DeleteTopicRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :topic, 1, type: :string, deprecated: false
end

defmodule Google.Pubsub.V1.DetachSubscriptionRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :subscription, 1, type: :string, deprecated: false
end

defmodule Google.Pubsub.V1.DetachSubscriptionResponse do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"
end

defmodule Google.Pubsub.V1.Subscription.LabelsEntry do
  @moduledoc false

  use Protobuf, map: true, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :key, 1, type: :string
  field :value, 2, type: :string
end

defmodule Google.Pubsub.V1.Subscription do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :name, 1, type: :string, deprecated: false
  field :topic, 2, type: :string, deprecated: false
  field :push_config, 4, type: Google.Pubsub.V1.PushConfig, json_name: "pushConfig"
  field :bigquery_config, 18, type: Google.Pubsub.V1.BigQueryConfig, json_name: "bigqueryConfig"

  field :cloud_storage_config, 22,
    type: Google.Pubsub.V1.CloudStorageConfig,
    json_name: "cloudStorageConfig"

  field :ack_deadline_seconds, 5, type: :int32, json_name: "ackDeadlineSeconds"
  field :retain_acked_messages, 7, type: :bool, json_name: "retainAckedMessages"

  field :message_retention_duration, 8,
    type: Google.Protobuf.Duration,
    json_name: "messageRetentionDuration"

  field :labels, 9, repeated: true, type: Google.Pubsub.V1.Subscription.LabelsEntry, map: true
  field :enable_message_ordering, 10, type: :bool, json_name: "enableMessageOrdering"

  field :expiration_policy, 11,
    type: Google.Pubsub.V1.ExpirationPolicy,
    json_name: "expirationPolicy"

  field :filter, 12, type: :string

  field :dead_letter_policy, 13,
    type: Google.Pubsub.V1.DeadLetterPolicy,
    json_name: "deadLetterPolicy"

  field :retry_policy, 14, type: Google.Pubsub.V1.RetryPolicy, json_name: "retryPolicy"
  field :detached, 15, type: :bool
  field :enable_exactly_once_delivery, 16, type: :bool, json_name: "enableExactlyOnceDelivery"

  field :topic_message_retention_duration, 17,
    type: Google.Protobuf.Duration,
    json_name: "topicMessageRetentionDuration",
    deprecated: false

  field :state, 19, type: Google.Pubsub.V1.Subscription.State, enum: true, deprecated: false
end

defmodule Google.Pubsub.V1.RetryPolicy do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :minimum_backoff, 1, type: Google.Protobuf.Duration, json_name: "minimumBackoff"
  field :maximum_backoff, 2, type: Google.Protobuf.Duration, json_name: "maximumBackoff"
end

defmodule Google.Pubsub.V1.DeadLetterPolicy do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :dead_letter_topic, 1, type: :string, json_name: "deadLetterTopic"
  field :max_delivery_attempts, 2, type: :int32, json_name: "maxDeliveryAttempts"
end

defmodule Google.Pubsub.V1.ExpirationPolicy do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :ttl, 1, type: Google.Protobuf.Duration
end

defmodule Google.Pubsub.V1.PushConfig.OidcToken do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :service_account_email, 1, type: :string, json_name: "serviceAccountEmail"
  field :audience, 2, type: :string
end

defmodule Google.Pubsub.V1.PushConfig.PubsubWrapper do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"
end

defmodule Google.Pubsub.V1.PushConfig.NoWrapper do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :write_metadata, 1, type: :bool, json_name: "writeMetadata"
end

defmodule Google.Pubsub.V1.PushConfig.AttributesEntry do
  @moduledoc false

  use Protobuf, map: true, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :key, 1, type: :string
  field :value, 2, type: :string
end

defmodule Google.Pubsub.V1.PushConfig do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  oneof :authentication_method, 0

  oneof :wrapper, 1

  field :push_endpoint, 1, type: :string, json_name: "pushEndpoint"

  field :attributes, 2,
    repeated: true,
    type: Google.Pubsub.V1.PushConfig.AttributesEntry,
    map: true

  field :oidc_token, 3,
    type: Google.Pubsub.V1.PushConfig.OidcToken,
    json_name: "oidcToken",
    oneof: 0

  field :pubsub_wrapper, 4,
    type: Google.Pubsub.V1.PushConfig.PubsubWrapper,
    json_name: "pubsubWrapper",
    oneof: 1

  field :no_wrapper, 5,
    type: Google.Pubsub.V1.PushConfig.NoWrapper,
    json_name: "noWrapper",
    oneof: 1
end

defmodule Google.Pubsub.V1.BigQueryConfig do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :table, 1, type: :string
  field :use_topic_schema, 2, type: :bool, json_name: "useTopicSchema"
  field :write_metadata, 3, type: :bool, json_name: "writeMetadata"
  field :drop_unknown_fields, 4, type: :bool, json_name: "dropUnknownFields"
  field :state, 5, type: Google.Pubsub.V1.BigQueryConfig.State, enum: true, deprecated: false
end

defmodule Google.Pubsub.V1.CloudStorageConfig.TextConfig do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"
end

defmodule Google.Pubsub.V1.CloudStorageConfig.AvroConfig do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :write_metadata, 1, type: :bool, json_name: "writeMetadata"
end

defmodule Google.Pubsub.V1.CloudStorageConfig do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  oneof :output_format, 0

  field :bucket, 1, type: :string, deprecated: false
  field :filename_prefix, 2, type: :string, json_name: "filenamePrefix"
  field :filename_suffix, 3, type: :string, json_name: "filenameSuffix"

  field :text_config, 4,
    type: Google.Pubsub.V1.CloudStorageConfig.TextConfig,
    json_name: "textConfig",
    oneof: 0

  field :avro_config, 5,
    type: Google.Pubsub.V1.CloudStorageConfig.AvroConfig,
    json_name: "avroConfig",
    oneof: 0

  field :max_duration, 6, type: Google.Protobuf.Duration, json_name: "maxDuration"
  field :max_bytes, 7, type: :int64, json_name: "maxBytes"
  field :state, 9, type: Google.Pubsub.V1.CloudStorageConfig.State, enum: true, deprecated: false
end

defmodule Google.Pubsub.V1.ReceivedMessage do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :ack_id, 1, type: :string, json_name: "ackId"
  field :message, 2, type: Google.Pubsub.V1.PubsubMessage
  field :delivery_attempt, 3, type: :int32, json_name: "deliveryAttempt"
end

defmodule Google.Pubsub.V1.GetSubscriptionRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :subscription, 1, type: :string, deprecated: false
end

defmodule Google.Pubsub.V1.UpdateSubscriptionRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :subscription, 1, type: Google.Pubsub.V1.Subscription, deprecated: false

  field :update_mask, 2,
    type: Google.Protobuf.FieldMask,
    json_name: "updateMask",
    deprecated: false
end

defmodule Google.Pubsub.V1.ListSubscriptionsRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :project, 1, type: :string, deprecated: false
  field :page_size, 2, type: :int32, json_name: "pageSize"
  field :page_token, 3, type: :string, json_name: "pageToken"
end

defmodule Google.Pubsub.V1.ListSubscriptionsResponse do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :subscriptions, 1, repeated: true, type: Google.Pubsub.V1.Subscription
  field :next_page_token, 2, type: :string, json_name: "nextPageToken"
end

defmodule Google.Pubsub.V1.DeleteSubscriptionRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :subscription, 1, type: :string, deprecated: false
end

defmodule Google.Pubsub.V1.ModifyPushConfigRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :subscription, 1, type: :string, deprecated: false

  field :push_config, 2,
    type: Google.Pubsub.V1.PushConfig,
    json_name: "pushConfig",
    deprecated: false
end

defmodule Google.Pubsub.V1.PullRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :subscription, 1, type: :string, deprecated: false
  field :return_immediately, 2, type: :bool, json_name: "returnImmediately", deprecated: true
  field :max_messages, 3, type: :int32, json_name: "maxMessages", deprecated: false
end

defmodule Google.Pubsub.V1.PullResponse do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :received_messages, 1,
    repeated: true,
    type: Google.Pubsub.V1.ReceivedMessage,
    json_name: "receivedMessages"
end

defmodule Google.Pubsub.V1.ModifyAckDeadlineRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :subscription, 1, type: :string, deprecated: false
  field :ack_ids, 4, repeated: true, type: :string, json_name: "ackIds", deprecated: false
  field :ack_deadline_seconds, 3, type: :int32, json_name: "ackDeadlineSeconds", deprecated: false
end

defmodule Google.Pubsub.V1.AcknowledgeRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :subscription, 1, type: :string, deprecated: false
  field :ack_ids, 2, repeated: true, type: :string, json_name: "ackIds", deprecated: false
end

defmodule Google.Pubsub.V1.StreamingPullRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :subscription, 1, type: :string, deprecated: false
  field :ack_ids, 2, repeated: true, type: :string, json_name: "ackIds"

  field :modify_deadline_seconds, 3,
    repeated: true,
    type: :int32,
    json_name: "modifyDeadlineSeconds"

  field :modify_deadline_ack_ids, 4,
    repeated: true,
    type: :string,
    json_name: "modifyDeadlineAckIds"

  field :stream_ack_deadline_seconds, 5,
    type: :int32,
    json_name: "streamAckDeadlineSeconds",
    deprecated: false

  field :client_id, 6, type: :string, json_name: "clientId"
  field :max_outstanding_messages, 7, type: :int64, json_name: "maxOutstandingMessages"
  field :max_outstanding_bytes, 8, type: :int64, json_name: "maxOutstandingBytes"
end

defmodule Google.Pubsub.V1.StreamingPullResponse.AcknowledgeConfirmation do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :ack_ids, 1, repeated: true, type: :string, json_name: "ackIds"
  field :invalid_ack_ids, 2, repeated: true, type: :string, json_name: "invalidAckIds"
  field :unordered_ack_ids, 3, repeated: true, type: :string, json_name: "unorderedAckIds"

  field :temporary_failed_ack_ids, 4,
    repeated: true,
    type: :string,
    json_name: "temporaryFailedAckIds"
end

defmodule Google.Pubsub.V1.StreamingPullResponse.ModifyAckDeadlineConfirmation do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :ack_ids, 1, repeated: true, type: :string, json_name: "ackIds"
  field :invalid_ack_ids, 2, repeated: true, type: :string, json_name: "invalidAckIds"

  field :temporary_failed_ack_ids, 3,
    repeated: true,
    type: :string,
    json_name: "temporaryFailedAckIds"
end

defmodule Google.Pubsub.V1.StreamingPullResponse.SubscriptionProperties do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :exactly_once_delivery_enabled, 1, type: :bool, json_name: "exactlyOnceDeliveryEnabled"
  field :message_ordering_enabled, 2, type: :bool, json_name: "messageOrderingEnabled"
end

defmodule Google.Pubsub.V1.StreamingPullResponse do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :received_messages, 1,
    repeated: true,
    type: Google.Pubsub.V1.ReceivedMessage,
    json_name: "receivedMessages"

  field :acknowledge_confirmation, 5,
    type: Google.Pubsub.V1.StreamingPullResponse.AcknowledgeConfirmation,
    json_name: "acknowledgeConfirmation"

  field :modify_ack_deadline_confirmation, 3,
    type: Google.Pubsub.V1.StreamingPullResponse.ModifyAckDeadlineConfirmation,
    json_name: "modifyAckDeadlineConfirmation"

  field :subscription_properties, 4,
    type: Google.Pubsub.V1.StreamingPullResponse.SubscriptionProperties,
    json_name: "subscriptionProperties"
end

defmodule Google.Pubsub.V1.CreateSnapshotRequest.LabelsEntry do
  @moduledoc false

  use Protobuf, map: true, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :key, 1, type: :string
  field :value, 2, type: :string
end

defmodule Google.Pubsub.V1.CreateSnapshotRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :name, 1, type: :string, deprecated: false
  field :subscription, 2, type: :string, deprecated: false

  field :labels, 3,
    repeated: true,
    type: Google.Pubsub.V1.CreateSnapshotRequest.LabelsEntry,
    map: true
end

defmodule Google.Pubsub.V1.UpdateSnapshotRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :snapshot, 1, type: Google.Pubsub.V1.Snapshot, deprecated: false

  field :update_mask, 2,
    type: Google.Protobuf.FieldMask,
    json_name: "updateMask",
    deprecated: false
end

defmodule Google.Pubsub.V1.Snapshot.LabelsEntry do
  @moduledoc false

  use Protobuf, map: true, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :key, 1, type: :string
  field :value, 2, type: :string
end

defmodule Google.Pubsub.V1.Snapshot do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :name, 1, type: :string
  field :topic, 2, type: :string, deprecated: false
  field :expire_time, 3, type: Google.Protobuf.Timestamp, json_name: "expireTime"
  field :labels, 4, repeated: true, type: Google.Pubsub.V1.Snapshot.LabelsEntry, map: true
end

defmodule Google.Pubsub.V1.GetSnapshotRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :snapshot, 1, type: :string, deprecated: false
end

defmodule Google.Pubsub.V1.ListSnapshotsRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :project, 1, type: :string, deprecated: false
  field :page_size, 2, type: :int32, json_name: "pageSize"
  field :page_token, 3, type: :string, json_name: "pageToken"
end

defmodule Google.Pubsub.V1.ListSnapshotsResponse do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :snapshots, 1, repeated: true, type: Google.Pubsub.V1.Snapshot
  field :next_page_token, 2, type: :string, json_name: "nextPageToken"
end

defmodule Google.Pubsub.V1.DeleteSnapshotRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  field :snapshot, 1, type: :string, deprecated: false
end

defmodule Google.Pubsub.V1.SeekRequest do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"

  oneof :target, 0

  field :subscription, 1, type: :string, deprecated: false
  field :time, 2, type: Google.Protobuf.Timestamp, oneof: 0
  field :snapshot, 3, type: :string, oneof: 0, deprecated: false
end

defmodule Google.Pubsub.V1.SeekResponse do
  @moduledoc false

  use Protobuf, syntax: :proto3, protoc_gen_elixir_version: "0.12.0"
end

defmodule Google.Pubsub.V1.Publisher.Service do
  @moduledoc false

  use GRPC.Service, name: "google.pubsub.v1.Publisher", protoc_gen_elixir_version: "0.12.0"

  rpc :CreateTopic, Google.Pubsub.V1.Topic, Google.Pubsub.V1.Topic

  rpc :UpdateTopic, Google.Pubsub.V1.UpdateTopicRequest, Google.Pubsub.V1.Topic

  rpc :Publish, Google.Pubsub.V1.PublishRequest, Google.Pubsub.V1.PublishResponse

  rpc :GetTopic, Google.Pubsub.V1.GetTopicRequest, Google.Pubsub.V1.Topic

  rpc :ListTopics, Google.Pubsub.V1.ListTopicsRequest, Google.Pubsub.V1.ListTopicsResponse

  rpc :ListTopicSubscriptions,
      Google.Pubsub.V1.ListTopicSubscriptionsRequest,
      Google.Pubsub.V1.ListTopicSubscriptionsResponse

  rpc :ListTopicSnapshots,
      Google.Pubsub.V1.ListTopicSnapshotsRequest,
      Google.Pubsub.V1.ListTopicSnapshotsResponse

  rpc :DeleteTopic, Google.Pubsub.V1.DeleteTopicRequest, Google.Protobuf.Empty

  rpc :DetachSubscription,
      Google.Pubsub.V1.DetachSubscriptionRequest,
      Google.Pubsub.V1.DetachSubscriptionResponse
end

defmodule Google.Pubsub.V1.Publisher.Stub do
  @moduledoc false

  use GRPC.Stub, service: Google.Pubsub.V1.Publisher.Service
end

defmodule Google.Pubsub.V1.Subscriber.Service do
  @moduledoc false

  use GRPC.Service, name: "google.pubsub.v1.Subscriber", protoc_gen_elixir_version: "0.12.0"

  rpc :CreateSubscription, Google.Pubsub.V1.Subscription, Google.Pubsub.V1.Subscription

  rpc :GetSubscription, Google.Pubsub.V1.GetSubscriptionRequest, Google.Pubsub.V1.Subscription

  rpc :UpdateSubscription,
      Google.Pubsub.V1.UpdateSubscriptionRequest,
      Google.Pubsub.V1.Subscription

  rpc :ListSubscriptions,
      Google.Pubsub.V1.ListSubscriptionsRequest,
      Google.Pubsub.V1.ListSubscriptionsResponse

  rpc :DeleteSubscription, Google.Pubsub.V1.DeleteSubscriptionRequest, Google.Protobuf.Empty

  rpc :ModifyAckDeadline, Google.Pubsub.V1.ModifyAckDeadlineRequest, Google.Protobuf.Empty

  rpc :Acknowledge, Google.Pubsub.V1.AcknowledgeRequest, Google.Protobuf.Empty

  rpc :Pull, Google.Pubsub.V1.PullRequest, Google.Pubsub.V1.PullResponse

  rpc :StreamingPull,
      stream(Google.Pubsub.V1.StreamingPullRequest),
      stream(Google.Pubsub.V1.StreamingPullResponse)

  rpc :ModifyPushConfig, Google.Pubsub.V1.ModifyPushConfigRequest, Google.Protobuf.Empty

  rpc :GetSnapshot, Google.Pubsub.V1.GetSnapshotRequest, Google.Pubsub.V1.Snapshot

  rpc :ListSnapshots,
      Google.Pubsub.V1.ListSnapshotsRequest,
      Google.Pubsub.V1.ListSnapshotsResponse

  rpc :CreateSnapshot, Google.Pubsub.V1.CreateSnapshotRequest, Google.Pubsub.V1.Snapshot

  rpc :UpdateSnapshot, Google.Pubsub.V1.UpdateSnapshotRequest, Google.Pubsub.V1.Snapshot

  rpc :DeleteSnapshot, Google.Pubsub.V1.DeleteSnapshotRequest, Google.Protobuf.Empty

  rpc :Seek, Google.Pubsub.V1.SeekRequest, Google.Pubsub.V1.SeekResponse
end

defmodule Google.Pubsub.V1.Subscriber.Stub do
  @moduledoc false

  use GRPC.Stub, service: Google.Pubsub.V1.Subscriber.Service
end