Module: SolidQueue
- Extended by:
- SolidQueue
- Included in:
- SolidQueue
- Defined in:
- lib/solid_queue.rb,
lib/solid_queue/pool.rb,
lib/solid_queue/engine.rb,
lib/solid_queue/worker.rb,
lib/solid_queue/version.rb,
app/models/solid_queue/job.rb,
lib/solid_queue/dispatcher.rb,
lib/solid_queue/supervisor.rb,
app/models/solid_queue/pause.rb,
app/models/solid_queue/queue.rb,
lib/solid_queue/app_executor.rb,
app/models/solid_queue/record.rb,
lib/solid_queue/configuration.rb,
lib/solid_queue/processes/base.rb,
app/models/solid_queue/execution.rb,
app/models/solid_queue/semaphore.rb,
app/models/solid_queue/job/clearable.rb,
app/models/solid_queue/job/retryable.rb,
app/models/solid_queue/job/executable.rb,
app/models/solid_queue/job/recurrable.rb,
app/models/solid_queue/queue_selector.rb,
app/models/solid_queue/job/schedulable.rb,
app/models/solid_queue/ready_execution.rb,
app/models/solid_queue/failed_execution.rb,
app/models/solid_queue/blocked_execution.rb,
lib/solid_queue/dispatcher/recurring_task.rb,
app/models/solid_queue/recurring_execution.rb,
app/models/solid_queue/scheduled_execution.rb,
app/models/solid_queue/execution/dispatching.rb,
lib/solid_queue/dispatcher/recurring_schedule.rb,
app/models/solid_queue/execution/job_attributes.rb,
app/models/solid_queue/job/concurrency_controls.rb,
lib/solid_queue/dispatcher/concurrency_maintenance.rb
Defined Under Namespace
Modules: AppExecutor, Processes
Classes: BlockedExecution, ClaimedExecution, Configuration, Dispatcher, Engine, Execution, FailedExecution, InstallGenerator, Job, LogSubscriber, Pause, Pool, Process, Queue, QueueSelector, ReadyExecution, Record, RecurringExecution, ScheduledExecution, Semaphore, Supervisor, Worker
Constant Summary
collapse
- DEFAULT_LOGGER =
ActiveSupport::Logger.new($stdout)
- VERSION =
"0.3.4"
Instance Method Summary
collapse
Instance Method Details
#instrument(channel, **options, &block) ⇒ Object
58
59
60
|
# File 'lib/solid_queue.rb', line 58
def instrument(channel, **options, &block)
ActiveSupport::Notifications.instrument("#{channel}.solid_queue", **options, &block)
end
|
#preserve_finished_jobs? ⇒ Boolean
54
55
56
|
# File 'lib/solid_queue.rb', line 54
def preserve_finished_jobs?
preserve_finished_jobs
end
|
#silence_polling? ⇒ Boolean
50
51
52
|
# File 'lib/solid_queue.rb', line 50
def silence_polling?
silence_polling
end
|
#supervisor? ⇒ Boolean
46
47
48
|
# File 'lib/solid_queue.rb', line 46
def supervisor?
supervisor
end
|