Contents

# frozen_string_literal: true

module Karafka
  # Karafka framework Cli
  class Cli < Thor
    # Server Karafka Cli action
    class Server < Base
      include Helpers::Colorize

      desc 'Start the Karafka server (short-cut alias: "s")'
      option aliases: 's'
      option :consumer_groups, type: :array, default: nil, aliases: :g

      # Start the Karafka server
      def call
        # Print our banner and info in the dev mode
        print_marketing_info if Karafka::App.env.development?

        Contracts::ServerCliOptions.new.validate!(cli.options)

        # We assign active topics on a server level, as only server is expected to listen on
        # part of the topics
        Karafka::Server.consumer_groups = cli.options[:consumer_groups]

        Karafka::Server.run
      end

      private

      # Prints marketing info
      def print_marketing_info
        Karafka.logger.info Info::BANNER

        if Karafka.pro?
          Karafka.logger.info(
            green('Thank you for investing in the Karafka Pro subscription!')
          )
        else
          Karafka.logger.info(
            red('You like Karafka? Please consider getting a Pro version!')
          )
        end
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
karafka-2.0.2	lib/karafka/cli/server.rb
karafka-2.0.1	lib/karafka/cli/server.rb
karafka-2.0.0	lib/karafka/cli/server.rb
karafka-2.0.0.rc6	lib/karafka/cli/server.rb
karafka-2.0.0.rc5	lib/karafka/cli/server.rb
karafka-2.0.0.rc4	lib/karafka/cli/server.rb
karafka-2.0.0.rc3	lib/karafka/cli/server.rb
karafka-2.0.0.rc2	lib/karafka/cli/server.rb