Sha256: 01edac864868b13f541965b0d0ac607f3d6370107629af3649d676e8ad73ea16
Contents?: true
Size: 1.4 KB
Versions: 14
Compression:
Stored size: 1.4 KB
Contents
# frozen_string_literal: true
module GoodJob
class ProbeServer
def self.task_observer(time, output, thread_error) # rubocop:disable Lint/UnusedMethodArgument
return if thread_error.is_a? Concurrent::CancelledOperationError
GoodJob._on_thread_error(thread_error) if thread_error
end
def initialize(port:)
@port = port
end
def start
@handler = HttpServer.new(self, port: @port, logger: GoodJob.logger)
@future = Concurrent::Future.new { @handler.run }
@future.add_observer(self.class, :task_observer)
@future.execute
end
def running?
@handler&.running?
end
def stop
@handler&.stop
@future&.value # wait for Future to exit
end
def call(env)
case Rack::Request.new(env).path
when '/', '/status'
[200, {}, ["OK"]]
when '/status/started'
started = GoodJob::Scheduler.instances.any? && GoodJob::Scheduler.instances.all?(&:running?)
started ? [200, {}, ["Started"]] : [503, {}, ["Not started"]]
when '/status/connected'
connected = GoodJob::Scheduler.instances.any? && GoodJob::Scheduler.instances.all?(&:running?) &&
GoodJob::Notifier.instances.any? && GoodJob::Notifier.instances.all?(&:connected?)
connected ? [200, {}, ["Connected"]] : [503, {}, ["Not connected"]]
else
[404, {}, ["Not found"]]
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems