class Novel::RepositoryAdapters::Redis

Attributes

connection_pool[R]

Public Class Methods

new(connection_pool:) click to toggle source
# File lib/novel/repository_adapters/redis.rb, line 6
def initialize(connection_pool:)
  @connection_pool = connection_pool
end

Public Instance Methods

find_context(saga_id) click to toggle source
# File lib/novel/repository_adapters/redis.rb, line 10
def find_context(saga_id)
  result = connection_pool.with { |r| r.get("novel.sagas.#{saga_id}") }
  result ? Marshal.load(result) : nil
end
persist_context(saga_id, context) click to toggle source
# File lib/novel/repository_adapters/redis.rb, line 15
def persist_context(saga_id, context)
  connection_pool.with { |r| r.set("novel.sagas.#{saga_id}", Marshal.dump(context)) }
  context
end