module CrossSpec

# File lib/cross_spec.rb, line 51
def self.beacon(task, data = nil, biomarkers = nil)
  str = JSON.dump(
    task: task,
    biomarkers: biomarkers || DistributedTracing.get,
    data: data
  )
  config.client.broadcast(str)
end

# File lib/cross_spec.rb, line 30
def self.config
  return @config if defined?(@config)
  @config = Config.new
  @config
end

# File lib/cross_spec.rb, line 25
def self.configure
  @config = Config.new
  yield(@config)
end

# File lib/cross_spec.rb, line 47
def self.failure_beacon!(data = nil)
  beacon(FAIL_TASK, data)
end

# File lib/cross_spec.rb, line 36
def self.handle(service, &block)
  config.handlers[service] = Proc.new do |*args|
    block.call(*args)
    nil
  end
end

# File lib/cross_spec.rb, line 43
def self.listen!
  config.client.listen!
end