Class: ConvertSdk::Stores::MemoryStore

Inherits:
Object
  • Object
show all
Defined in:
lib/convert_sdk/stores/memory_store.rb

Overview

The default in-process store: a plain +Hash+ guarded by a +Mutex+.

+MemoryStore+ is what DataStoreManager falls back to when no custom store is supplied (or a supplied store fails validation). It satisfies the duck-typed store contract — +#get+ / +#set+ — with both operations serialized through a single mutex so concurrent reads and writes from multiple threads cannot corrupt the underlying +Hash+ or lose a write.

== Per-process limitation

State lives only in this process's memory. It is NOT shared across processes, workers, or machines: sticky bucketing (Story 2.11) and goal deduplication (Story 4.3) that round-trip through a +MemoryStore+ are therefore consistent only within the lifetime of a single process. A forked web worker, a restarted process, or a second host each start with an empty store. For cross-process stickiness and dedup, supply a shared backing store — +RedisStore+ (Story 2.2) is the first-party option.

== Thread safety

All access to the backing +Hash+ is serialized by +@mutex+; there is no public path to the +Hash+ that bypasses the lock.

Instance Method Summary collapse

Constructor Details

#initialize ⇒ MemoryStore

Returns a new instance of MemoryStore.



31
32
33
34
35
 
# File 'lib/convert_sdk/stores/memory_store.rb', line 31

def initialize
  # Thread safety: guarded by @mutex.
  @data = {}
  @mutex = Thread::Mutex.new
end

Instance Method Details

#get(key) ⇒ Object?

Read the value stored under +key+.

Parameters:

  • key (String) —

    the lookup key.

Returns:

  • (Object, nil) —

    the stored value, or +nil+ if the key is absent.



41
42
43
 
# File 'lib/convert_sdk/stores/memory_store.rb', line 41

def get(key)
  @mutex.synchronize { @data[key] }
end

#set(key, value) ⇒ Object

Store +value+ under +key+, overwriting any existing value.

Parameters:

  • key (String) —

    the storage key.

  • value (Object) —

    the value to store.

Returns:

  • (Object) —

    the stored value.



50
51
52
 
# File 'lib/convert_sdk/stores/memory_store.rb', line 50

def set(key, value)
  @mutex.synchronize { @data[key] = value }
end