lib/taskinator/api.rb in taskinator-0.4.2 vs lib/taskinator/api.rb in taskinator-0.4.3
- old
+ new
@@ -11,22 +11,31 @@
end
def each(&block)
return to_enum(__method__) unless block_given?
+ identifiers = Taskinator.redis do |conn|
+ conn.smembers(@processes_list_key)
+ end
+
instance_cache = {}
- Taskinator.redis do |conn|
- uuids = conn.smembers(@processes_list_key)
- uuids.each do |uuid|
- yield Process.fetch(uuid, instance_cache)
- end
+ identifiers.each do |identifier|
+ yield Process.fetch(identifier, instance_cache)
end
end
def size
Taskinator.redis do |conn|
conn.scard(@processes_list_key)
end
end
+ end
+
+ def self.find_process(identifier)
+ Process.fetch(identifier)
+ end
+
+ def self.find_task(identifier)
+ Task.fetch(identifier)
end
end
end