Table of Contents - lowkiq-1.1.0 Documentation
Classes and Modules
- Lowkiq
- Lowkiq::OptionParser
- Lowkiq::Queue
- Lowkiq::Queue::Actions
- Lowkiq::Queue::Fetch
- Lowkiq::Queue::Keys
- Lowkiq::Queue::Queries
- Lowkiq::Queue::Queue
- Lowkiq::Queue::QueueMetrics
- Lowkiq::Queue::ShardMetrics
- Lowkiq::RedisInfo
- Lowkiq::Schedulers
- Lowkiq::Schedulers::Lag
- Lowkiq::Schedulers::Seq
- Lowkiq::Script
- Lowkiq::Server
- Lowkiq::ShardHandler
- Lowkiq::Splitters
- Lowkiq::Splitters::ByNode
- Lowkiq::Splitters::Default
- Lowkiq::Utils
- Lowkiq::Utils::Array
- Lowkiq::Utils::Redis
- Lowkiq::Utils::Timestamp
- Lowkiq::Web
- Lowkiq::Web::Action
- Lowkiq::Web::Api
- Lowkiq::Worker
Methods
- ::build — Lowkiq::Server
- ::build_by_node_splitter — Lowkiq
- ::build_default_splitter — Lowkiq
- ::build_lag_scheduler — Lowkiq
- ::build_many — Lowkiq::ShardHandler
- ::build_seq_scheduler — Lowkiq
- ::call — Lowkiq::Web
- ::call — Lowkiq::Web::Api
- ::client_redis_pool — Lowkiq
- ::match_to_worker — Lowkiq::Web::Api
- ::new — Lowkiq::Queue::Actions
- ::new — Lowkiq::Queue::Fetch
- ::new — Lowkiq::Queue::Keys
- ::new — Lowkiq::Queue::Queries
- ::new — Lowkiq::Queue::Queue
- ::new — Lowkiq::Queue::QueueMetrics
- ::new — Lowkiq::Queue::ShardMetrics
- ::new — Lowkiq::RedisInfo
- ::new — Lowkiq::Schedulers::Lag
- ::new — Lowkiq::Schedulers::Seq
- ::new — Lowkiq::Server
- ::new — Lowkiq::ShardHandler
- ::new — Lowkiq::Splitters::ByNode
- ::new — Lowkiq::Splitters::Default
- ::new — Lowkiq::Utils::Array
- ::new — Lowkiq::Utils::Redis
- ::new — Lowkiq::Web::Action
- ::now — Lowkiq::Utils::Timestamp
- ::segments_to_regex — Lowkiq::Web::Action
- ::server_redis_pool — Lowkiq
- ::server_wrapper — Lowkiq
- ::shard_handlers — Lowkiq
- #_fetch — Lowkiq::Queue::Queries
- #_morgue_fetch — Lowkiq::Queue::Queries
- #ack — Lowkiq::Queue::Queue
- #all_ids_lex_zset — Lowkiq::Queue::Keys
- #all_ids_scored_by_perform_in_zset — Lowkiq::Queue::Keys
- #all_ids_scored_by_retry_count_zset — Lowkiq::Queue::Keys
- #batch_from_data — Lowkiq::ShardHandler
- #build_job — Lowkiq::Schedulers::Lag
- #build_job — Lowkiq::Schedulers::Seq
- #call — Lowkiq::Queue::QueueMetrics
- #call — Lowkiq::Queue::ShardMetrics
- #call — Lowkiq::RedisInfo
- #call — Lowkiq::Splitters::ByNode
- #call — Lowkiq::Splitters::Default
- #call — Lowkiq::Web::Action
- #call — Lowkiq::OptionParser
- #client_actions — Lowkiq
- #client_queries — Lowkiq
- #client_queue — Lowkiq
- #coerce — Lowkiq::Queue::QueueMetrics
- #coerce — Lowkiq::Queue::ShardMetrics
- #coerce_busy — Lowkiq::Queue::QueueMetrics
- #coerce_lag — Lowkiq::Queue::QueueMetrics
- #coerce_lag — Lowkiq::Queue::ShardMetrics
- #delete — Lowkiq::Queue::Queue
- #delete_all_failed_jobs — Lowkiq::Queue::Actions
- #errors_hash — Lowkiq::Queue::Keys
- #exit_from_thread? — Lowkiq::Server
- #fail! — Lowkiq::ShardHandler
- #failed? — Lowkiq::Server
- #failed_key — Lowkiq::Queue::Keys
- #fetch — Lowkiq::Queue::Fetch
- #fetch — Lowkiq::Queue::Queries
- #hmove — Lowkiq::Script
- #id_to_shard — Lowkiq::Queue::Queue
- #ids_scored_by_perform_in_zset — Lowkiq::Queue::Keys
- #in_transposed_groups — Lowkiq::Utils::Array
- #join — Lowkiq::Server
- #kill_all_failed_jobs — Lowkiq::Queue::Actions
- #load! — Lowkiq::Script
- #morgue_all_ids_lex_zset — Lowkiq::Queue::Keys
- #morgue_all_ids_scored_by_updated_at_zset — Lowkiq::Queue::Keys
- #morgue_delete — Lowkiq::Queue::Queue
- #morgue_delete_all_jobs — Lowkiq::Queue::Actions
- #morgue_errors_hash — Lowkiq::Queue::Keys
- #morgue_fetch — Lowkiq::Queue::Fetch
- #morgue_fetch — Lowkiq::Queue::Queries
- #morgue_payloads_zset — Lowkiq::Queue::Keys
- #morgue_queue_up — Lowkiq::Queue::Actions
- #morgue_queue_up_all_jobs — Lowkiq::Queue::Actions
- #morgue_range_by_id — Lowkiq::Queue::Queries
- #morgue_range_by_updated_at — Lowkiq::Queue::Queries
- #morgue_rev_range_by_id — Lowkiq::Queue::Queries
- #morgue_rev_range_by_updated_at — Lowkiq::Queue::Queries
- #payloads_zset — Lowkiq::Queue::Keys
- #perform — Lowkiq
- #perform_all_jobs_now — Lowkiq::Queue::Actions
- #perform_async — Lowkiq
- #pipeline — Lowkiq::Queue::QueueMetrics
- #pipeline — Lowkiq::Queue::ShardMetrics
- #pipeline_count — Lowkiq::Queue::QueueMetrics
- #pipeline_count — Lowkiq::Queue::ShardMetrics
- #pop — Lowkiq::Queue::Queue
- #process — Lowkiq::ShardHandler
- #processed_key — Lowkiq::Queue::Keys
- #processing_data — Lowkiq::Queue::Queue
- #processing_data_build — Lowkiq::Queue::Queue
- #processing_data_pipeline — Lowkiq::Queue::Queue
- #processing_errors_hash — Lowkiq::Queue::Keys
- #processing_ids_with_perform_in_hash — Lowkiq::Queue::Keys
- #processing_ids_with_retry_count_hash — Lowkiq::Queue::Keys
- #processing_length_by_shard_hash — Lowkiq::Queue::Keys
- #processing_payloads_zset — Lowkiq::Queue::Keys
- #push — Lowkiq::Queue::Queue
- #push_back — Lowkiq::Queue::Queue
- #push_to_morgue — Lowkiq::Queue::Queue
- #range_by_id — Lowkiq::Queue::Queries
- #range_by_perform_in — Lowkiq::Queue::Queries
- #range_by_retry_count — Lowkiq::Queue::Queries
- #restore — Lowkiq::ShardHandler
- #retry_in — Lowkiq
- #rev_range_by_id — Lowkiq::Queue::Queries
- #rev_range_by_perform_in — Lowkiq::Queue::Queries
- #rev_range_by_retry_count — Lowkiq::Queue::Queries
- #separate — Lowkiq::ShardHandler
- #shards — Lowkiq::Queue::Queue
- #start — Lowkiq::Server
- #stop — Lowkiq::Server
- #stopped? — Lowkiq::Server
- #zremhset — Lowkiq::Script
- #zresetscores — Lowkiq::Utils::Redis