Module: Hanami::Events::CloudPubsub

Extended by:
Dry::Configurable
Defined in:
lib/hanami/events/cloud_pubsub.rb,
lib/hanami/events/cloud_pubsub/cli.rb,
lib/hanami/events/cloud_pubsub/errors.rb,
lib/hanami/events/cloud_pubsub/runner.rb,
lib/hanami/events/cloud_pubsub/version.rb,
lib/hanami/events/cloud_pubsub/listener.rb,
lib/hanami/events/cloud_pubsub/register.rb,
lib/hanami/events/cloud_pubsub/subscriber.rb,
lib/hanami/events/cloud_pubsub/integration.rb,
lib/hanami/events/cloud_pubsub/middleware/stack.rb,
lib/hanami/events/cloud_pubsub/thread_inspector.rb,
lib/hanami/events/cloud_pubsub/middleware/logging.rb,
lib/hanami/events/cloud_pubsub/safe_error_handler.rb,
lib/hanami/events/cloud_pubsub/health_check_server.rb,
lib/hanami/events/cloud_pubsub/middleware/prometheus.rb,
lib/hanami/events/cloud_pubsub/middleware/request_id.rb,
lib/hanami/events/cloud_pubsub/middleware/client/request_id.rb

Overview

CloudPubsub

Defined Under Namespace

Modules: CLI, Errors, Integration, Middleware, Register, SafeErrorHandler Classes: HealthCheckServer, Listener, Runner, Subscriber, ThreadInspector

Constant Summary collapse

VERSION = 
'3.3.0'

Class Method Summary collapse

Class Method Details

.finalize_settings! ⇒ Object 



98
99
100
101
102
 
# File 'lib/hanami/events/cloud_pubsub.rb', line 98

def self.finalize_settings!
  require 'google/cloud/pubsub'
  conf_hash = config.pubsub
  conf_hash.each { |key, val| Google::Cloud::Pubsub.configure[key] = val }
end