Class: AsyncRequestReply::RepositoryAdapters::IORepositoryAdapter

Inherits:
AbstractRepositoryAdapter show all
Defined in:
lib/async_request_reply/repository_adapters/i_o_repository_adapter.rb

Constant Summary collapse

@@prefix = 
".async_request_reply".freeze

Class Method Summary collapse

Class Method Details

.del(uuid) ⇒ Object 



20
21
22
 
# File 'lib/async_request_reply/repository_adapters/i_o_repository_adapter.rb', line 20

def del(uuid)
  File.delete("#{@@prefix}/#{uuid}")
end

.get(uuid) ⇒ Object 



11
12
13
14
15
16
17
18
 
# File 'lib/async_request_reply/repository_adapters/i_o_repository_adapter.rb', line 11

def get(uuid)
  begin
    IO.binread("#{@@prefix}/#{uuid}")
  rescue StandardError => e
    return nil if e.is_a?(Errno::ENOENT)
    raise e
  end
end

.setex(uuid, ttl = nil, payload) ⇒ Object 



24
25
26
27
28
 
# File 'lib/async_request_reply/repository_adapters/i_o_repository_adapter.rb', line 24

def setex(uuid, ttl = nil, payload)
  Dir.mkdir(@@prefix) unless Dir.exist?(@@prefix)
  IO.binwrite("#{@@prefix}/#{uuid}", payload)
  self.get(uuid)
end