Sha256: d59fe143556e22ede60de5268cc06d36411506423d39b153f3d924519a3cbf16
Contents?: true
Size: 854 Bytes
Versions: 25
Compression:
Stored size: 854 Bytes
Contents
module PerfectQueue
class Task
def initialize(id, created_at, data, resource=nil)
@id = id
@created_at = created_at
@data = data
@resource = resource
end
attr_reader :id, :created_at, :data, :resource
end
class CanceledError < RuntimeError
end
class Backend
# => list {|id,created_at,data,timeout| ... }
def list(&block)
end
# => token, task
def acquire(timeout, now=Time.now.to_i)
end
# => true (success) or false (canceled)
def finish(token, delete_timeout=3600, now=Time.now.to_i)
end
# => nil
def update(token, timeout)
end
# => true (success) or false (not found, canceled or finished)
def cancel(id, delete_timeout=3600, now=Time.now.to_i)
end
# => true (success) or nil (already exists)
def submit(id, data, time=Time.now.to_i, resource=nil)
end
def close
end
end
end
Version data entries
25 entries across 25 versions & 1 rubygems