Sha256: 7d5c66076d9f8cb346d2fd8ea207165e6e77d27b4b5e4954e9d0a4302d9ad3bf
Contents?: true
Size: 1003 Bytes
Versions: 11
Compression:
Stored size: 1003 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
# Namespace for all the commands related to management of the Web-UI in the context of Karafka
# It includes things like installing, creating needed topics, etc.
module Management
# Base class for all the commands that we use to manage
class Base
include ::Karafka::Helpers::Colorize
private
# @return [String] green colored word "successfully"
def successfully
green('successfully')
end
# @return [String] green colored word "already"
def already
green('already')
end
# @return [Array<String>] topics available in the cluster
def existing_topics_names
@existing_topics_names ||= ::Karafka::Admin
.cluster_info
.topics
.map { |topic| topic[:topic_name] }
end
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems