Sha256: de8578fdd6670856f0f481d123f1ee72e0f908b80fe5c961d112b84432b16056
Contents?: true
Size: 1.05 KB
Versions: 17
Compression:
Stored size: 1.05 KB
Contents
# frozen_string_literal: true
module Karafka
module Web
module Management
# 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 Actions
# 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
end
Version data entries
17 entries across 17 versions & 1 rubygems