| .circleci/config.yml | |
|
|
| .codeclimate.json | |
|
|
| .gitignore | |
|
|
| .rspec | |
|
|
| .rubocop.yml | |
|
|
| .travis.yml | |
|
|
| CHANGELOG.md | |
|
|
| CODE_OF_CONDUCT.md | |
|
|
| Dockerfile | |
|
|
| Gemfile | |
|
|
| Gemfile.lock | |
|
|
| Guardfile | |
|
|
| LICENSE.txt | |
|
|
| README.md | |
|
|
| Rakefile | |
|
|
| bin/console | |
|
|
| bin/rspec | |
|
|
| bin/setup | |
|
|
| examples/basic/docker-compose.yml | |
|
|
| examples/basic/example_publisher.rb | 12 | A 0 mins |
|
| examples/basic/example_subscriber.rb | 15 | A 0 mins |
|
| jstreams.gemspec | |
|
|
| lib/jstreams.rb | 6 | A 0 mins |
|
| lib/jstreams/consumer_group.rb | 18 | A 0 mins |
|
| lib/jstreams/context.rb | 60 | A 0 mins |
|
| lib/jstreams/publisher.rb | 18 | A 0 mins |
|
| lib/jstreams/serializer.rb | 10 | A 0 mins |
|
| lib/jstreams/serializers/json.rb | 14 | A 0 mins |
|
| lib/jstreams/subscriber.rb | 199 | A 25 mins |
|
| lib/jstreams/tagged_logging.rb | 63 | A 0 mins |
|
| lib/jstreams/version.rb | 3 | A 0 mins |
|
| package-lock.json | |
|
|