0.0
The project is in a healthy, maintained state
Redis bus for aggregating data from parallel processing in Ruby
2005
2006
2007
2008
2009
2010
2011
2012
2013
2014
2015
2016
2017
2018
2019
2020
2021
 Project Readme

double_decker

Build Status codecov

library for parallel aggregation in Ruby

installation

in your Gemfile

gem "double_decker"

usage

require "double_decker"

# instatiate the bus with a run id shared across parallel processes
bus = DoubleDecker::Bus.new(UNIQUE_SHARED_RUN_ID, url: 'redis://127.0.0.1')

# call an on finished hook with the final payload when all processes complete
bus.on_finished do |payload|
  ...
end

# register in agent in each process
agent = bus.register

# merge data into the agent
agent.merge({ hello: :world })

# finish each agent at the end of the process
at_exit do
  agent.finish!
end

running tests

docker-compose build && docker-compose run lib rspec