module EventMachine::Bucketer::Database::Hash

Private Instance Methods

add_bucket_to_db(bucket_id, item_id, item, &blk) click to toggle source
# File lib/em-bucketer/database/hash.rb, line 20
def add_bucket_to_db(bucket_id, item_id, item, &blk)
  EM::Completion.new.tap do |c|
    c.callback(&blk) if block_given?
    @buckets[bucket_id] ||= {}
    @buckets[bucket_id][item_id] = item
    c.succeed
  end
end
bucket_size_from_db(bucket_id, &blk) click to toggle source
# File lib/em-bucketer/database/hash.rb, line 12
def bucket_size_from_db(bucket_id, &blk)
  EM::Completion.new.tap do |c|
    c.callback(&blk) if block_given?
    @buckets[bucket_id] ||= {}
    c.succeed @buckets[bucket_id].size
  end
end
empty_bucket_in_db(bucket_id, &blk) click to toggle source
# File lib/em-bucketer/database/hash.rb, line 37
def empty_bucket_in_db(bucket_id, &blk)
  EM::Completion.new.tap do |c|
    c.callback(&blk) if block_given?
    @buckets[bucket_id] = {}
    c.succeed
  end
end
get_bucket_from_db(bucket_id, &blk) click to toggle source
# File lib/em-bucketer/database/hash.rb, line 29
def get_bucket_from_db(bucket_id, &blk)
  EM::Completion.new.tap do |c|
    c.callback(&blk) if block_given?
    @buckets[bucket_id] ||= {}
    c.succeed @buckets[bucket_id]
  end
end
setup_db() click to toggle source
# File lib/em-bucketer/database/hash.rb, line 8
def setup_db
  @buckets = {}
end