Contents

# frozen_string_literal: true

module Karafka
  class Cli
    # CLI actions related to Kafka cluster topics management
    class Topics < Base
      include Helpers::Colorize
      include Helpers::ConfigImporter.new(
        kafka_config: %i[kafka]
      )

      desc 'Allows for the topics management'

      option(
        :detailed_exitcode,
        'Exists with 0 when no changes, 1 when error and 2 when changes present or applied',
        TrueClass,
        %w[
          --detailed_exitcode
        ]
      )

      # We exit with 0 if no changes happened
      NO_CHANGES_EXIT_CODE = 0

      # When any changes happened (or could happen) we return 2 because 1 is default when Ruby
      # crashes
      CHANGES_EXIT_CODE = 2

      private_constant :NO_CHANGES_EXIT_CODE, :CHANGES_EXIT_CODE

      # @param action [String] action we want to take
      def call(action = 'missing')
        detailed_exit_code = options.fetch(:detailed_exitcode, false)

        command = case action
                  when 'create'
                    Topics::Create
                  when 'delete'
                    Topics::Delete
                  when 'reset'
                    Topics::Reset
                  when 'repartition'
                    Topics::Repartition
                  when 'migrate'
                    Topics::Migrate
                  when 'align'
                    Topics::Align
                  when 'plan'
                    Topics::Plan
                  else
                    raise ::ArgumentError, "Invalid topics action: #{action}"
                  end

        changes = command.new.call

        return unless detailed_exit_code

        changes ? exit(CHANGES_EXIT_CODE) : exit(NO_CHANGES_EXIT_CODE)
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
karafka-2.4.14	lib/karafka/cli/topics.rb
karafka-2.4.13	lib/karafka/cli/topics.rb