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

Configuration RPC class for the Publisher 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

create_topic[R]

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

delete_topic[R]

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

detach_subscription[R]

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

get_topic[R]

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

list_topic_snapshots[R]

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

list_topic_subscriptions[R]

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

list_topics[R]

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

publish[R]

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

update_topic[R]

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

Public Class Methods

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

@private

# File lib/google/cloud/pubsub/v1/publisher/client.rb, line 1066
def initialize parent_rpcs = nil
  create_topic_config = parent_rpcs.create_topic if parent_rpcs.respond_to? :create_topic
  @create_topic = ::Gapic::Config::Method.new create_topic_config
  update_topic_config = parent_rpcs.update_topic if parent_rpcs.respond_to? :update_topic
  @update_topic = ::Gapic::Config::Method.new update_topic_config
  publish_config = parent_rpcs.publish if parent_rpcs.respond_to? :publish
  @publish = ::Gapic::Config::Method.new publish_config
  get_topic_config = parent_rpcs.get_topic if parent_rpcs.respond_to? :get_topic
  @get_topic = ::Gapic::Config::Method.new get_topic_config
  list_topics_config = parent_rpcs.list_topics if parent_rpcs.respond_to? :list_topics
  @list_topics = ::Gapic::Config::Method.new list_topics_config
  list_topic_subscriptions_config = parent_rpcs.list_topic_subscriptions if parent_rpcs.respond_to? :list_topic_subscriptions
  @list_topic_subscriptions = ::Gapic::Config::Method.new list_topic_subscriptions_config
  list_topic_snapshots_config = parent_rpcs.list_topic_snapshots if parent_rpcs.respond_to? :list_topic_snapshots
  @list_topic_snapshots = ::Gapic::Config::Method.new list_topic_snapshots_config
  delete_topic_config = parent_rpcs.delete_topic if parent_rpcs.respond_to? :delete_topic
  @delete_topic = ::Gapic::Config::Method.new delete_topic_config
  detach_subscription_config = parent_rpcs.detach_subscription if parent_rpcs.respond_to? :detach_subscription
  @detach_subscription = ::Gapic::Config::Method.new detach_subscription_config

  yield self if block_given?
end