class CrossSpec::Config
Attributes
client[W]
handlers[W]
Public Instance Methods
client()
click to toggle source
# File lib/cross_spec/config.rb, line 3 def client return @client if defined?(@client) self.client = Client.new(KafkaClient.new(kafka), handlers) @client end
handlers()
click to toggle source
# File lib/cross_spec/config.rb, line 9 def handlers @handlers ||= {} end
kafka_connection_string()
click to toggle source
# File lib/cross_spec/config.rb, line 13 def kafka_connection_string return @kafka_connection_string if defined?(@kafka_connection_string) self.kafka_connection_string = "localhost" @kafka_connection_string end
kafka_connection_string=(value)
click to toggle source
# File lib/cross_spec/config.rb, line 21 def kafka_connection_string=(value) @kafka_connection_string = value @kafka = Kafka.new(seed_brokers: @kafka_connection_string) value end
Private Instance Methods
kafka()
click to toggle source
# File lib/cross_spec/config.rb, line 29 def kafka @kafka ||= Kafka.new(seed_brokers: kafka_connection_string) end