Class: Parse::AtlasSearch::Session::MemoryCache

Inherits:
Object
  • Object
show all
Defined in:
lib/parse/atlas_search/session.rb

Overview

Default cache: in-memory hash with per-entry TTL, guarded by a +Mutex+. Suitable for single-process apps. Apps running multi-process (Puma workers, Sidekiq processes) get a per- process cache — install a shared cache through Parse::AtlasSearch.session_cache= for cross-process sharing.

Instance Method Summary collapse

Constructor Details

#initialize ⇒ MemoryCache

Returns a new instance of MemoryCache.



58
59
60
61
 
# File 'lib/parse/atlas_search/session.rb', line 58

def initialize
  @data = {}
  @mutex = Mutex.new
end

Instance Method Details

#clear ⇒ Object

Drop every entry. Used by Parse::AtlasSearch::Session.reset_caches! and by tests that need a clean slate.



95
96
97
 
# File 'lib/parse/atlas_search/session.rb', line 95

def clear
  @mutex.synchronize { @data.clear }
end

#get(key) ⇒ Object?

Returns the cached value, or +nil+ when the key is missing or its TTL has elapsed. Expired entries are evicted lazily on read.

Parameters:

Returns:

  • (Object, nil) —

    the cached value, or +nil+ when the key is missing or its TTL has elapsed. Expired entries are evicted lazily on read.



67
68
69
70
71
72
73
74
75
76
77
 
# File 'lib/parse/atlas_search/session.rb', line 67

def get(key)
  @mutex.synchronize do
    entry = @data[key]
    return nil if entry.nil?
    if entry[:expires_at] < Time.now
      @data.delete(key)
      return nil
    end
    entry[:value]
  end
end

#invalidate(key) ⇒ Object

Parameters:

  • key (String) —

    cache key to forget.



89
90
91
 
# File 'lib/parse/atlas_search/session.rb', line 89

def invalidate(key)
  @mutex.synchronize { @data.delete(key) }
end

#set(key, value, ttl:) ⇒ Object

Parameters:

  • key (String)
  • value (Object)
  • ttl (Numeric) —

    seconds until the entry expires.



82
83
84
85
86
 
# File 'lib/parse/atlas_search/session.rb', line 82

def set(key, value, ttl:)
  @mutex.synchronize do
    @data[key] = { value: value, expires_at: Time.now + ttl }
  end
end