Module: Ikibana::Consumer::ClassMethods

Defined in:

lib/ikibana/consumer.rb

Instance Method Summary

• #at_most_once ⇒ Object
• #cache ⇒ Object
• #destructor ⇒ Object
• #sync ⇒ Object

Instance Method Details

#at_most_once ⇒ Object

# File 'lib/ikibana/consumer.rb', line 12

def at_most_once
  cache.write("#{self}_locked", true)
end

#cache ⇒ Object

# File 'lib/ikibana/consumer.rb', line 25

def cache
  Ikibana::Config.instance.cache
end

#destructor ⇒ Object

# File 'lib/ikibana/consumer.rb', line 21

def destructor(...)
  cache.write("#{self}_locked", false)
end

#sync ⇒ Object

# File 'lib/ikibana/consumer.rb', line 16

def sync(...)
  cache.write("#{self}_locked", false)
  cache.write("#{self}_sync", true)
end