Class: Thingfish::Datastore::Memory

Inherits:
Thingfish::Datastore show all
Extended by:
Loggability
Defined in:
lib/thingfish/datastore/memory.rb

Overview

An in-memory datastore for testing and tryout purposes.

Instance Method Summary collapse

Methods inherited from Thingfish::Datastore

#inspect, #transaction

Methods included from Normalization

make_object_id, normalize_key, normalize_keys, normalize_oid

Constructor Details

#initialize(storage = {}) ⇒ Memory

Create a new MemoryDatastore, using the given storage object to store data in. The storage should quack like a Hash.



19
20
21
 
# File 'lib/thingfish/datastore/memory.rb', line 19

def initialize( storage={} )
  @storage = storage
end

Instance Method Details

#each(&block) ⇒ Object

Iterator – yield a pair:

UUID => datablob

of each object in the datastore to the block, or return an Enumerator for each UUID if called without a block.



88
89
90
 
# File 'lib/thingfish/datastore/memory.rb', line 88

def each( &block )
  return @storage.each( &block )
end

#each_oid(&block) ⇒ Object

Iterator – yield the UUID of each object in the datastore to the block, or return an Enumerator for each UUID if called without a block.



79
80
81
 
# File 'lib/thingfish/datastore/memory.rb', line 79

def each_oid( &block )
  return @storage.each_key( &block )
end

#fetch(oid) ⇒ Object

Fetch the data corresponding to the given oid as an IOish object.



55
56
57
58
59
60
 
# File 'lib/thingfish/datastore/memory.rb', line 55

def fetch( oid )
  oid = normalize_oid( oid )
  self.log.debug "Fetching data for OID %s" % [ oid ]
  data = @storage[ oid ] or return nil
  return StringIO.new( data )
end

#include?(oid) ⇒ Boolean

Return true if the datastore has data associated with the specified oid.

Returns:

  • (Boolean) 


71
72
73
74
 
# File 'lib/thingfish/datastore/memory.rb', line 71

def include?( oid )
  oid = normalize_oid( oid )
  return @storage.include?( oid )
end

#remove(oid) ⇒ Object

Remove the data associated with oid from the Datastore.



64
65
66
67
 
# File 'lib/thingfish/datastore/memory.rb', line 64

def remove( oid )
  oid = normalize_oid( oid )
  @storage.delete( oid )
end

#replace(oid, io) ⇒ Object

Replace the existing object associated with oid with the data read from the given io.



41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/thingfish/datastore/memory.rb', line 41

def replace( oid, io )
  offset = io.pos
  data = io.read.dup
  oid = normalize_oid( oid )

  self.log.debug "Replacing data under OID %s with %d bytes" % [ oid, data.bytesize ]
  @storage[ oid ] = data

  io.pos = offset
  return true
end

#save(io) ⇒ Object

Save the data read from the specified io and return an ID that can be used to fetch it later.



26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/thingfish/datastore/memory.rb', line 26

def save( io )
  oid = make_object_id()
  offset = io.pos
  data = io.read.dup

  self.log.debug "Saving %d bytes of data under OID %s" % [ data.bytesize, oid ]
  @storage[ oid ] = data

  io.pos = offset
  return oid
end