Class: AsyncRequestReply::RepositoryAdapters::RedisRepositoryAdapter

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

Class Method Summary collapse

Class Method Details

.client ⇒ Object 



23
24
25
26
 
# File 'lib/async_request_reply/repository_adapters/redis_repository_adapter.rb', line 23

def client
	#TODO: ADD CONFIGURATION timeout and size of pool
	@@redis ||= RedisClient.config(url: AsyncRequestReply::Config.instance.redis_url_conection).new_pool(timeout: 0.5, size: 5) 
end

.del(uuid) ⇒ Object 



14
15
16
 
# File 'lib/async_request_reply/repository_adapters/redis_repository_adapter.rb', line 14

def del(uuid)
	client.call("DEL", uuid)
end

.get(uuid) ⇒ Object 



10
11
12
 
# File 'lib/async_request_reply/repository_adapters/redis_repository_adapter.rb', line 10

def get(uuid)
	client.call("GET", uuid)
end

.setex(uuid, ttl, payload) ⇒ Object 



18
19
20
21
 
# File 'lib/async_request_reply/repository_adapters/redis_repository_adapter.rb', line 18

def setex(uuid, ttl, payload)
	raise "Redis can`t save key #{uuid}" unless client.call("SET", uuid, payload, ex: ttl)
	get(uuid)
end