module Nutella::Persist

Implements basic run-dependent persistence for run-level components

Public Class Methods

get_json_collection_store( name ) click to toggle source

This method returns a JSON-file-backed store (i.e. persistence) for a collection (i.e. an Array) @param [String] name the name of the store @return [JSONFilePersistedCollection] a JSON-file-backed collection store

# File lib/nutella_lib/persist.rb, line 35
def self.get_json_collection_store( name )
  dir_path = "data/#{Nutella.run_id}"
  file_path = "data/#{Nutella.run_id}/#{name}.json"
  FileUtils.mkdir_p dir_path
  JSONFilePersistedCollection.new file_path
end
get_json_object_store( name ) click to toggle source

This method returns a JSON-file-backed store (i.e. persistence) for a single object (i.e. an Hash) @param [String] name the name of the store @return [JSONFilePersistedHash] a JSON-file-backed Hash store

# File lib/nutella_lib/persist.rb, line 46
def self.get_json_object_store( name )
  dir_path = "data/#{Nutella.run_id}"
  file_path = "data/#{Nutella.run_id}/#{name}.json"
  FileUtils.mkdir_p dir_path
  JSONFilePersistedHash.new file_path
end
get_mongo_collection_store( name ) click to toggle source

This method returns a MongoDB-backed store (i.e. persistence) for a collection (i.e. an Array) @param [String] name the name of the store @return [MongoPersistedCollection] a MongoDB-backed collection store

# File lib/nutella_lib/persist.rb, line 17
def self.get_mongo_collection_store( name )
  collection = "#{Nutella.run_id}/#{name}"
  MongoPersistedCollection.new Nutella.mongo_host, Nutella.app_id, collection
end
get_mongo_object_store( name ) click to toggle source

This method returns a MongoDB-backed store (i.e. persistence) for a single object (i.e. an Hash) @param [String] name the name of the store @return [MongoPersistedHash] a MongoDB-backed Hash store

# File lib/nutella_lib/persist.rb, line 26
def self.get_mongo_object_store( name )
  doc_id = "#{Nutella.run_id}/#{name}"
  MongoPersistedHash.new Nutella.mongo_host, Nutella.app_id, 'run_persisted_hashes', doc_id
end