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