class ROM::Memory::Storage

In-memory thread-safe data storage

@private

Attributes

data[R]

Dataset registry

@return [ThreadSafe::Hash]

@api private

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