Class: Karafka::Web::Pro::Ui::Controllers::Topics::DistributionsController
- Inherits:
-
BaseController
- Object
- Ui::Controllers::BaseController
- BaseController
- BaseController
- Karafka::Web::Pro::Ui::Controllers::Topics::DistributionsController
- Defined in:
- lib/karafka/web/pro/ui/controllers/topics/distributions_controller.rb
Overview
Controller responsible for checking the data distribution in topics
Constant Summary
Constants inherited from Ui::Controllers::BaseController
Ui::Controllers::BaseController::Models
Instance Attribute Summary
Attributes inherited from Ui::Controllers::BaseController
Instance Method Summary collapse
- #edit(topic_name) ⇒ Object
-
#show(topic_name) ⇒ Object
Displays the messages distribution across various partitions.
- #update(topic_name) ⇒ Object
Methods inherited from Ui::Controllers::BaseController
Methods included from Ui::Controllers::Requests::Hookable
included, #run_after_hooks, #run_before_hooks
Constructor Details
This class inherits a constructor from Karafka::Web::Ui::Controllers::BaseController
Instance Method Details
#edit(topic_name) ⇒ Object
49 50 51 52 53 54 55 |
# File 'lib/karafka/web/pro/ui/controllers/topics/distributions_controller.rb', line 49 def edit(topic_name) features.topics_management! @topic = Models::Topic.find(topic_name) render end |
#show(topic_name) ⇒ Object
Note:
Because computing distribution is fairly expensive, we paginate this. While because of that results may not be exact, this allows us to support topics with many partitions.
Displays the messages distribution across various partitions
31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 |
# File 'lib/karafka/web/pro/ui/controllers/topics/distributions_controller.rb', line 31 def show(topic_name) @topic = Models::Topic.find(topic_name) @active_partitions, _materialized_page, @limited = Paginators::Partitions.call( @topic.partition_count, @params.current_page ) @aggregated, distribution = @topic.distribution(@active_partitions) @distribution = refine(distribution) next_page = @active_partitions.last < @topic.partition_count - 1 paginate(@params.current_page, next_page) render end |
#update(topic_name) ⇒ Object
58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 |
# File 'lib/karafka/web/pro/ui/controllers/topics/distributions_controller.rb', line 58 def update(topic_name) edit(topic_name) partition_count = params.int(:partition_count) begin Karafka::Admin.create_partitions( topic_name, partition_count ) rescue Rdkafka::RdkafkaError => e @form_error = e rescue Rdkafka::Config::ConfigError => e @form_error = e end return edit(topic_name) if @form_error redirect( "topics/#{topic_name}/distribution", success: format_flash( 'Topic ? repartitioning to ? partitions successfully started', topic_name, partition_count ) ) end |