Module: PatientHttp

Defined in:

lib/patient_http/solid_queue.rb,
lib/patient_http/solid_queue/engine.rb,
lib/patient_http/solid_queue/record.rb,
lib/patient_http/solid_queue/context.rb,
lib/patient_http/solid_queue/gc_lock.rb,
lib/patient_http/solid_queue/request_job.rb,
lib/patient_http/solid_queue/callback_job.rb,
lib/patient_http/solid_queue/task_handler.rb,
lib/patient_http/solid_queue/task_monitor.rb,
lib/patient_http/solid_queue/configuration.rb,
lib/patient_http/solid_queue/lifecycle_hooks.rb,
lib/patient_http/solid_queue/inflight_request.rb,
lib/patient_http/solid_queue/request_executor.rb,
lib/patient_http/solid_queue/processor_observer.rb,
lib/patient_http/solid_queue/task_monitor_thread.rb,
lib/patient_http/solid_queue/process_registration.rb

Overview

Main module for the Solid Queue Async HTTP gem.

This gem provides a mechanism to offload long-running HTTP requests from Solid Queue workers to a dedicated async I/O processor running in the same process, freeing worker threads immediately while HTTP requests are in flight.

Usage

request = PatientHttp::Request.new(:get, "https://api.example.com/users/123")
PatientHttp::SolidQueue.execute(
  request,
  callback: MyCallback,
  callback_args: {user_id: 123}
)

Define a callback service class with on_complete and on_error methods:

class MyCallback
  def on_complete(response)
    user_id = response.callback_args[:user_id]
    User.find(user_id).update!(data: response.json)
  end

  def on_error(error)
    Rails.logger.error("Request failed: #{error.message}")
  end
end

Defined Under Namespace

Modules: SolidQueue