| .coditsu/ci.yml | |
|
|
| .diffend.yml | |
|
|
| .github/FUNDING.yml | |
|
|
| .github/workflows/ci.yml | |
|
|
| .gitignore | |
|
|
| .rspec | |
|
|
| .ruby-gemset | |
|
|
| .ruby-version | |
|
|
| CHANGELOG.md | |
|
|
| Gemfile | |
|
|
| Gemfile.lock | |
|
|
| LICENSE | |
|
|
| README.md | |
|
|
| certs/cert.pem | |
|
|
| docker-compose.yml | |
|
|
| lib/waterdrop.rb | 21 | A 0 mins |
|
| lib/waterdrop/clients/buffered.rb | 60 | A 0 mins |
|
| lib/waterdrop/clients/dummy.rb | 35 | A 0 mins |
|
| lib/waterdrop/clients/rdkafka.rb | 35 | A 0 mins |
|
| lib/waterdrop/config.rb | 63 | A 0 mins |
|
| lib/waterdrop/contracts.rb | 4 | A 0 mins |
|
| lib/waterdrop/contracts/config.rb | 43 | A 30 mins |
|
| lib/waterdrop/contracts/message.rb | 46 | A 0 mins |
|
| lib/waterdrop/contracts/transactional_offset.rb | 16 | A 0 mins |
|
| lib/waterdrop/contracts/variant.rb | 70 | A 1 hr |
|
| lib/waterdrop/errors.rb | 26 | A 0 mins |
|
| lib/waterdrop/helpers/counter.rb | 17 | A 0 mins |
|
| lib/waterdrop/instrumentation/callbacks/delivery.rb | 79 | A 1 hr |
|
| lib/waterdrop/instrumentation/callbacks/error.rb | 31 | A 0 mins |
|
| lib/waterdrop/instrumentation/callbacks/oauthbearer_token_refresh.rb | 28 | A 0 mins |
|
| lib/waterdrop/instrumentation/callbacks/statistics.rb | 30 | A 0 mins |
|
| lib/waterdrop/instrumentation/logger_listener.rb | 120 | A 3 hrs |
|
| lib/waterdrop/instrumentation/monitor.rb | 12 | A 0 mins |
|
| lib/waterdrop/instrumentation/notifications.rb | 35 | A 0 mins |
|
| lib/waterdrop/instrumentation/vendors/datadog/dashboard.json | |
|
|
| lib/waterdrop/instrumentation/vendors/datadog/metrics_listener.rb | 146 | A 1 hr |
|
| lib/waterdrop/middleware.rb | 29 | A 0 mins |
|
| lib/waterdrop/producer.rb | 189 | C 1 day |
|
| lib/waterdrop/producer/async.rb | 56 | A 1 hr |
|
| lib/waterdrop/producer/buffer.rb | 51 | A 0 mins |
|
| lib/waterdrop/producer/builder.rb | 11 | A 0 mins |
|
| lib/waterdrop/producer/status.rb | 33 | A 0 mins |
|
| lib/waterdrop/producer/sync.rb | 62 | A 2 hrs |
|
| lib/waterdrop/producer/transactions.rb | 147 | C 1 day |
|
| lib/waterdrop/producer/variant.rb | 53 | A 0 mins |
|
| lib/waterdrop/version.rb | 3 | A 0 mins |
|
| renovate.json | |
|
|
| waterdrop.gemspec | |
|
|