Table of Contents - que-2.4.1 Documentation
Pages
- down.sql
- up.sql
- down.sql
- up.sql
- down.sql
- up.sql
- down.sql
- up.sql
- down.sql
- up.sql
- down.sql
- up.sql
- down.sql
- up.sql
Classes and Modules
- ActiveJob
- ActiveJob::QueueAdapters
- ActiveJob::QueueAdapters::QueAdapter
- ActiveJob::QueueAdapters::QueAdapter::JobWrapper
- Que
- Que::ActiveJob
- Que::ActiveJob::JobExtensions
- Que::ActiveJob::WrapperExtensions
- Que::ActiveJob::WrapperExtensions::ClassMethods
- Que::ActiveJob::WrapperExtensions::InstanceMethods
- Que::ActiveRecord
- Que::ActiveRecord::Connection
- Que::ActiveRecord::Connection::JobMiddleware
- Que::ActiveRecord::Model
- Que::CommandLineInterface
- Que::Connection
- Que::ConnectionPool
- Que::Error
- Que::Job
- Que::JobBuffer
- Que::JobBuffer::PriorityQueue
- Que::JobMethods
- Que::Listener
- Que::Locker
- Que::Metajob
- Que::Migrations
- Que::Poller
- Que::Rails
- Que::Rails::Railtie
- Que::ResultQueue
- Que::Sequel
- Que::Sequel::Model
- Que::Utils
- Que::Utils::Assertions
- Que::Utils::Assertions::AssertionFailed
- Que::Utils::Constantization
- Que::Utils::ErrorNotification
- Que::Utils::Freeze
- Que::Utils::Introspection
- Que::Utils::JSONSerialization
- Que::Utils::Logging
- Que::Utils::Middleware
- Que::Utils::QueueManagement
- Que::Utils::Ruby2Keywords
- Que::Utils::Transactions
- Que::Worker
Methods
- ::_bulk_enqueue_insert — Que::Job
- ::_raise_db_version_comment_missing_error — Que::Migrations
- ::_run_attrs — Que::Job
- ::bulk_enqueue — Que::Job
- ::by_args — Que::ActiveRecord::Model
- ::by_job_class — Que::ActiveRecord::Model
- ::by_queue — Que::ActiveRecord::Model
- ::by_tag — Que::ActiveRecord::Model
- ::call — Que::ActiveRecord::Connection::JobMiddleware
- ::checkout — Que::ActiveRecord::Connection
- ::cleanup — Que::Poller
- ::connection= — Que
- ::connection_proc= — Que
- ::db_version — Que::Migrations
- ::default_queue — Que
- ::enqueue — Que::Job
- ::job_schema_version — Que
- ::migrate! — Que::Migrations
- ::new — Que::Connection
- ::new — Que::ConnectionPool
- ::new — Que::Job
- ::new — Que::JobBuffer
- ::new — Que::JobBuffer::PriorityQueue
- ::new — Que::Listener
- ::new — Que::Locker
- ::new — Que::Metajob
- ::new — Que::Poller
- ::new — Que::ResultQueue
- ::new — Que::Worker
- ::parse — Que::CommandLineInterface
- ::pool — Que
- ::resolve_que_setting — Que::Job
- ::run — Que::Job
- ::server? — Que
- ::set_db_version — Que::Migrations
- ::setup — Que::Poller
- ::wrap — Que::Connection
- ::wrap_in_rails_executor — Que::ActiveRecord::Connection
- #<=> — Que::Metajob
- #_buffer_space — Que::JobBuffer
- #_check_assertion_args — Que::Utils::Assertions
- #_default_log_data — Que::Utils::Logging
- #_push — Que::JobBuffer::PriorityQueue
- #_run — Que::JobMethods
- #_shift_job — Que::JobBuffer
- #_size — Que::JobBuffer
- #_stopping? — Que::JobBuffer
- #accept? — Que::JobBuffer
- #assert — Que::Utils::Assertions
- #assert? — Que::Utils::Assertions
- #async_error_thread — Que::Utils::ErrorNotification
- #attrs — Que::ActiveJob::WrapperExtensions::InstanceMethods
- #available_priorities — Que::JobBuffer
- #buffer_space — Que::JobBuffer
- #by_args — Que::Sequel::Model
- #by_job_class — Que::Sequel::Model
- #by_queue — Que::Sequel::Model
- #by_tag — Que::Sequel::Model
- #checkout — Que::ConnectionPool
- #clear — Que::JobBuffer
- #clear — Que::ResultQueue
- #clear! — Que::Utils::QueueManagement
- #constantize — Que::Utils::Constantization
- #convert_params — Que::Connection
- #convert_result — Que::Connection
- #create! — Que::Utils::QueueManagement
- #current_connection — Que::ConnectionPool
- #current_connection= — Que::ConnectionPool
- #cycle — Que::Locker
- #default_resolve_action — Que::JobMethods
- #delete_pid — Que::Locker
- #deserialize_json — Que::Utils::JSONSerialization
- #destroy — Que::JobMethods
- #drain_notifications — Que::Connection
- #drop! — Que::Utils::QueueManagement
- #enqueue — ActiveJob::QueueAdapters::QueAdapter
- #enqueue — Que::ActiveJob::WrapperExtensions::ClassMethods
- #enqueue_at — ActiveJob::QueueAdapters::QueAdapter
- #error_count — Que::JobMethods
- #execute — Que::Connection
- #execute — Que::ConnectionPool
- #execute_prepared — Que::Connection
- #expire — Que::JobMethods
- #fetch_next_metajob — Que::Worker
- #finish — Que::JobMethods
- #finish_jobs — Que::Locker
- #get_logger — Que::Utils::Logging
- #handle_error — Que::JobMethods
- #handle_results — Que::Locker
- #id — Que::Metajob
- #in_transaction? — Que::Connection
- #in_transaction? — Que::ConnectionPool
- #internal_log — Que::Utils::Logging
- #invoke_middleware — Que::Utils::Middleware
- #job_available? — Que::JobBuffer
- #job_states — Que::Utils::Introspection
- #job_stats — Que::Utils::Introspection
- #length — Que::ResultQueue
- #listen — Que::Listener
- #lock_jobs — Que::Locker
- #log — Que::Utils::Logging
- #log_formatter — Que::Utils::Logging
- #log_level — Que::JobMethods
- #mark_id_as_locked — Que::Locker
- #message_has_all_keys? — Que::Listener
- #message_has_no_excess_keys? — Que::Listener
- #message_keys_all_valid? — Que::Listener
- #message_matches_format? — Que::Listener
- #next_notification — Que::Connection
- #notify_error — Que::Utils::ErrorNotification
- #notify_error_async — Que::Utils::ErrorNotification
- #parse_payload — Que::Listener
- #perform — Que::ActiveJob::JobExtensions
- #poll — Que::Locker
- #poll — Que::Poller
- #poll_interval_elapsed? — Que::Poller
- #poll_satisfied? — Que::Poller
- #pop — Que::JobBuffer
- #pop — Que::JobBuffer::PriorityQueue
- #populate — Que::JobBuffer::PriorityQueue
- #priority_sufficient? — Que::Metajob
- #push — Que::JobBuffer
- #push — Que::ResultQueue
- #push_jobs — Que::Locker
- #que_filter_args — Que::ActiveJob::JobExtensions
- #que_target — Que::Job
- #que_target — Que::ActiveJob::JobExtensions
- #que_target — Que::JobMethods
- #recursively_freeze — Que::Utils::Freeze
- #resolve_que_setting — Que::JobMethods
- #retry_in — Que::JobMethods
- #retry_in_default_interval — Que::JobMethods
- #run — ActiveJob::QueueAdapters::QueAdapter::JobWrapper
- #run — Que::Job
- #run — Que::ActiveJob::JobExtensions
- #run — Que::ActiveJob::WrapperExtensions::InstanceMethods
- #serialize_json — Que::Utils::JSONSerialization
- #server_version — Que::Connection
- #set_job — Que::Metajob
- #shift — Que::JobBuffer
- #shift_job — Que::JobBuffer
- #should_poll? — Que::Poller
- #shutdown — Que::Locker
- #size — Que::JobBuffer
- #split_out_ruby2_keywords — Que::Utils::Ruby2Keywords
- #startup — Que::Locker
- #stop — Que::JobBuffer
- #stop — Que::JobBuffer::PriorityQueue
- #stop — Que::Locker
- #stop! — Que::Locker
- #stopping? — Que::JobBuffer
- #stopping? — Que::Locker
- #sync — Que::ConnectionPool
- #sync — Que::JobBuffer
- #sync — Que::JobBuffer::PriorityQueue
- #sync — Que::ResultQueue
- #to_a — Que::JobBuffer
- #to_a — Que::ResultQueue
- #transaction — Que::Utils::Transactions
- #unlisten — Que::Listener
- #unlock_jobs — Que::Locker
- #wait — Que::Locker
- #wait_for_grouped_messages — Que::Listener
- #wait_for_messages — Que::Listener
- #wait_for_shutdown — Que::Locker
- #wait_for_stop — Que::Locker
- #wait_until_stopped — Que::Worker
- #waiting_count — Que::JobBuffer
- #waiting_count — Que::JobBuffer::PriorityQueue
- #work_job — Que::Worker
- #work_loop — Que::Locker
- #work_loop — Que::Worker
- #write_pid — Que::Locker