| renovate.json | |
|
|
| lib/karafka/version.rb | 3 | A 0 mins |
|
| lib/karafka/time_trackers/poll.rb | 33 | A 0 mins |
|
| lib/karafka/time_trackers/pause.rb | 61 | A 0 mins |
|
| lib/karafka/time_trackers/base.rb | 7 | A 0 mins |
|
| lib/karafka/templates/karafka.rb.erb | |
|
|
| lib/karafka/templates/example_consumer.rb.erb | |
|
|
| lib/karafka/templates/application_consumer.rb.erb | |
|
|
| lib/karafka/swarm/supervisor.rb | 116 | A 3 hrs |
|
| lib/karafka/swarm/pidfd.rb | 91 | A 2 hrs |
|
| lib/karafka/swarm/node.rb | 85 | A 0 mins |
|
| lib/karafka/swarm/manager.rb | 125 | B 4 hrs |
|
| lib/karafka/swarm/liveness_listener.rb | 33 | A 0 mins |
|
| lib/karafka/swarm.rb | 16 | A 0 mins |
|
| lib/karafka/status.rb | 51 | A 20 mins |
|
| lib/karafka/setup/dsl.rb | 12 | A 0 mins |
|
| lib/karafka/setup/config.rb | 179 | A 45 mins |
|
| lib/karafka/setup/attributes_map.rb | 314 | B 4 hrs |
|
| lib/karafka/server.rb | 74 | A 3 hrs |
|
| lib/karafka/runner.rb | 34 | A 0 mins |
|
| lib/karafka/routing/topics.rb | 22 | A 0 mins |
|
| lib/karafka/routing/topic.rb | 74 | A 0 mins |
|
| lib/karafka/routing/subscription_groups_builder.rb | 42 | A 0 mins |
|
| lib/karafka/routing/subscription_group.rb | 77 | A 0 mins |
|
| lib/karafka/routing/router.rb | 27 | A 0 mins |
|
| lib/karafka/routing/proxy.rb | 25 | A 0 mins |
|
| lib/karafka/routing/features/manual_offset_management/topic.rb | 21 | A 25 mins |
|
| lib/karafka/routing/features/manual_offset_management/contracts/topic.rb | 22 | A 50 mins |
|
| lib/karafka/routing/features/manual_offset_management/config.rb | 12 | A 0 mins |
|
| lib/karafka/routing/features/manual_offset_management.rb | 8 | A 0 mins |
|
| lib/karafka/routing/features/inline_insights/topic.rb | 23 | A 25 mins |
|
| lib/karafka/routing/features/inline_insights/contracts/topic.rb | 22 | A 50 mins |
|
| lib/karafka/routing/features/inline_insights/config.rb | 12 | A 0 mins |
|
| lib/karafka/routing/features/inline_insights.rb | 25 | A 0 mins |
|
| lib/karafka/routing/features/deserializers/topic.rb | 33 | A 0 mins |
|
| lib/karafka/routing/features/deserializers/contracts/topic.rb | 25 | A 0 mins |
|
| lib/karafka/routing/features/deserializers/config.rb | 15 | A 0 mins |
|
| lib/karafka/routing/features/deserializers.rb | 8 | A 0 mins |
|
| lib/karafka/routing/features/declaratives/topic.rb | 29 | A 0 mins |
|
| lib/karafka/routing/features/declaratives/contracts/topic.rb | 28 | A 0 mins |
|
| lib/karafka/routing/features/declaratives/config.rb | 15 | A 0 mins |
|
| lib/karafka/routing/features/declaratives.rb | 8 | A 0 mins |
|
| lib/karafka/routing/features/dead_letter_queue/topic.rb | 38 | A 0 mins |
|
| lib/karafka/routing/features/dead_letter_queue/contracts/topic.rb | 41 | A 0 mins |
|
| lib/karafka/routing/features/dead_letter_queue/config.rb | 23 | A 0 mins |
|
| lib/karafka/routing/features/dead_letter_queue.rb | 8 | A 0 mins |
|
| lib/karafka/routing/features/base/expander.rb | 37 | A 1 hr |
|
| lib/karafka/routing/features/base.rb | 62 | A 0 mins |
|
| lib/karafka/routing/features/active_job/topic.rb | 21 | A 25 mins |
|
| lib/karafka/routing/features/active_job/proxy.rb | 11 | A 0 mins |
|