Class Skynet::MessageQueueAdapter::Mysql
In: lib/skynet/message_queue_adapters/mysql.rb
Parent: Skynet::MessageQueueAdapter

Methods

adapter   clear_outstanding_tasks   debug_class_desc   delete_expired_messages   get_worker_version   list_results   list_tasks   message_queue_table   message_to_conditions   message_to_hash   new   set_worker_version   start_or_connect   stats   take_next_task   take_result   template_to_conditions   update_message_with_result   version_active?   write_error   write_fallback_message   write_message   write_result  

Included Modules

SkynetDebugger Skynet::GuidGenerator

Constants

SEARCH_FIELDS = [:tasktype, :task_id, :job_id, :payload_type, :expire_time, :iteration, :version] unless defined?(SEARCH_FIELDS)

Public Class methods

Public Instance methods

stats()

select hostname, iteration, count(id) as number_of_workers, count(iteration) as iteration, sum(processed) as processed, max(started_at) as most_recent_task_time from skynet_worker_queues where tasksubtype = ‘worker’ group by hostname, iteration;

select hostname, count(id) as number_of_workers, sum(processed) as processed, max(started_at) as most_recent_task_time, CASE iteration WHEN NULL

from skynet_worker_queues where tasksubtype = ‘worker’ group by hostname;

[Validate]