defmodule Google.Pubsub.V1.MessageStoragePolicy do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          allowed_persistence_regions: [String.t()]
        }
  defstruct [:allowed_persistence_regions]

  field :allowed_persistence_regions, 1, repeated: true, type: :string
end

defmodule Google.Pubsub.V1.Topic.LabelsEntry do
  @moduledoc false
  use Protobuf, map: true, syntax: :proto3

  @type t :: %__MODULE__{
          key: String.t(),
          value: String.t()
        }
  defstruct [:key, :value]

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

defmodule Google.Pubsub.V1.Topic do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          name: String.t(),
          labels: %{String.t() => String.t()},
          message_storage_policy: Google.Pubsub.V1.MessageStoragePolicy.t() | nil,
          kms_key_name: String.t()
        }
  defstruct [:name, :labels, :message_storage_policy, :kms_key_name]

  field :name, 1, type: :string
  field :labels, 2, repeated: true, type: Google.Pubsub.V1.Topic.LabelsEntry, map: true
  field :message_storage_policy, 3, type: Google.Pubsub.V1.MessageStoragePolicy
  field :kms_key_name, 5, type: :string
end

defmodule Google.Pubsub.V1.PubsubMessage.AttributesEntry do
  @moduledoc false
  use Protobuf, map: true, syntax: :proto3

  @type t :: %__MODULE__{
          key: String.t(),
          value: String.t()
        }
  defstruct [:key, :value]

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

defmodule Google.Pubsub.V1.PubsubMessage do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          data: binary,
          attributes: %{String.t() => String.t()},
          message_id: String.t(),
          publish_time: Google.Protobuf.Timestamp.t() | nil,
          ordering_key: String.t()
        }
  defstruct [:data, :attributes, :message_id, :publish_time, :ordering_key]

  field :data, 1, type: :bytes

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

  field :message_id, 3, type: :string
  field :publish_time, 4, type: Google.Protobuf.Timestamp
  field :ordering_key, 5, type: :string
end

defmodule Google.Pubsub.V1.GetTopicRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          topic: String.t()
        }
  defstruct [:topic]

  field :topic, 1, type: :string
end

defmodule Google.Pubsub.V1.UpdateTopicRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          topic: Google.Pubsub.V1.Topic.t() | nil,
          update_mask: Google.Protobuf.FieldMask.t() | nil
        }
  defstruct [:topic, :update_mask]

  field :topic, 1, type: Google.Pubsub.V1.Topic
  field :update_mask, 2, type: Google.Protobuf.FieldMask
end

defmodule Google.Pubsub.V1.PublishRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          topic: String.t(),
          messages: [Google.Pubsub.V1.PubsubMessage.t()]
        }
  defstruct [:topic, :messages]

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

defmodule Google.Pubsub.V1.PublishResponse do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          message_ids: [String.t()]
        }
  defstruct [:message_ids]

  field :message_ids, 1, repeated: true, type: :string
end

defmodule Google.Pubsub.V1.ListTopicsRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          project: String.t(),
          page_size: integer,
          page_token: String.t()
        }
  defstruct [:project, :page_size, :page_token]

  field :project, 1, type: :string
  field :page_size, 2, type: :int32
  field :page_token, 3, type: :string
end

defmodule Google.Pubsub.V1.ListTopicsResponse do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          topics: [Google.Pubsub.V1.Topic.t()],
          next_page_token: String.t()
        }
  defstruct [:topics, :next_page_token]

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

defmodule Google.Pubsub.V1.ListTopicSubscriptionsRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          topic: String.t(),
          page_size: integer,
          page_token: String.t()
        }
  defstruct [:topic, :page_size, :page_token]

  field :topic, 1, type: :string
  field :page_size, 2, type: :int32
  field :page_token, 3, type: :string
end

defmodule Google.Pubsub.V1.ListTopicSubscriptionsResponse do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          subscriptions: [String.t()],
          next_page_token: String.t()
        }
  defstruct [:subscriptions, :next_page_token]

  field :subscriptions, 1, repeated: true, type: :string
  field :next_page_token, 2, type: :string
