class ActiveFedora::Base
Public Class Methods
stream()
click to toggle source
# File lib/sufia/models/active_fedora/redis.rb, line 9 def self.stream Nest.new(name, $redis) rescue nil end
Public Instance Methods
create_event(action, timestamp)
click to toggle source
# File lib/sufia/models/active_fedora/redis.rb, line 26 def create_event(action, timestamp) event_id = $redis.incr("events:latest_id") $redis.hmset("events:#{event_id}", "action", action, "timestamp", timestamp) event_id rescue nil end
events(size = -1)
click to toggle source
# File lib/sufia/models/active_fedora/redis.rb, line 15 def events(size = -1) stream[:event].lrange(0, size).map do |event_id| { action: $redis.hget("events:#{event_id}", "action"), timestamp: $redis.hget("events:#{event_id}", "timestamp") } end rescue [] end
log_event(event_id)
click to toggle source
# File lib/sufia/models/active_fedora/redis.rb, line 34 def log_event(event_id) stream[:event].lpush(event_id) rescue nil end
stream()
click to toggle source
# File lib/sufia/models/active_fedora/redis.rb, line 3 def stream Nest.new(self.class.name, $redis)[to_param] rescue nil end