class ROM::Memory::Storage
In-memory thread-safe data storage
@private
Attributes
data[R]
Public Class Methods
new()
click to toggle source
@api private
# File lib/rom/memory/storage.rb, line 22 def initialize @data = Concurrent::Hash.new end
Public Instance Methods
[](name)
click to toggle source
@return [Dataset]
@api private
# File lib/rom/memory/storage.rb, line 29 def [](name) data[name] end
create_dataset(name)
click to toggle source
Register a new dataset
@return [Dataset]
@api private
# File lib/rom/memory/storage.rb, line 38 def create_dataset(name) data[name] = Dataset.new(Concurrent::Array.new) end
key?(name)
click to toggle source
Check if there's dataset under specified key
@return [Boolean]
@api private
# File lib/rom/memory/storage.rb, line 47 def key?(name) data.key?(name) end
size()
click to toggle source
Return registered datasets count
@return [Integer]
@api private
# File lib/rom/memory/storage.rb, line 56 def size data.size end