health = BrainzLab::Nerve.queue_health

health.each do |queue_name, stats|
  puts "#{queue_name}:"
  puts "  Size: #{stats.size}"
  puts "  Wait time: #{stats.latency}s"
  puts "  Throughput: #{stats.throughput}/min"
  puts "  Status: #{stats.status}" # :healthy, :degraded, :critical
end

BrainzLab::Nerve.configure_queue(:default,
  size_threshold: 100,
  latency_threshold: 30,
  alert_on: [:degraded, :critical]
)

metrics = BrainzLab::Nerve.queue_metrics(:default)

puts metrics.size           # Current queue size
puts metrics.latency        # Wait time for oldest job
puts metrics.throughput     # Jobs/minute
puts metrics.jobs_processed # Total processed today
puts metrics.jobs_failed    # Total failed today

history = BrainzLab::Nerve.queue_history(:default, period: :day)

history.each do |point|
  puts "#{point.timestamp}: size=#{point.size}, throughput=#{point.throughput}"
end

comparison = BrainzLab::Nerve.compare_queues([:default, :mailers, :critical])

comparison.each do |queue, stats|
  puts "#{queue}: #{stats.avg_duration}ms avg, #{stats.failure_rate}% failures"
end

# Alert when queue backs up
BrainzLab::Nerve.alert_on(:default,
  condition: :size_exceeds,
  threshold: 1000,
  channel: :slack
)

# Alert when latency spikes
BrainzLab::Nerve.alert_on(:critical,
  condition: :latency_exceeds,
  threshold: 60, # seconds
  channel: :pagerduty
)

BrainzLab::Nerve.pause_queue(:mailers)
# Workers will stop pulling from this queue

BrainzLab::Nerve.resume_queue(:mailers)

# Caution: This deletes all pending jobs!
BrainzLab::Nerve.clear_queue(:default, confirm: true)

analysis = BrainzLab::Nerve.queue_analysis

analysis.needs_attention.each do |queue|
  puts "#{queue.name}: #{queue.issue}"
  # => "mailers: High latency (45s average)"
end

analysis.recommendations.each do |rec|
  puts rec
  # => "Consider adding workers for 'default' queue"
end