end

defmodule Google.Pubsub.V1.ListTopicSnapshotsRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          topic: String.t(),
          page_size: integer,
          page_token: String.t()
        }
  defstruct [:topic, :page_size, :page_token]

  field :topic, 1, type: :string
  field :page_size, 2, type: :int32
  field :page_token, 3, type: :string
end

defmodule Google.Pubsub.V1.ListTopicSnapshotsResponse do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          snapshots: [String.t()],
          next_page_token: String.t()
        }
  defstruct [:snapshots, :next_page_token]

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

defmodule Google.Pubsub.V1.DeleteTopicRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          topic: String.t()
        }
  defstruct [:topic]

  field :topic, 1, type: :string
end

defmodule Google.Pubsub.V1.Subscription.LabelsEntry do
  @moduledoc false
  use Protobuf, map: true, syntax: :proto3

  @type t :: %__MODULE__{
          key: String.t(),
          value: String.t()
        }
  defstruct [:key, :value]

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

defmodule Google.Pubsub.V1.Subscription do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          name: String.t(),
          topic: String.t(),
          push_config: Google.Pubsub.V1.PushConfig.t() | nil,
          ack_deadline_seconds: integer,
          retain_acked_messages: boolean,
          message_retention_duration: Google.Protobuf.Duration.t() | nil,
          labels: %{String.t() => String.t()},
          enable_message_ordering: boolean,
          expiration_policy: Google.Pubsub.V1.ExpirationPolicy.t() | nil,
          filter: String.t(),
          dead_letter_policy: Google.Pubsub.V1.DeadLetterPolicy.t() | nil,
          retry_policy: Google.Pubsub.V1.RetryPolicy.t() | nil
        }
  defstruct [
    :name,
    :topic,
    :push_config,
    :ack_deadline_seconds,
    :retain_acked_messages,
    :message_retention_duration,
    :labels,
    :enable_message_ordering,
    :expiration_policy,
    :filter,
    :dead_letter_policy,
    :retry_policy
  ]

  field :name, 1, type: :string
  field :topic, 2, type: :string
  field :push_config, 4, type: Google.Pubsub.V1.PushConfig
  field :ack_deadline_seconds, 5, type: :int32
  field :retain_acked_messages, 7, type: :bool
  field :message_retention_duration, 8, type: Google.Protobuf.Duration
  field :labels, 9, repeated: true, type: Google.Pubsub.V1.Subscription.LabelsEntry, map: true
  field :enable_message_ordering, 10, type: :bool
  field :expiration_policy, 11, type: Google.Pubsub.V1.ExpirationPolicy
  field :filter, 12, type: :string
  field :dead_letter_policy, 13, type: Google.Pubsub.V1.DeadLetterPolicy
  field :retry_policy, 14, type: Google.Pubsub.V1.RetryPolicy
end

defmodule Google.Pubsub.V1.RetryPolicy do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          minimum_backoff: Google.Protobuf.Duration.t() | nil,
          maximum_backoff: Google.Protobuf.Duration.t() | nil
        }
  defstruct [:minimum_backoff, :maximum_backoff]

  field :minimum_backoff, 1, type: Google.Protobuf.Duration
  field :maximum_backoff, 2, type: Google.Protobuf.Duration
end

defmodule Google.Pubsub.V1.DeadLetterPolicy do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          dead_letter_topic: String.t(),
          max_delivery_attempts: integer
        }
  defstruct [:dead_letter_topic, :max_delivery_attempts]

  field :dead_letter_topic, 1, type: :string
  field :max_delivery_attempts, 2, type: :int32
end

defmodule Google.Pubsub.V1.ExpirationPolicy do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          ttl: Google.Protobuf.Duration.t() | nil
        }
  defstruct [:ttl]

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

defmodule Google.Pubsub.V1.PushConfig.OidcToken do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          service_account_email: String.t(),
          audience: String.t()
        }
  defstruct [:service_account_email, :audience]

  field :service_account_email, 1, type: :string
  field :audience, 2, type: :string
