Table of Contents - chore-core-4.2.0 Documentation
Pages
- LICENSE
-
README
- Chore: Async Job Processing Framework For Ruby
- About
- Configuration
- Tips For Configuring Chore
- Producing & Consuming Jobs
- Integration
Chore::Job
Chore::Job
&perform
SignaturesChore::Job
& Publishing Jobs- Retry Backoff Strategy
- Setup
- Using The Backoff
- Notes On SQS & Delays
- Hooks
- Global Hooks
- Filesystem Consumer/Publisher Hooks
- SQS Consumer Hooks
- Per Job
- Signals
- Timeouts
- Plugins
- Managing Chore Processes
- Sample Upstart
- Locating Processes
- Copyright
- queues.task
Classes and Modules
- Chore
- Chore::CLI
- Chore::Configuration
- Chore::Consumer
- Chore::DuplicateDetector
- Chore::Encoder
- Chore::Encoder::JsonEncoder
- Chore::Fetcher
- Chore::FilesystemQueue
- Chore::Hooks
- Chore::Job
- Chore::Job::ClassMethods
- Chore::Job::RejectMessageException
- Chore::Manager
- Chore::Publisher
- Chore::Queues
- Chore::Queues::Filesystem
- Chore::Queues::Filesystem::Consumer
- Chore::Queues::Filesystem::Publisher
- Chore::Queues::SQS
- Chore::Queues::SQS::Consumer
- Chore::Queues::SQS::Publisher
- Chore::Railtie
- Chore::Signal
- Chore::Strategy
- Chore::Strategy::Batcher
- Chore::Strategy::ForkedWorkerStrategy
- Chore::Strategy::Ipc
- Chore::Strategy::PreForkedWorkerStrategy
- Chore::Strategy::PreforkedWorker
- Chore::Strategy::SingleConsumerStrategy
- Chore::Strategy::SingleWorkerStrategy
- Chore::Strategy::ThreadedConsumerStrategy
- Chore::Strategy::ThrottledConsumerStrategy
- Chore::Strategy::WorkDistributor
- Chore::Strategy::WorkerInfo
- Chore::Strategy::WorkerKiller
- Chore::Strategy::WorkerManager
- Chore::TerribleMistake
- Chore::TimeoutError
- Chore::UnitOfWork
- Chore::Util
- Chore::Version
- Chore::Worker
Methods
- ::cleanup — Chore::Queues::Filesystem::Consumer
- ::create_queues! — Chore::Queues::SQS
- ::decode — Chore::Encoder::JsonEncoder
- ::decode — Chore::Job
- ::delete_queues! — Chore::Queues::SQS
- ::each_file — Chore::Queues::Filesystem::Consumer
- ::encode — Chore::Encoder::JsonEncoder
- ::existing_queues — Chore::Queues::SQS
- ::file_info — Chore::Queues::Filesystem::Consumer
- ::listen — Chore::Signal
- ::make_in_progress — Chore::Queues::Filesystem::Consumer
- ::make_new_again — Chore::Queues::Filesystem::Consumer
- ::new — Chore::CLI
- ::new — Chore::Consumer
- ::new — Chore::Manager
- ::new — Chore::Publisher
- ::new — Chore::Queues::Filesystem::Consumer
- ::new — Chore::Queues::SQS::Consumer
- ::new — Chore::Queues::SQS::Publisher
- ::new — Chore::Strategy::Batcher
- ::new — Chore::Strategy::SingleConsumerStrategy
- ::new — Chore::Strategy::ThreadedConsumerStrategy
- ::new — Chore::Strategy::WorkerInfo
- ::new — Chore::Strategy::SingleWorkerStrategy
- ::new — Chore::Worker
- ::new — Chore::Job
- ::next_signal — Chore::Signal
- ::on_wakeup — Chore::Signal
- ::payload — Chore::Job
- ::payload_class — Chore::Job
- ::process — Chore::Signal
- ::publish — Chore::Publisher
- ::register_option — Chore::CLI
- ::reset — Chore::Signal
- ::reset_connection! — Chore::Consumer
- ::reset_connection! — Chore::Publisher
- ::reset_connection! — Chore::Queues::SQS::Consumer
- ::reset_connection! — Chore::Queues::SQS::Publisher
- ::sqs_client — Chore::Queues::SQS
- ::trap — Chore::Signal
- ::wakeup — Chore::Signal
- #acquire_worker — Chore::Strategy::SingleWorkerStrategy
- #add — Chore::Strategy::Batcher
- #assign — Chore::Manager
- #assign — Chore::Strategy::SingleWorkerStrategy
- #attempt_to_delay — Chore::Worker
- #candidate_methods — Chore::Hooks
- #complete — Chore::Consumer
- #complete — Chore::Queues::Filesystem::Consumer
- #complete — Chore::Queues::SQS::Consumer
- #config_dir — Chore::FilesystemQueue
- #config_value — Chore::FilesystemQueue
- #constantize — Chore::Util
- #consume — Chore::Consumer
- #consume — Chore::Queues::Filesystem::Consumer
- #consume — Chore::Queues::SQS::Consumer
- #current_attempt — Chore::UnitOfWork
- #dedupe_key — Chore::Job::ClassMethods
- #delay — Chore::Queues::SQS::Consumer
- #dupe_detector — Chore::Consumer
- #duplicate_message? — Chore::Consumer
- #duplicate_work? — Chore::Worker
- #encode_job — Chore::Publisher
- #execute — Chore::Strategy::Batcher
- #expired? — Chore::Worker
- #expires_at — Chore::Worker
- #fetch — Chore::Strategy::SingleConsumerStrategy
- #fetch — Chore::Strategy::ThreadedConsumerStrategy
- #fetch_work — Chore::Manager
- #filename — Chore::Queues::Filesystem::Publisher
- #global_hooks_for — Chore::Hooks
- #handle_failure — Chore::Worker
- #handle_messages — Chore::Consumer
- #handle_messages — Chore::Queues::Filesystem::Consumer
- #handle_messages — Chore::Queues::SQS::Consumer
- #has_backoff? — Chore::Job::ClassMethods
- #has_dedupe_lambda? — Chore::Job::ClassMethods
- #hooks_for — Chore::Hooks
- #in_progress_dir — Chore::FilesystemQueue
- #job_hash — Chore::Job::ClassMethods
- #make_in_progress — Chore::Queues::Filesystem::Consumer
- #make_new_again — Chore::Queues::Filesystem::Consumer
- #merge_hash — Chore::Configuration
- #new_dir — Chore::FilesystemQueue
- #perform — Chore::Job
- #perform — Chore::Job::ClassMethods
- #perform_async — Chore::Job
- #perform_async — Chore::Job::ClassMethods
- #perform_job — Chore::Worker
- #prefixed_queue_name — Chore::Job::ClassMethods
- #prepare_dir — Chore::FilesystemQueue
- #procline — Chore::Util
- #provide_work — Chore::Consumer
- #publish — Chore::Publisher
- #publish — Chore::Queues::Filesystem::Publisher
- #publish — Chore::Queues::SQS::Publisher
- #queue — Chore::Queues::SQS::Consumer
- #queue — Chore::Queues::SQS::Publisher
- #queue_dir — Chore::FilesystemQueue
- #queue_options — Chore::Job::ClassMethods
- #queue_timeout — Chore::Queues::SQS::Consumer
- #queue_timeout — Chore::FilesystemQueue
- #ready? — Chore::Strategy::Batcher
- #reject — Chore::Consumer
- #reject — Chore::Queues::Filesystem::Consumer
- #reject — Chore::Queues::SQS::Consumer
- #release_worker — Chore::Strategy::SingleWorkerStrategy
- #required_options — Chore::Job::ClassMethods
- #return_work — Chore::Manager
- #root_dir — Chore::FilesystemQueue
- #run! — Chore::CLI
- #run_hooks_for — Chore::Hooks
- #running? — Chore::Consumer
- #running? — Chore::Strategy::ThreadedConsumerStrategy
- #schedule — Chore::Strategy::Batcher
- #shutdown — Chore::CLI
- #shutdown! — Chore::Manager
- #sqs — Chore::Queues::SQS::Consumer
- #sqs — Chore::Queues::SQS::Publisher
- #sqs_polling_amount — Chore::Queues::SQS::Consumer
- #start — Chore::Manager
- #start — Chore::Strategy::SingleWorkerStrategy
- #start — Chore::Worker
- #start_consumer_thread — Chore::Strategy::ThreadedConsumerStrategy
- #start_item — Chore::Worker
- #stop — Chore::Consumer
- #stop — Chore::Strategy::Batcher
- #stop! — Chore::Strategy::SingleConsumerStrategy
- #stop! — Chore::Strategy::ThreadedConsumerStrategy
- #stop! — Chore::Strategy::SingleWorkerStrategy
- #stop! — Chore::Worker
- #validate_dir — Chore::FilesystemQueue
- #validate_strategy! — Chore::CLI
- #worker_klass — Chore::Strategy::SingleWorkerStrategy