Table of Contents - RDoc Documentation
Classes and Modules
-
MerrittZK
- Merritt Queue Design
- Batch Queue vs Job Queue
- Use of ZooKeeper
- Code Examples
- Create Batch
- Consumer Daemon Acquires Batch and Creates Jobs
- Consumer Daemon Acquires Pending Job and Moves Job to Estimating
- Consumer Daemon Acquires Estimating Job and Updates Priority
- Acquire Completed Batch, Perform Reporting
- See Also
- MerrittZK::Access
- MerrittZK::AccessState
- MerrittZK::Batch
- MerrittZK::BatchState
- MerrittZK::IngestState
- MerrittZK::Job
- MerrittZK::JobState
- MerrittZK::LargeLegacyAccessJob
- MerrittZK::LegacyAccessJob
- MerrittZK::LegacyIngestJob
- MerrittZK::LegacyInventoryJob
- MerrittZK::LegacyItem
- MerrittZK::Locks
- MerrittZK::MerrittStateError
- MerrittZK::MerrittZKNodeInvalid
- MerrittZK::QueueItem
- MerrittZK::SmallLegacyAccessJob
- MerrittZK::ZkKeys
- MyZooTest
Methods
- ::acquire_batch_for_reporting_batch — MerrittZK::Batch
- ::acquire_job — MerrittZK::Job
- ::acquire_pending_assembly — MerrittZK::Access
- ::acquire_pending_batch — MerrittZK::Batch
- ::batch_uuid_path — MerrittZK::Batch
- ::check_lock_collection — MerrittZK::Locks
- ::check_lock_ingest_queue — MerrittZK::Locks
- ::check_lock_large_access_queue — MerrittZK::Locks
- ::check_lock_object_inventory — MerrittZK::Locks
- ::check_lock_object_storage — MerrittZK::Locks
- ::check_lock_small_access_queue — MerrittZK::Locks
- ::create_assembly — MerrittZK::Access
- ::create_batch — MerrittZK::Batch
- ::create_ephemeral_lock — MerrittZK::Locks
- ::create_id — MerrittZK::QueueItem
- ::create_if_needed — MerrittZK::Locks
- ::create_job — MerrittZK::Job
- ::create_lock — MerrittZK::Locks
- ::delete_completed_batches — MerrittZK::Batch
- ::dir — MerrittZK::Access
- ::dir — MerrittZK::Batch
- ::find_batch_by_uuid — MerrittZK::Batch
- ::init — MerrittZK::AccessState
- ::init — MerrittZK::BatchState
- ::init — MerrittZK::JobState
- ::init_locks — MerrittZK::Locks
- ::list_jobs_as_json — MerrittZK::Access
- ::list_jobs_as_json — MerrittZK::LegacyAccessJob
- ::list_jobs_as_json — MerrittZK::Job
- ::list_jobs_as_json — MerrittZK::LegacyIngestJob
- ::list_jobs_as_json — MerrittZK::LegacyInventoryJob
- ::lock_collection — MerrittZK::Locks
- ::lock_ingest_queue — MerrittZK::Locks
- ::lock_large_access_queue — MerrittZK::Locks
- ::lock_object_inventory — MerrittZK::Locks
- ::lock_object_storage — MerrittZK::Locks
- ::lock_small_access_queue — MerrittZK::Locks
- ::new — MerrittZK::Access
- ::new — MerrittZK::LegacyAccessJob
- ::new — MerrittZK::SmallLegacyAccessJob
- ::new — MerrittZK::LargeLegacyAccessJob
- ::new — MerrittZK::Batch
- ::new — MerrittZK::Job
- ::new — MerrittZK::QueueItem
- ::new — MerrittZK::LegacyItem
- ::new — MerrittZK::IngestState
- ::new — MyZooTest
- ::prefix_path — MerrittZK::Access
- ::prefix_path — MerrittZK::Batch
- ::prefix_path — MerrittZK::Job
- ::serialize — MerrittZK::QueueItem
- ::state_yaml — MerrittZK::IngestState
- ::unlock_collection — MerrittZK::Locks
- ::unlock_ingest_queue — MerrittZK::Locks
- ::unlock_large_access_queue — MerrittZK::Locks
- ::unlock_object_inventory — MerrittZK::Locks
- ::unlock_object_storage — MerrittZK::Locks
- ::unlock_small_access_queue — MerrittZK::Locks
- #batch_state_subpath — MerrittZK::Job
- #batch_uuid — MerrittZK::Batch
- #bid — MerrittZK::LegacyIngestJob
- #creator — MerrittZK::Job
- #creator — MerrittZK::LegacyIngestJob
- #data_prop — MerrittZK::QueueItem
- #deletable? — MerrittZK::IngestState
- #delete — MerrittZK::Access
- #delete — MerrittZK::Batch
- #delete — MerrittZK::Job
- #delete_all — MyZooTest
- #dir — MerrittZK::LegacyIngestJob
- #dir — MerrittZK::LegacyInventoryJob
- #dir — MerrittZK::LegacyItem
- #fail — MerrittZK::AccessState
- #fail — MerrittZK::BatchState
- #fail — MerrittZK::JobState
- #fail_lookup — MerrittZK::IngestState
- #filename — MerrittZK::Job
- #filename — MerrittZK::LegacyIngestJob
- #get_completed_jobs — MerrittZK::Batch
- #get_deleted_jobs — MerrittZK::Batch
- #get_failed_jobs — MerrittZK::Batch
- #get_jobs — MerrittZK::Batch
- #get_processing_jobs — MerrittZK::Batch
- #init — MyZooTest
- #input — MyZooTest
- #int_property — MerrittZK::QueueItem
- #json? — MerrittZK::LegacyAccessJob
- #json? — MerrittZK::LegacyInventoryJob
- #json? — MerrittZK::LegacyItem
- #json_property — MerrittZK::QueueItem
- #list — MyZooTest
- #list_all — MyZooTest
- #load — MerrittZK::QueueItem
- #load — MerrittZK::LegacyItem
- #load_has_failure — MerrittZK::Batch
- #load_optimized — MerrittZK::Job
- #load_properties — MerrittZK::Access
- #load_properties — MerrittZK::Batch
- #load_properties — MerrittZK::Job
- #load_properties — MerrittZK::QueueItem
- #load_status — MerrittZK::Job
- #load_status — MerrittZK::QueueItem
- #load_test — MyZooTest
- #lock — MerrittZK::QueueItem
- #make_path — MyZooTest
- #name — MerrittZK::IngestState
- #output — MyZooTest
- #path — MerrittZK::Access
- #path — MerrittZK::Batch
- #path — MerrittZK::Job
- #path — MerrittZK::QueueItem
- #path — MerrittZK::LegacyItem
- #payload_object — MerrittZK::LegacyAccessJob
- #payload_object — MerrittZK::LegacyInventoryJob
- #payload_object — MerrittZK::LegacyItem
- #payload_text — MerrittZK::LegacyItem
- #priority — MerrittZK::LegacyIngestJob
- #profile — MerrittZK::Job
- #profile — MerrittZK::LegacyIngestJob
- #response_form — MerrittZK::Job
- #response_form — MerrittZK::LegacyIngestJob
- #serialize — MyZooTest
- #set_batch_state_path — MerrittZK::Job
- #set_config — MyZooTest
- #set_data — MerrittZK::QueueItem
- #set_job_state_path — MerrittZK::Job
- #set_priority — MerrittZK::Job
- #set_space_needed — MerrittZK::Job
- #set_status — MerrittZK::Job
- #set_status — MerrittZK::QueueItem
- #set_status_with_priority — MerrittZK::Job
- #skip_listing — MyZooTest
- #space_needed — MerrittZK::LegacyIngestJob
- #state_change — MerrittZK::AccessState
- #state_change — MerrittZK::BatchState
- #state_change — MerrittZK::JobState
- #state_change_allowed — MerrittZK::IngestState
- #state_lookup — MerrittZK::IngestState
- #states — MerrittZK::Access
- #states — MerrittZK::Batch
- #states — MerrittZK::Job
- #states — MerrittZK::QueueItem
- #status_byte — MerrittZK::LegacyItem
- #status_name — MerrittZK::QueueItem
- #status_name — MerrittZK::LegacyItem
- #status_object — MerrittZK::Job
- #status_object — MerrittZK::QueueItem
- #status_path — MerrittZK::QueueItem
- #status_vals — MerrittZK::LegacyItem
- #string_property — MerrittZK::QueueItem
- #submitter — MerrittZK::Job
- #submitter — MerrittZK::LegacyIngestJob
- #success — MerrittZK::AccessState
- #success — MerrittZK::BatchState
- #success — MerrittZK::JobState
- #success_lookup — MerrittZK::IngestState
- #time — MerrittZK::LegacyItem
- #title — MerrittZK::Job
- #title — MerrittZK::LegacyIngestJob
- #to_s — MerrittZK::IngestState
- #type — MerrittZK::Job
- #type — MerrittZK::LegacyIngestJob
- #udpate — MerrittZK::Job
- #udpate — MerrittZK::LegacyIngestJob
- #unlock — MerrittZK::QueueItem
- #verify_output — MyZooTest
- #zk_new — MyZooTest