Module: PulseMeter::Mixins::Dumper::InstanceMethods

Defined in:
lib/pulse_meter/mixins/dumper.rb

Instance Method Summary collapse

Instance Method Details

#cleanup_dump ⇒ Object

Cleans up object dump in Redis



42
43
44
 
# File 'lib/pulse_meter/mixins/dumper.rb', line 42

def cleanup_dump
  redis.hdel(DUMP_REDIS_KEY, self.name)
end

#dump!(safe = true) ⇒ Object

Serializes object and saves it to Redis

Parameters:

  • safe (Boolean) (defaults to: true) —

    forbids dump if sensor has already been dumped

Raises:



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/pulse_meter/mixins/dumper.rb', line 15

def dump!(safe = true)
  ensure_storability!
  serialized_obj = to_yaml
  if safe
    unless redis.hsetnx(DUMP_REDIS_KEY, name, serialized_obj)
      stored = self.class.restore(name)
      unless stored.class == self.class
        raise DumpConflictError, "Attempt to create sensor #{name} of class #{self.class} but it already has class #{stored.class}"
      end
    end
  else
    redis.hset(DUMP_REDIS_KEY, name, serialized_obj)
  end
rescue DumpError, RestoreError => exc
  raise exc
rescue StandardError => exc
  raise DumpError, "object cannot be dumped: #{exc}"
end

#ensure_storability! ⇒ Object

Ensures that object is dumpable

Raises:



36
37
38
39
 
# File 'lib/pulse_meter/mixins/dumper.rb', line 36

def ensure_storability!
  raise DumpError, "#name attribute must be readable" unless self.respond_to?(:name)
  raise DumpError, "#redis attribute must be available" unless self.respond_to?(:redis) && self.redis
end