Table of Contents - qyu-1.1.0 Documentation
Pages
Classes and Modules
- Qyu
- Qyu::Concerns
- Qyu::Concerns::WorkflowDescriptorValidator
- Qyu::Config
- Qyu::Config::QueueConfig
- Qyu::Config::ServiceConfig
- Qyu::Config::StoreConfig
- Qyu::Errors
- Qyu::Errors::Base
- Qyu::Errors::CouldNotFetchTask
- Qyu::Errors::InvalidQueueName
- Qyu::Errors::InvalidTaskAttributes
- Qyu::Errors::InvalidWorkerConfigurationValue
- Qyu::Errors::JobNotFound
- Qyu::Errors::LockAlreadyAcquired
- Qyu::Errors::LockNotAcquired
- Qyu::Errors::MessageNotReceived
- Qyu::Errors::MissingSplitParameters
- Qyu::Errors::NotImplementedError
- Qyu::Errors::PayloadValidationError
- Qyu::Errors::TaskNotFound
- Qyu::Errors::TaskStatusUpdateFailed
- Qyu::Errors::UnknownValidationOption
- Qyu::Errors::UnsyncError
- Qyu::Errors::WorkflowDescriptorValidationError
- Qyu::Errors::WorkflowNotFound
- Qyu::Factory
- Qyu::Factory::QueueFactory
- Qyu::Factory::ServiceFactory
- Qyu::Factory::StoreFactory
- Qyu::Helpers
- Qyu::Helpers::Pagination
- Qyu::Helpers::Pagination::PaginatableArray
- Qyu::Job
- Qyu::Queue
- Qyu::Queue::Base
- Qyu::Queue::Memory
- Qyu::Queue::Memory::Adapter
- Qyu::Status
- Qyu::Store
- Qyu::Store::Base
- Qyu::Store::Memory
- Qyu::Store::Memory::Adapter
- Qyu::Task
- Qyu::Utils
- Qyu::Workers
- Qyu::Workers::Base
- Qyu::Workers::Concerns
- Qyu::Workers::Concerns::Callback
- Qyu::Workers::Concerns::FailureQueue
- Qyu::Workers::Concerns::PayloadValidator
- Qyu::Workers::Concerns::Split
- Qyu::Workers::Concerns::Timeout
- Qyu::Workers::Split
- Qyu::Workers::Sync
- Qyu::Workflow
Methods
- ::acknowledge_message — Qyu::Task
- ::clear_completed — Qyu::Job
- ::config — Qyu
- ::config= — Qyu
- ::configuration — Qyu
- ::configure — Qyu
- ::configured? — Qyu
- ::count — Qyu::Job
- ::count — Qyu::Workflow
- ::create — Qyu::Job
- ::create — Qyu::Task
- ::create — Qyu::Workflow
- ::default_logger — Qyu
- ::delete — Qyu::Job
- ::delete — Qyu::Workflow
- ::delete_by — Qyu::Workflow
- ::enqueue_in_failure_queue — Qyu::Task
- ::fetch — Qyu::Task
- ::find — Qyu::Status
- ::find — Qyu::Job
- ::find — Qyu::Workflow
- ::find_by — Qyu::Workflow
- ::find_by! — Qyu::Workflow
- ::find_by_name — Qyu::Workflow
- ::get — Qyu::Factory::ServiceFactory
- ::logger — Qyu
- ::logger= — Qyu
- ::new — Qyu::Config
- ::new — Qyu::Errors::CouldNotFetchTask
- ::new — Qyu::Errors::InvalidQueueName
- ::new — Qyu::Errors::InvalidTaskAttributes
- ::new — Qyu::Errors::InvalidWorkerConfigurationValue
- ::new — Qyu::Errors::JobNotFound
- ::new — Qyu::Errors::LockAlreadyAcquired
- ::new — Qyu::Errors::LockNotAcquired
- ::new — Qyu::Errors::MessageNotReceived
- ::new — Qyu::Errors::MissingSplitParameters
- ::new — Qyu::Errors::NotImplementedError
- ::new — Qyu::Errors::PayloadValidationError
- ::new — Qyu::Errors::TaskNotFound
- ::new — Qyu::Errors::TaskStatusUpdateFailed
- ::new — Qyu::Errors::UnknownValidationOption
- ::new — Qyu::Errors::UnsyncError
- ::new — Qyu::Errors::WorkflowDescriptorValidationError
- ::new — Qyu::Errors::WorkflowNotFound
- ::new — Qyu::Concerns::WorkflowDescriptorValidator
- ::new — Qyu::Status
- ::new — Qyu::Job
- ::new — Qyu::Task
- ::new — Qyu::Workflow
- ::new — Qyu::Queue::Memory::Adapter
- ::new — Qyu::Store::Memory::Adapter
- ::new — Qyu::Helpers::Pagination::PaginatableArray
- ::new — Qyu::Workers::Base
- ::persist — Qyu::Job
- ::persist — Qyu::Workflow
- ::queue — Qyu
- ::register — Qyu::Config::ServiceConfig
- ::register — Qyu::Factory::ServiceFactory
- ::requeue — Qyu::Task
- ::seconds_after_time — Qyu::Utils
- ::select — Qyu::Job
- ::select — Qyu::Task
- ::select — Qyu::Workflow
- ::store — Qyu
- ::stringify_hash_keys — Qyu::Utils
- ::test_connections — Qyu
- ::types — Qyu::Config::ServiceConfig
- ::types — Qyu::Factory::ServiceFactory
- ::uuid — Qyu::Utils
- ::valid? — Qyu::Config::ServiceConfig
- ::valid_attributes? — Qyu::Task
- ::valid_config? — Qyu::Queue::Base
- ::valid_config? — Qyu::Queue::Memory::Adapter
- ::valid_config? — Qyu::Store::Base
- ::valid_config? — Qyu::Store::Memory::Adapter
- ::valid_queue_name? — Qyu::Task
- #[] — Qyu::Job
- #[] — Qyu::Task
- #[] — Qyu::Workflow
- #acknowledge_message — Qyu::Task
- #acknowledge_message — Qyu::Queue::Base
- #acknowledge_message — Qyu::Queue::Memory::Adapter
- #acknowledge_message_with_task_id_not_found_in_store — Qyu::Workers::Base
- #acknowledgeable? — Qyu::Task
- #calc_func_x — Qyu::Job
- #callback — Qyu::Workers::Concerns::Callback
- #check_completion! — Qyu::Workers::Sync
- #clear_completed_jobs — Qyu::Store::Base
- #clear_completed_jobs — Qyu::Store::Memory::Adapter
- #completed — Qyu::Workers::Sync
- #completed? — Qyu::Status
- #completed? — Qyu::Task
- #conclude_task — Qyu::Workers::Base
- #count_jobs — Qyu::Store::Base
- #count_jobs — Qyu::Store::Memory::Adapter
- #create_next_tasks — Qyu::Job
- #create_task — Qyu::Job
- #delete_job — Qyu::Store::Base
- #delete_job — Qyu::Store::Memory::Adapter
- #delete_workflow — Qyu::Store::Base
- #delete_workflow — Qyu::Store::Memory::Adapter
- #delete_workflow_by_name — Qyu::Store::Base
- #delete_workflow_by_name — Qyu::Store::Memory::Adapter
- #descriptor — Qyu::Task
- #discard_completed_task — Qyu::Workers::Base
- #enqueue_in_failure_queue — Qyu::Task
- #enqueue_task — Qyu::Queue::Base
- #enqueue_task — Qyu::Queue::Memory::Adapter
- #enqueue_task_to_failed_queue — Qyu::Queue::Base
- #enqueue_task_to_failed_queue — Qyu::Queue::Memory::Adapter
- #enqueue_tasks — Qyu::Queue::Base
- #entry_points — Qyu::Concerns::WorkflowDescriptorValidator
- #eq_completed — Qyu::Workers::Sync
- #fail_task — Qyu::Workers::Base
- #failed? — Qyu::Status
- #failure_queue — Qyu::Workers::Concerns::FailureQueue
- #fetch_next_message — Qyu::Queue::Base
- #fetch_next_message — Qyu::Queue::Memory::Adapter
- #fetch_task — Qyu::Workers::Base
- #find_callback — Qyu::Workers::Concerns::Callback
- #find_job — Qyu::Store::Base
- #find_job — Qyu::Store::Memory::Adapter
- #find_or_persist_task — Qyu::Store::Base
- #find_or_persist_task — Qyu::Store::Memory::Adapter
- #find_task — Qyu::Store::Base
- #find_task — Qyu::Store::Memory::Adapter
- #find_task_ids_by_job_id_and_name — Qyu::Store::Base
- #find_task_ids_by_job_id_and_name — Qyu::Store::Memory::Adapter
- #find_task_ids_by_job_id_name_and_parent_task_ids — Qyu::Store::Base
- #find_task_ids_by_job_id_name_and_parent_task_ids — Qyu::Store::Memory::Adapter
- #find_task_ids_by_name — Qyu::Job
- #find_task_ids_by_name_and_ancestor_task_id — Qyu::Job
- #find_workflow — Qyu::Store::Base
- #find_workflow — Qyu::Store::Memory::Adapter
- #find_workflow_by_name — Qyu::Store::Base
- #find_workflow_by_name — Qyu::Store::Memory::Adapter
- #get_or_create_queue — Qyu::Queue::Memory::Adapter
- #invalid_payload? — Qyu::Status
- #job — Qyu::Task
- #lock! — Qyu::Task
- #lock_task! — Qyu::Store::Base
- #lock_task! — Qyu::Store::Memory::Adapter
- #locked? — Qyu::Task
- #log — Qyu::Workers::Base
- #mark_completed — Qyu::Task
- #mark_failed — Qyu::Task
- #mark_invalid_payload — Qyu::Task
- #mark_queued — Qyu::Task
- #mark_working — Qyu::Task
- #message_acknowledged? — Qyu::Queue::Memory::Adapter
- #next_pages_for — Qyu::Helpers::Pagination
- #next_task_names — Qyu::Job
- #payload_key — Qyu::Workers::Concerns::Split
- #persist_job — Qyu::Store::Base
- #persist_job — Qyu::Store::Memory::Adapter
- #persist_workflow — Qyu::Store::Base
- #persist_workflow — Qyu::Store::Memory::Adapter
- #previous_pages_for — Qyu::Helpers::Pagination
- #queue — Qyu::Queue::Memory::Adapter
- #queue_name — Qyu::Job
- #queued? — Qyu::Status
- #queues — Qyu::Queue::Base
- #queues — Qyu::Queue::Memory::Adapter
- #renew_lock_lease — Qyu::Store::Base
- #renew_lock_lease — Qyu::Store::Memory::Adapter
- #requeue — Qyu::Task
- #run_callbacks — Qyu::Workers::Concerns::Callback
- #run_garbage_collector — Qyu::Workers::Base
- #sample — Qyu::Workers::Concerns::Split
- #schedule_renewal — Qyu::Task
- #schedule_requeue — Qyu::Queue::Memory::Adapter
- #select_jobs — Qyu::Store::Base
- #select_jobs — Qyu::Store::Memory::Adapter
- #select_tasks_by_job_id — Qyu::Store::Base
- #select_tasks_by_job_id — Qyu::Store::Memory::Adapter
- #size — Qyu::Queue::Base
- #size — Qyu::Queue::Memory::Adapter
- #slice_size — Qyu::Workers::Concerns::Split
- #start — Qyu::Job
- #status — Qyu::Status
- #sync_condition — Qyu::Job
- #task_name? — Qyu::Job
- #task_payload — Qyu::Job
- #task_status_counts — Qyu::Job
- #task_status_counts — Qyu::Store::Base
- #task_status_counts — Qyu::Store::Memory::Adapter
- #tasks — Qyu::Concerns::WorkflowDescriptorValidator
- #tasks_to_wait_for — Qyu::Job
- #timeout — Qyu::Workers::Concerns::Timeout
- #total_pages — Qyu::Helpers::Pagination::PaginatableArray
- #transaction — Qyu::Store::Base
- #transaction — Qyu::Store::Memory::Adapter
- #unlock! — Qyu::Task
- #unlock_task! — Qyu::Store::Base
- #unlock_task! — Qyu::Store::Memory::Adapter
- #update_status — Qyu::Store::Base
- #update_status — Qyu::Store::Memory::Adapter
- #valid? — Qyu::Concerns::WorkflowDescriptorValidator
- #validate — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_descriptor_type — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_entry_points_presence — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_entry_points_type — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_format — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_payload! — Qyu::Workers::Concerns::PayloadValidator
- #validate_presence_of_reference_tasks — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_queue_presence — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_referenced_tasks — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_split_parameters! — Qyu::Workers::Concerns::Split
- #validate_sync_condition_params — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_task_keys — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_task_reference_formats — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_tasks_presence — Qyu::Concerns::WorkflowDescriptorValidator
- #validate_tasks_type — Qyu::Concerns::WorkflowDescriptorValidator
- #validates — Qyu::Workers::Concerns::PayloadValidator
- #work — Qyu::Workers::Base
- #work — Qyu::Workers::Split
- #work — Qyu::Workers::Sync
- #workflow — Qyu::Task
- #workflow_descriptor — Qyu::Task
- #working? — Qyu::Status