Class: ROM::Gateway Abstract
- Inherits:
-
Object
- Object
- ROM::Gateway
- Extended by:
- Dry::Core::ClassAttributes, Notifications::Listener
- Defined in:
- core/lib/rom/gateway.rb
Overview
Abstract gateway class
Every adapter needs to inherit from this class and implement required interface
Direct Known Subclasses
Instance Attribute Summary collapse
- #connection ⇒ Object readonly
Class Method Summary collapse
-
.adapter ⇒ Object
Get or set gateway's adapter identifier.
-
.class_from_symbol(type) ⇒ Class
private
Get gateway subclass for a specific adapter.
-
.setup(gateway_or_scheme, *args, **kwargs) ⇒ Gateway
Set up a gateway.
-
.subscribe(event_id, query = EMPTY_HASH, &block) ⇒ Object
extended
from Notifications::Listener
Subscribe to events.
Instance Method Summary collapse
-
#adapter ⇒ Symbol
Returns the adapter, defined for the class.
-
#disconnect ⇒ Object
Disconnect is optional and it's a no-op by default.
-
#logger ⇒ NilClass
A generic interface for returning default logger.
-
#transaction(opts = EMPTY_HASH, &block) ⇒ Object
Runs a block inside a transaction.
-
#use_logger ⇒ Object
abstract
A generic interface for setting up a logger.
Instance Attribute Details
#connection ⇒ Object (readonly)
37 38 39 |
# File 'core/lib/rom/gateway.rb', line 37 def connection @connection end |
Class Method Details
.adapter ⇒ Symbol .gateway(adapter) ⇒ Object
Get or set gateway's adapter identifier
33 |
# File 'core/lib/rom/gateway.rb', line 33 defines :adapter |
.class_from_symbol(type) ⇒ Class
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
Get gateway subclass for a specific adapter
110 111 112 113 114 115 116 117 118 119 120 121 122 |
# File 'core/lib/rom/gateway.rb', line 110 def self.class_from_symbol(type) adapter = ROM.adapters.fetch(type) do begin require "rom/#{type}" rescue LoadError raise AdapterLoadError, "Failed to load adapter rom/#{type}" end ROM.adapters.fetch(type) end adapter.const_get(:Gateway) end |
.setup(type, *args) ⇒ Gateway .setup(gateway) ⇒ Gateway
Set up a gateway
81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 |
# File 'core/lib/rom/gateway.rb', line 81 def self.setup(gateway_or_scheme, *args, **kwargs) case gateway_or_scheme when String raise ArgumentError, <<-STRING.gsub(/^ {10}/, '') URIs without an explicit scheme are not supported anymore. See https://github.com/rom-rb/rom/blob/master/CHANGELOG.md STRING when Symbol klass = class_from_symbol(gateway_or_scheme) if klass.instance_method(:initialize).arity.zero? klass.new else klass.new(*args, **kwargs) end else raise ArgumentError, "Can't accept arguments when passing an instance" unless args.empty? gateway_or_scheme end end |
.subscribe(event_id, query = EMPTY_HASH, &block) ⇒ Object Originally defined in module Notifications::Listener
Subscribe to events
Instance Method Details
#adapter ⇒ Symbol
Returns the adapter, defined for the class
129 130 131 132 133 134 |
# File 'core/lib/rom/gateway.rb', line 129 def adapter self.class.adapter || raise( MissingAdapterIdentifierError, "gateway class +#{self}+ is missing the adapter identifier" ) end |
#disconnect ⇒ Object
Disconnect is optional and it's a no-op by default
162 163 164 |
# File 'core/lib/rom/gateway.rb', line 162 def disconnect # noop end |
#logger ⇒ NilClass
A generic interface for returning default logger
Adapters should implement this method as handling loggers is different across adapters. This is a no-op by default and returns nil.
155 156 157 |
# File 'core/lib/rom/gateway.rb', line 155 def logger # noop end |
#transaction(opts = EMPTY_HASH, &block) ⇒ Object
Runs a block inside a transaction. The underlying transaction engine is adapter-specific
175 176 177 |
# File 'core/lib/rom/gateway.rb', line 175 def transaction(opts = EMPTY_HASH, &block) transaction_runner(opts).run(opts, &block) end |
#use_logger ⇒ Object
A generic interface for setting up a logger
This is not a required interface, it's a no-op by default
143 144 145 |
# File 'core/lib/rom/gateway.rb', line 143 def use_logger(*) # noop end |