end

defmodule Google.Pubsub.V1.PushConfig.AttributesEntry do
  @moduledoc false
  use Protobuf, map: true, syntax: :proto3

  @type t :: %__MODULE__{
          key: String.t(),
          value: String.t()
        }
  defstruct [:key, :value]

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

defmodule Google.Pubsub.V1.PushConfig do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          authentication_method: {atom, any},
          push_endpoint: String.t(),
          attributes: %{String.t() => String.t()}
        }
  defstruct [:authentication_method, :push_endpoint, :attributes]

  oneof :authentication_method, 0
  field :push_endpoint, 1, type: :string

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

  field :oidc_token, 3, type: Google.Pubsub.V1.PushConfig.OidcToken, oneof: 0
end

defmodule Google.Pubsub.V1.ReceivedMessage do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          ack_id: String.t(),
          message: Google.Pubsub.V1.PubsubMessage.t() | nil,
          delivery_attempt: integer
        }
  defstruct [:ack_id, :message, :delivery_attempt]

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

defmodule Google.Pubsub.V1.GetSubscriptionRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          subscription: String.t()
        }
  defstruct [:subscription]

  field :subscription, 1, type: :string
end

defmodule Google.Pubsub.V1.UpdateSubscriptionRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          subscription: Google.Pubsub.V1.Subscription.t() | nil,
          update_mask: Google.Protobuf.FieldMask.t() | nil
        }
  defstruct [:subscription, :update_mask]

  field :subscription, 1, type: Google.Pubsub.V1.Subscription
  field :update_mask, 2, type: Google.Protobuf.FieldMask
end

defmodule Google.Pubsub.V1.ListSubscriptionsRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          project: String.t(),
          page_size: integer,
          page_token: String.t()
        }
  defstruct [:project, :page_size, :page_token]

  field :project, 1, type: :string
  field :page_size, 2, type: :int32
  field :page_token, 3, type: :string
end

defmodule Google.Pubsub.V1.ListSubscriptionsResponse do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          subscriptions: [Google.Pubsub.V1.Subscription.t()],
          next_page_token: String.t()
        }
  defstruct [:subscriptions, :next_page_token]

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

defmodule Google.Pubsub.V1.DeleteSubscriptionRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          subscription: String.t()
        }
  defstruct [:subscription]

  field :subscription, 1, type: :string
end

defmodule Google.Pubsub.V1.ModifyPushConfigRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          subscription: String.t(),
          push_config: Google.Pubsub.V1.PushConfig.t() | nil
        }
  defstruct [:subscription, :push_config]

  field :subscription, 1, type: :string
  field :push_config, 2, type: Google.Pubsub.V1.PushConfig
end

defmodule Google.Pubsub.V1.PullRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          subscription: String.t(),
          return_immediately: boolean,
          max_messages: integer
        }
  defstruct [:subscription, :return_immediately, :max_messages]

  field :subscription, 1, type: :string
  field :return_immediately, 2, type: :bool, deprecated: true
  field :max_messages, 3, type: :int32
end

defmodule Google.Pubsub.V1.PullResponse do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          received_messages: [Google.Pubsub.V1.ReceivedMessage.t()]
        }
  defstruct [:received_messages]

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

defmodule Google.Pubsub.V1.ModifyAckDeadlineRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          subscription: String.t(),
          ack_ids: [String.t()],
          ack_deadline_seconds: integer
        }
  defstruct [:subscription, :ack_ids, :ack_deadline_seconds]

  field :subscription, 1, type: :string
  field :ack_ids, 4, repeated: true, type: :string
  field :ack_deadline_seconds, 3, type: :int32
end

defmodule Google.Pubsub.V1.AcknowledgeRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          subscription: String.t(),
          ack_ids: [String.t()]
        }
  defstruct [:subscription, :ack_ids]

  field :subscription, 1, type: :string
  field :ack_ids, 2, repeated: true, type: :string
end

