class Google::Cloud::PubSub::V1::Subscriber::Client::Configuration::Rpcs

Configuration RPC class for the Subscriber API.

Includes fields providing the configuration for each RPC in this service. Each configuration object is of type `Gapic::Config::Method` and includes the following configuration fields:

*  `timeout` (*type:* `Numeric`) - The call timeout in seconds
*  `metadata` (*type:* `Hash{Symbol=>String}`) - Additional gRPC headers
*  `retry_policy (*type:* `Hash`) - The retry policy. The policy fields
   include the following keys:
    *  `:initial_delay` (*type:* `Numeric`) - The initial delay in seconds.
    *  `:max_delay` (*type:* `Numeric`) - The max delay in seconds.
    *  `:multiplier` (*type:* `Numeric`) - The incremental backoff multiplier.
    *  `:retry_codes` (*type:* `Array<String>`) - The error codes that should
       trigger a retry.

Attributes

acknowledge[R]

RPC-specific configuration for `acknowledge` @return [::Gapic::Config::Method]

create_snapshot[R]

RPC-specific configuration for `create_snapshot` @return [::Gapic::Config::Method]

create_subscription[R]

RPC-specific configuration for `create_subscription` @return [::Gapic::Config::Method]

delete_snapshot[R]

RPC-specific configuration for `delete_snapshot` @return [::Gapic::Config::Method]

delete_subscription[R]

RPC-specific configuration for `delete_subscription` @return [::Gapic::Config::Method]

get_snapshot[R]

RPC-specific configuration for `get_snapshot` @return [::Gapic::Config::Method]

get_subscription[R]

RPC-specific configuration for `get_subscription` @return [::Gapic::Config::Method]

list_snapshots[R]

RPC-specific configuration for `list_snapshots` @return [::Gapic::Config::Method]

list_subscriptions[R]

RPC-specific configuration for `list_subscriptions` @return [::Gapic::Config::Method]

modify_ack_deadline[R]

RPC-specific configuration for `modify_ack_deadline` @return [::Gapic::Config::Method]

modify_push_config[R]

RPC-specific configuration for `modify_push_config` @return [::Gapic::Config::Method]

pull[R]

RPC-specific configuration for `pull` @return [::Gapic::Config::Method]

seek[R]

RPC-specific configuration for `seek` @return [::Gapic::Config::Method]

streaming_pull[R]

RPC-specific configuration for `streaming_pull` @return [::Gapic::Config::Method]

update_snapshot[R]

RPC-specific configuration for `update_snapshot` @return [::Gapic::Config::Method]

update_subscription[R]

RPC-specific configuration for `update_subscription` @return [::Gapic::Config::Method]

Public Class Methods

new(parent_rpcs = nil) { |self| ... } click to toggle source

@private

# File lib/google/cloud/pubsub/v1/subscriber/client.rb, line 1790
def initialize parent_rpcs = nil
  create_subscription_config = parent_rpcs.create_subscription if parent_rpcs.respond_to? :create_subscription
  @create_subscription = ::Gapic::Config::Method.new create_subscription_config
  get_subscription_config = parent_rpcs.get_subscription if parent_rpcs.respond_to? :get_subscription
  @get_subscription = ::Gapic::Config::Method.new get_subscription_config
  update_subscription_config = parent_rpcs.update_subscription if parent_rpcs.respond_to? :update_subscription
  @update_subscription = ::Gapic::Config::Method.new update_subscription_config
  list_subscriptions_config = parent_rpcs.list_subscriptions if parent_rpcs.respond_to? :list_subscriptions
  @list_subscriptions = ::Gapic::Config::Method.new list_subscriptions_config
  delete_subscription_config = parent_rpcs.delete_subscription if parent_rpcs.respond_to? :delete_subscription
  @delete_subscription = ::Gapic::Config::Method.new delete_subscription_config
  modify_ack_deadline_config = parent_rpcs.modify_ack_deadline if parent_rpcs.respond_to? :modify_ack_deadline
  @modify_ack_deadline = ::Gapic::Config::Method.new modify_ack_deadline_config
  acknowledge_config = parent_rpcs.acknowledge if parent_rpcs.respond_to? :acknowledge
  @acknowledge = ::Gapic::Config::Method.new acknowledge_config
  pull_config = parent_rpcs.pull if parent_rpcs.respond_to? :pull
  @pull = ::Gapic::Config::Method.new pull_config
  streaming_pull_config = parent_rpcs.streaming_pull if parent_rpcs.respond_to? :streaming_pull
  @streaming_pull = ::Gapic::Config::Method.new streaming_pull_config
  modify_push_config_config = parent_rpcs.modify_push_config if parent_rpcs.respond_to? :modify_push_config
  @modify_push_config = ::Gapic::Config::Method.new modify_push_config_config
  get_snapshot_config = parent_rpcs.get_snapshot if parent_rpcs.respond_to? :get_snapshot
  @get_snapshot = ::Gapic::Config::Method.new get_snapshot_config
  list_snapshots_config = parent_rpcs.list_snapshots if parent_rpcs.respond_to? :list_snapshots
  @list_snapshots = ::Gapic::Config::Method.new list_snapshots_config
  create_snapshot_config = parent_rpcs.create_snapshot if parent_rpcs.respond_to? :create_snapshot
  @create_snapshot = ::Gapic::Config::Method.new create_snapshot_config
  update_snapshot_config = parent_rpcs.update_snapshot if parent_rpcs.respond_to? :update_snapshot
  @update_snapshot = ::Gapic::Config::Method.new update_snapshot_config
  delete_snapshot_config = parent_rpcs.delete_snapshot if parent_rpcs.respond_to? :delete_snapshot
  @delete_snapshot = ::Gapic::Config::Method.new delete_snapshot_config
  seek_config = parent_rpcs.seek if parent_rpcs.respond_to? :seek
  @seek = ::Gapic::Config::Method.new seek_config

  yield self if block_given?
end