class RubyEventStore::ROM::Memory::SpecHelper
Attributes
close_pool_connection[R]
connection_pool_size[R]
env[R]
Public Class Methods
new()
click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 45 def initialize @connection_pool_size = 5 @env = ROM.setup(:memory) end
Public Instance Methods
close_gateway_connection()
click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 64 def close_gateway_connection gateway.disconnect end
drop_gateway_schema()
click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 60 def drop_gateway_schema gateway.connection.data.values.each { |v| v.data.clear } end
gateway()
click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 56 def gateway env.rom_container.gateways.fetch(:default) end
gateway_type?(name)
click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 68 def gateway_type?(name) name == :memory end
has_connection_pooling?()
click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 72 def has_connection_pooling? true end
run_lifecycle() { || ... }
click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 50 def run_lifecycle yield ensure drop_gateway_schema end
supports_upsert?()
click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 76 def supports_upsert? true end