module Kafkat::Formatting
Public Instance Methods
justify(field, width=2)
click to toggle source
# File lib/kafkat/utility/formatting.rb, line 3 def justify(field, width=2) field = field.to_s count = [width - (field.length / 8), 1].max field + "\t" * count end
print_assignment(assignment)
click to toggle source
# File lib/kafkat/utility/formatting.rb, line 54 def print_assignment(assignment) print justify(assignment.topic_name) print justify(assignment.partition_id) print justify(assignment.replicas.inspect) print "\n" end
print_assignment_header()
click to toggle source
# File lib/kafkat/utility/formatting.rb, line 61 def print_assignment_header print justify('Topic') print justify('Partition') print justify('Replicas') print "\n" end
print_broker(broker)
click to toggle source
# File lib/kafkat/utility/formatting.rb, line 9 def print_broker(broker) print justify(broker.id) print justify("#{broker.host}:#{broker.port}") print "\n" end
print_broker_header()
click to toggle source
# File lib/kafkat/utility/formatting.rb, line 15 def print_broker_header print justify('Broker') print justify('Socket') print "\n" end
print_partition(partition)
click to toggle source
# File lib/kafkat/utility/formatting.rb, line 36 def print_partition(partition) print justify(partition.topic_name) print justify(partition.id) print justify(partition.leader || 'none') print justify(partition.replicas.inspect, 7) print justify(partition.isr.inspect, 7) print "\n" end
print_partition_header()
click to toggle source
# File lib/kafkat/utility/formatting.rb, line 45 def print_partition_header print justify('Topic') print justify('Partition') print justify('Leader') print justify('Replicas', 7) print justify('ISRs', 7) print "\n" end
print_topic(topic)
click to toggle source
# File lib/kafkat/utility/formatting.rb, line 21 def print_topic(topic) print justify(topic.name) print "\n" end
print_topic_header()
click to toggle source
# File lib/kafkat/utility/formatting.rb, line 31 def print_topic_header print justify('Topic') print "\n" end
print_topic_name(topic_name)
click to toggle source
# File lib/kafkat/utility/formatting.rb, line 26 def print_topic_name(topic_name) print justify(topic_name) print "\n" end