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

Methods

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

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]