| .codeclimate.json | |
|
|
| .dockerignore | |
|
|
| .env | |
|
|
| .gitattributes | |
|
|
| .gitignore | |
|
|
| .rspec | |
|
|
| .rubocop.yml | |
|
|
| .rubocop_common.yml | |
|
|
| .rubocop_todo.yml | |
|
|
| .rubosync.yml | |
|
|
| .ruby-version | |
|
|
| .travis.yml | |
|
|
| CHANGELOG.md | |
|
|
| Dockerfile | |
|
|
| Gemfile | |
|
|
| LICENSE.txt | |
|
|
| README.md | |
|
|
| Rakefile | |
|
|
| bin/console | |
|
|
| bin/phobos | |
|
|
| bin/setup | |
|
|
| bin/tapioca | |
|
|
| defs.rbi | |
|
|
| docker-compose.yml | |
|
|
| examples/handler_saving_events_database.rb | 16 | A 0 mins |
|
| examples/handler_using_async_producer.rb | 8 | A 0 mins |
|
| examples/publishing_messages_without_consumer.rb | 44 | A 0 mins |
|
| lib/phobos.rb | 64 | A 0 mins |
|
| lib/phobos/actions/process_batch.rb | 35 | A 0 mins |
|
| lib/phobos/actions/process_batch_inline.rb | 50 | A 0 mins |
|
| lib/phobos/actions/process_message.rb | 39 | A 0 mins |
|
| lib/phobos/batch_handler.rb | 17 | A 0 mins |
|
| lib/phobos/batch_message.rb | 21 | A 0 mins |
|
| lib/phobos/cli.rb | 59 | A 0 mins |
|
| lib/phobos/cli/runner.rb | 37 | A 25 mins |
|
| lib/phobos/cli/start.rb | 54 | A 0 mins |
|
| lib/phobos/configuration.rb | 81 | A 25 mins |
|
| lib/phobos/constants.rb | 29 | A 0 mins |
|
| lib/phobos/deep_struct.rb | 28 | A 0 mins |
|
| lib/phobos/echo_handler.rb | 8 | A 0 mins |
|
| lib/phobos/errors.rb | 4 | A 0 mins |
|
| lib/phobos/executor.rb | 83 | A 45 mins |
|
| lib/phobos/handler.rb | 17 | A 0 mins |
|
| lib/phobos/instrumentation.rb | 19 | A 0 mins |
|
| lib/phobos/listener.rb | 153 | A 1 hr |
|
| lib/phobos/log.rb | 21 | A 0 mins |
|
| lib/phobos/processor.rb | 50 | A 0 mins |
|
| lib/phobos/producer.rb | 130 | A 0 mins |
|
| lib/phobos/test.rb | 1 | A 0 mins |
|
| lib/phobos/version.rb | 3 | A 0 mins |
|