| .circleci/config.yml | |
|
|
| .gitignore | |
|
|
| .rspec | |
|
|
| .rubocop.yml | |
|
|
| CHANGELOG.md | |
|
|
| Gemfile | |
|
|
| LICENSE.txt | |
|
|
| README.md | |
|
|
| Rakefile | |
|
|
| bin/console | |
|
|
| bin/setup | |
|
|
| circuitry.gemspec | |
|
|
| exe/circuitry | |
|
|
| lib/circuitry.rb | 47 |
|
|
| lib/circuitry/cli.rb | 52 |
|
|
| lib/circuitry/concerns/async.rb | 57 |
|
|
| lib/circuitry/config/file_loader.rb | 20 |
|
|
| lib/circuitry/config/publisher_settings.rb | 14 |
|
|
| lib/circuitry/config/shared_settings.rb | 37 |
|
|
| lib/circuitry/config/subscriber_settings.rb | 28 |
|
|
| lib/circuitry/locks/base.rb | 37 |
|
|
| lib/circuitry/locks/memcache.rb | 26 |
|
|
| lib/circuitry/locks/memory.rb | 53 |
|
|
| lib/circuitry/locks/noop.rb | 15 |
|
|
| lib/circuitry/locks/redis.rb | 42 |
|
|
| lib/circuitry/message.rb | 25 |
|
|
| lib/circuitry/middleware/chain.rb | 68 |
|
|
| lib/circuitry/middleware/entry.rb | 16 |
|
|
| lib/circuitry/processor.rb | 30 |
|
|
| lib/circuitry/processors/batcher.rb | 19 |
|
|
| lib/circuitry/processors/forker.rb | 19 |
|
|
| lib/circuitry/processors/threader.rb | 22 |
|
|
| lib/circuitry/provisioning.rb | 8 |
|
|
| lib/circuitry/provisioning/provisioner.rb | 65 |
|
|
| lib/circuitry/provisioning/queue_creator.rb | 52 |
|
|
| lib/circuitry/provisioning/subscription_creator.rb | 53 |
|
|
| lib/circuitry/provisioning/topic_creator.rb | 23 |
|
|
| lib/circuitry/publisher.rb | 83 | A 25 mins |
|
| lib/circuitry/queue.rb | 35 |
|
|
| lib/circuitry/railtie.rb | 15 |
|
|
| lib/circuitry/services/sns.rb | 10 |
|
|
| lib/circuitry/services/sqs.rb | 10 |
|
|
| lib/circuitry/subscriber.rb | 161 | A 3 hrs |
|
| lib/circuitry/tasks.rb | 13 |
|
|
| lib/circuitry/testing.rb | 11 |
|
|
| lib/circuitry/topic.rb | 32 |
|
|
| lib/circuitry/version.rb | 3 |
|
|