double_decker

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