Table of Contents - shoryuken-5.3.0 Documentation
Classes and Modules
- ActiveJob
- ActiveJob::QueueAdapters
- ActiveJob::QueueAdapters::ShoryukenAdapter
- ActiveJob::QueueAdapters::ShoryukenAdapter::JobWrapper
- ActiveJob::QueueAdapters::ShoryukenConcurrentSendAdapter
- Hash
- Object
- Shoryuken
- Shoryuken::ActiveJobExtensions
- Shoryuken::ActiveJobExtensions::SQSSendMessageParametersAccessor
- Shoryuken::ActiveJobExtensions::SQSSendMessageParametersSupport
- Shoryuken::BodyParser
- Shoryuken::Client
- Shoryuken::DefaultWorkerRegistry
- Shoryuken::EnvironmentLoader
- Shoryuken::Fetcher
- Shoryuken::HashExt
- Shoryuken::HashExt::DeepSymbolizeKeys
- Shoryuken::HashExt::StringifyKeys
- Shoryuken::HashExt::SymbolizeKeys
- Shoryuken::Launcher
- Shoryuken::Logging
- Shoryuken::Logging::Pretty
- Shoryuken::Manager
- Shoryuken::Message
- Shoryuken::Middleware
- Shoryuken::Middleware::Chain
- Shoryuken::Middleware::Entry
- Shoryuken::Middleware::Server
- Shoryuken::Middleware::Server::ActiveRecord
- Shoryuken::Middleware::Server::AutoDelete
- Shoryuken::Middleware::Server::AutoExtendVisibility
- Shoryuken::Middleware::Server::AutoExtendVisibility::MessageVisibilityExtender
- Shoryuken::Middleware::Server::ExponentialBackoffRetry
- Shoryuken::Middleware::Server::Timing
- Shoryuken::Options
- Shoryuken::Polling
- Shoryuken::Polling::BaseStrategy
- Shoryuken::Polling::StrictPriority
- Shoryuken::Polling::WeightedRoundRobin
- Shoryuken::Processor
- Shoryuken::Queue
- Shoryuken::Runner
- Shoryuken::Shutdown
- Shoryuken::StringExt
- Shoryuken::StringExt::Constantize
- Shoryuken::Util
- Shoryuken::Worker
- Shoryuken::Worker::ClassMethods
- Shoryuken::Worker::DefaultExecutor
- Shoryuken::Worker::InlineExecutor
- Shoryuken::WorkerRegistry
- String
Methods
- ::call — Shoryuken::Worker::InlineExecutor
- ::enqueue — ActiveJob::QueueAdapters::ShoryukenAdapter
- ::enqueue_at — ActiveJob::QueueAdapters::ShoryukenAdapter
- ::healthy? — Shoryuken
- ::included — Shoryuken::Worker
- ::initialize_logger — Shoryuken::Logging
- ::instance — ActiveJob::QueueAdapters::ShoryukenAdapter
- ::load_for_rails_console — Shoryuken::EnvironmentLoader
- ::logger — Shoryuken::Logging
- ::logger= — Shoryuken::Logging
- ::new — Shoryuken::DefaultWorkerRegistry
- ::new — Shoryuken::EnvironmentLoader
- ::new — ActiveJob::QueueAdapters::ShoryukenConcurrentSendAdapter
- ::new — Shoryuken::Fetcher
- ::new — Shoryuken::Launcher
- ::new — Shoryuken::Manager
- ::new — Shoryuken::Message
- ::new — Shoryuken::Middleware::Chain
- ::new — Shoryuken::Middleware::Entry
- ::new — Shoryuken::Options
- ::new — Shoryuken::Polling::StrictPriority
- ::new — Shoryuken::Polling::WeightedRoundRobin
- ::new — Shoryuken::Processor
- ::new — Shoryuken::Queue
- ::new — Shoryuken::ActiveJobExtensions::SQSSendMessageParametersSupport
- ::parse — Shoryuken::BodyParser
- ::perform_async — Shoryuken::Worker::DefaultExecutor
- ::perform_async — Shoryuken::Worker::InlineExecutor
- ::perform_in — Shoryuken::Worker::DefaultExecutor
- ::perform_in — Shoryuken::Worker::InlineExecutor
- ::process — Shoryuken::Processor
- ::queues — Shoryuken::Client
- ::setup_options — Shoryuken::EnvironmentLoader
- ::shoryuken_options — Shoryuken
- ::sqs — Shoryuken::Client
- ::sqs= — Shoryuken::Client
- ::with_context — Shoryuken::Logging
- #== — Shoryuken::Polling::BaseStrategy
- #active_job? — Shoryuken::Options
- #active_job_queue_name_prefixing? — Shoryuken::Options
- #active_queues — Shoryuken::Polling::BaseStrategy
- #active_queues — Shoryuken::Polling::StrictPriority
- #active_queues — Shoryuken::Polling::WeightedRoundRobin
- #add — Shoryuken::Middleware::Chain
- #add_fifo_attributes! — Shoryuken::Queue
- #add_group — Shoryuken::Options
- #add_queue — Shoryuken::Options
- #arn_to_url — Shoryuken::Queue
- #assign — Shoryuken::Manager
- #auto_delete? — Shoryuken::Worker::ClassMethods
- #auto_extend — Shoryuken::Middleware::Server::AutoExtendVisibility::MessageVisibilityExtender
- #auto_visibility_timeout? — Shoryuken::Worker::ClassMethods
- #auto_visibility_timer — Shoryuken::Middleware::Server::AutoExtendVisibility
- #batch_receive_messages? — Shoryuken::DefaultWorkerRegistry
- #batch_receive_messages? — Shoryuken::WorkerRegistry
- #batched_queue? — Shoryuken::Fetcher
- #batched_queue? — Shoryuken::Manager
- #body — Shoryuken::Processor
- #busy — Shoryuken::Manager
- #cache_visibility_timeout? — Shoryuken::Options
- #calculate_delay — ActiveJob::QueueAdapters::ShoryukenAdapter
- #call — Shoryuken::Logging::Pretty
- #call — Shoryuken::Middleware::Server::ActiveRecord
- #call — Shoryuken::Middleware::Server::AutoDelete
- #call — Shoryuken::Middleware::Server::AutoExtendVisibility
- #call — Shoryuken::Middleware::Server::ExponentialBackoffRetry
- #call — Shoryuken::Middleware::Server::Timing
- #change_visibility — Shoryuken::Message
- #clear — Shoryuken::DefaultWorkerRegistry
- #clear — Shoryuken::Middleware::Chain
- #clear — Shoryuken::WorkerRegistry
- #client_middleware — Shoryuken::Options
- #config_file_options — Shoryuken::EnvironmentLoader
- #configure_client — Shoryuken::Options
- #configure_server — Shoryuken::Options
- #constantize — Shoryuken::StringExt::Constantize
- #context — Shoryuken::Logging::Pretty
- #create_managers — Shoryuken::Launcher
- #current_queue_weight — Shoryuken::Polling::WeightedRoundRobin
- #daemonize — Shoryuken::Runner
- #deep_symbolize_keys — Shoryuken::HashExt::DeepSymbolizeKeys
- #default_client_middleware — Shoryuken::Options
- #default_server_middleware — Shoryuken::Options
- #default_worker_options — Shoryuken::Options
- #delay — Shoryuken::Options
- #delay — Shoryuken::Polling::BaseStrategy
- #delete — Shoryuken::Message
- #delete_messages — Shoryuken::Queue
- #dispatch — Shoryuken::Manager
- #dispatch_batch — Shoryuken::Manager
- #dispatch_loop — Shoryuken::Manager
- #dispatch_single_messages — Shoryuken::Manager
- #dup — Shoryuken::Middleware::Chain
- #elapsed — Shoryuken::Util
- #enqueue — ActiveJob::QueueAdapters::ShoryukenConcurrentSendAdapter
- #enqueue — Shoryuken::ActiveJobExtensions::SQSSendMessageParametersSupport
- #error_handler — ActiveJob::QueueAdapters::ShoryukenConcurrentSendAdapter
- #execute_soft_shutdown — Shoryuken::Runner
- #execute_terminal_stop — Shoryuken::Runner
- #executor — Shoryuken::Launcher
- #exists? — Shoryuken::Middleware::Chain
- #exponential_backoff? — Shoryuken::Worker::ClassMethods
- #fetch — Shoryuken::Fetcher
- #fetch_with_auto_retry — Shoryuken::Fetcher
- #fetch_worker — Shoryuken::DefaultWorkerRegistry
- #fetch_worker — Shoryuken::WorkerRegistry
- #fifo? — Shoryuken::Queue
- #fire_event — Shoryuken::Util
- #fire_utilization_update_event — Shoryuken::Manager
- #get_interval — Shoryuken::Middleware::Server::ExponentialBackoffRetry
- #handle_dispatch_error — Shoryuken::Manager
- #handle_failure — Shoryuken::Middleware::Server::ExponentialBackoffRetry
- #handle_signal — Shoryuken::Runner
- #healthy? — Shoryuken::Launcher
- #healthy? — Shoryuken::Runner
- #initialize_concurrent_logger — Shoryuken::Runner
- #initialize_fifo_attribute — Shoryuken::Queue
- #initialize_logger — Shoryuken::EnvironmentLoader
- #initialize_options — Shoryuken::EnvironmentLoader
- #initiate_stop — Shoryuken::Launcher
- #insert_after — Shoryuken::Middleware::Chain
- #insert_before — Shoryuken::Middleware::Chain
- #invoke — Shoryuken::Middleware::Chain
- #load — Shoryuken::EnvironmentLoader
- #load_rails — Shoryuken::EnvironmentLoader
- #logger — Shoryuken::Options
- #logger — Shoryuken::Util
- #make_new — Shoryuken::Middleware::Entry
- #max_number_of_messages — Shoryuken::Fetcher
- #maximum_queue_weight — Shoryuken::Polling::WeightedRoundRobin
- #message — ActiveJob::QueueAdapters::ShoryukenAdapter
- #message_id — Shoryuken::Manager
- #message_processed — Shoryuken::Polling::BaseStrategy
- #message_processed — Shoryuken::Polling::StrictPriority
- #message_processed — Shoryuken::Polling::WeightedRoundRobin
- #messages_found — Shoryuken::Polling::BaseStrategy
- #messages_found — Shoryuken::Polling::StrictPriority
- #messages_found — Shoryuken::Polling::WeightedRoundRobin
- #next_active_queue — Shoryuken::Polling::StrictPriority
- #next_queue — Shoryuken::Polling::BaseStrategy
- #next_queue — Shoryuken::Polling::StrictPriority
- #next_queue — Shoryuken::Polling::WeightedRoundRobin
- #next_visibility_timeout — Shoryuken::Middleware::Server::ExponentialBackoffRetry
- #normalize_worker_queue! — Shoryuken::Worker::ClassMethods
- #on — Shoryuken::Options
- #on_start — Shoryuken::Options
- #on_stop — Shoryuken::Options
- #options — Shoryuken::Options
- #parse_body — Shoryuken::Processor
- #parse_queue — Shoryuken::EnvironmentLoader
- #parse_queues — Shoryuken::EnvironmentLoader
- #patch_batch! — Shoryuken::Manager
- #pause — Shoryuken::Polling::StrictPriority
- #pause — Shoryuken::Polling::WeightedRoundRobin
- #perform_async — Shoryuken::Worker::ClassMethods
- #perform_at — Shoryuken::Worker::ClassMethods
- #perform_in — Shoryuken::Worker::ClassMethods
- #polling_strategy — Shoryuken::Options
- #prefix_active_job_queue_name — Shoryuken::EnvironmentLoader
- #prefix_active_job_queue_names — Shoryuken::EnvironmentLoader
- #prepend — Shoryuken::Middleware::Chain
- #print_threads_backtrace — Shoryuken::Runner
- #process — Shoryuken::Processor
- #processor_done — Shoryuken::Manager
- #queue_attributes — Shoryuken::Queue
- #queue_paused? — Shoryuken::Polling::StrictPriority
- #queue_weight — Shoryuken::Polling::WeightedRoundRobin
- #queues — Shoryuken::DefaultWorkerRegistry
- #queues — Shoryuken::WorkerRegistry
- #queues_unpaused_since? — Shoryuken::Polling::StrictPriority
- #ready — Shoryuken::Manager
- #receive_messages — Shoryuken::Fetcher
- #receive_messages — Shoryuken::Queue
- #receive_options — Shoryuken::Fetcher
- #register_worker — Shoryuken::DefaultWorkerRegistry
- #register_worker — Shoryuken::Options
- #register_worker — Shoryuken::WorkerRegistry
- #register_worker — Shoryuken::Worker::ClassMethods
- #register_worker! — ActiveJob::QueueAdapters::ShoryukenAdapter
- #remove — Shoryuken::Middleware::Chain
- #require_workers — Shoryuken::EnvironmentLoader
- #reset_next_queue — Shoryuken::Polling::StrictPriority
- #retrieve — Shoryuken::Middleware::Chain
- #run — Shoryuken::Runner
- #running? — Shoryuken::Manager
- #sanitize_message! — Shoryuken::Queue
- #sanitize_messages! — Shoryuken::Queue
- #send_concurrently — ActiveJob::QueueAdapters::ShoryukenConcurrentSendAdapter
- #send_message — Shoryuken::Queue
- #send_messages — Shoryuken::Queue
- #server? — Shoryuken::Options
- #server_middleware — Shoryuken::Options
- #server_middleware — Shoryuken::Worker::ClassMethods
- #set_by_name — Shoryuken::Queue
- #set_by_url — Shoryuken::Queue
- #set_name_and_url — Shoryuken::Queue
- #setup_options — Shoryuken::EnvironmentLoader
- #shoryuken_options — Shoryuken::Worker::ClassMethods
- #sqs_client — Shoryuken::Options
- #sqs_client_receive_message_opts= — Shoryuken::Options
- #start — Shoryuken::Launcher
- #start — Shoryuken::Manager
- #start_callback — Shoryuken::Launcher
- #start_managers — Shoryuken::Launcher
- #stop — Shoryuken::Launcher
- #stop! — Shoryuken::Launcher
- #stop_callback — Shoryuken::Launcher
- #stringify_keys — Shoryuken::HashExt::StringifyKeys
- #success_handler — ActiveJob::QueueAdapters::ShoryukenConcurrentSendAdapter
- #symbolize_keys — Shoryuken::HashExt::SymbolizeKeys
- #ungrouped_queues — Shoryuken::Options
- #unparse_queues — Shoryuken::Util
- #unpause_queues — Shoryuken::Polling::WeightedRoundRobin
- #validate_queues — Shoryuken::EnvironmentLoader
- #validate_workers — Shoryuken::EnvironmentLoader
- #visibility_timeout — Shoryuken::Queue
- #visibility_timeout= — Shoryuken::Message
- #worker — Shoryuken::Processor
- #worker_class — Shoryuken::Processor
- #worker_name — Shoryuken::Util
- #workers — Shoryuken::DefaultWorkerRegistry
- #workers — Shoryuken::WorkerRegistry
- #write_pid — Shoryuken::Runner