defmodule Google.Pubsub.V1.StreamingPullRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          subscription: String.t(),
          ack_ids: [String.t()],
          modify_deadline_seconds: [integer],
          modify_deadline_ack_ids: [String.t()],
          stream_ack_deadline_seconds: integer,
          client_id: String.t()
        }
  defstruct [
    :subscription,
    :ack_ids,
    :modify_deadline_seconds,
    :modify_deadline_ack_ids,
    :stream_ack_deadline_seconds,
    :client_id
  ]

  field :subscription, 1, type: :string
  field :ack_ids, 2, repeated: true, type: :string
  field :modify_deadline_seconds, 3, repeated: true, type: :int32
  field :modify_deadline_ack_ids, 4, repeated: true, type: :string
  field :stream_ack_deadline_seconds, 5, type: :int32
  field :client_id, 6, type: :string
end

defmodule Google.Pubsub.V1.StreamingPullResponse do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          received_messages: [Google.Pubsub.V1.ReceivedMessage.t()]
        }
  defstruct [:received_messages]

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

defmodule Google.Pubsub.V1.CreateSnapshotRequest.LabelsEntry do
  @moduledoc false
  use Protobuf, map: true, syntax: :proto3

  @type t :: %__MODULE__{
          key: String.t(),
          value: String.t()
        }
  defstruct [:key, :value]

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

defmodule Google.Pubsub.V1.CreateSnapshotRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          name: String.t(),
          subscription: String.t(),
          labels: %{String.t() => String.t()}
        }
  defstruct [:name, :subscription, :labels]

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

  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

  @type t :: %__MODULE__{
          snapshot: Google.Pubsub.V1.Snapshot.t() | nil,
          update_mask: Google.Protobuf.FieldMask.t() | nil
        }
  defstruct [:snapshot, :update_mask]

  field :snapshot, 1, type: Google.Pubsub.V1.Snapshot
  field :update_mask, 2, type: Google.Protobuf.FieldMask
end

defmodule Google.Pubsub.V1.Snapshot.LabelsEntry do
  @moduledoc false
  use Protobuf, map: true, syntax: :proto3

  @type t :: %__MODULE__{
          key: String.t(),
          value: String.t()
        }
  defstruct [:key, :value]

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

defmodule Google.Pubsub.V1.Snapshot do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          name: String.t(),
          topic: String.t(),
          expire_time: Google.Protobuf.Timestamp.t() | nil,
          labels: %{String.t() => String.t()}
        }
  defstruct [:name, :topic, :expire_time, :labels]

  field :name, 1, type: :string
  field :topic, 2, type: :string
  field :expire_time, 3, type: Google.Protobuf.Timestamp
  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

  @type t :: %__MODULE__{
          snapshot: String.t()
        }
  defstruct [:snapshot]

  field :snapshot, 1, type: :string
end

defmodule Google.Pubsub.V1.ListSnapshotsRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          project: String.t(),
          page_size: integer,
          page_token: String.t()
        }
  defstruct [:project, :page_size, :page_token]

  field :project, 1, type: :string
  field :page_size, 2, type: :int32
  field :page_token, 3, type: :string
end

defmodule Google.Pubsub.V1.ListSnapshotsResponse do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          snapshots: [Google.Pubsub.V1.Snapshot.t()],
          next_page_token: String.t()
        }
  defstruct [:snapshots, :next_page_token]

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

defmodule Google.Pubsub.V1.DeleteSnapshotRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          snapshot: String.t()
        }
  defstruct [:snapshot]

  field :snapshot, 1, type: :string
end

defmodule Google.Pubsub.V1.SeekRequest do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{
          target: {atom, any},
          subscription: String.t()
        }
  defstruct [:target, :subscription]

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

defmodule Google.Pubsub.V1.SeekResponse do
  @moduledoc false
  use Protobuf, syntax: :proto3

  @type t :: %__MODULE__{}
  defstruct []
end

defmodule Google.Pubsub.V1.Publisher.Service do
  @moduledoc false
  use GRPC.Service, name: "google.pubsub.v1.Publisher"

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

  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