Methods

[] (Skynet::Message)
[] (Skynet::TaskIterator)
active_workers (Skynet::Manager)
adapter (Skynet::MessageQueue)
adapter (Skynet::MessageQueueAdapter::Mysql)
adapter (Skynet::MessageQueueAdapter::TupleSpace)
adapter_class (Skynet::MessageQueue)
add_lib (Skynet::ConsoleHelper)
add_message_queue (Skynet::Config)
add_worker (Skynet::Manager)
add_workers (Skynet::ConsoleHelper)
add_workers (Skynet::Manager)
all_workers_template (Skynet::WorkerStatusMessage)
ansi_clear (Skynet::MessageQueue)
args_pp (SkynetDebugger)
args_pp (SkynetDebugger::ClassMethods)
async? (Skynet::Job)
can_marshal? (Skynet::Task)
check_number_of_workers (Skynet::Manager)
check_running_pids (Skynet::Manager)
check_started_workers (Skynet::Manager)
check_workers (Skynet::Manager)
chunk_query (ActiveRecord::Mapreduce)
clear_outstanding_tasks (Skynet::MessageQueueAdapter)
clear_outstanding_tasks (Skynet::MessageQueueAdapter::TupleSpace)
clear_outstanding_tasks (Skynet::MessageQueueAdapter::Mysql)
configure (Skynet::UniqueDBNumGenerator)
constantize (String)
data_debug? (Skynet::Job)
debug (SkynetDebugger)
debug (Skynet::Loggable)
debug (SkynetDebugger::ClassMethods)
debug_class_desc (Skynet::MessageQueueAdapter::Mysql)
debug_class_desc (Skynet::MessageQueueAdapter::TupleSpace)
debug_class_desc (Skynet::Worker)
debug_class_desc (SkynetDebugger::ClassMethods)
debug_class_desc (Skynet::Manager)
debug_class_desc (Skynet::Task)
debug_class_desc (Skynet::Job)
debug_header (SkynetDebugger)
debug_header (SkynetDebugger::ClassMethods)
delete_expired_messages (Skynet::MessageQueueAdapter::Mysql)
display_info (Skynet::Job)
each (Skynet::TaskIterator)
each (Skynet::Config)
each (ActiveRecord::Mapreduce)
each_method (Skynet::TaskIterator)
each_range (ActiveRecord::Mapreduce)
empty? (Skynet::Job::LocalMessageQueue)
enqueue_messages (Skynet::Job)
error (SkynetDebugger::ClassMethods)
error (SkynetDebugger)
error (Skynet::Loggable)
error_message (Skynet::Message)
error_message (Skynet::Message)
error_template (Skynet::Message)
error_template (Skynet::Message)
fallback_task_message (Skynet::Message)
fallback_task_message (Skynet::Message)
fallback_template (Skynet::Message)
fallback_template (Skynet::Message)
fatal (Skynet::Loggable)
fatal (SkynetDebugger::ClassMethods)
fatal (SkynetDebugger)
fields (Skynet::Message)
find (ActiveRecord::Mapreduce)
find_pid_size (Skynet::Worker)
first (Skynet::TaskIterator)
gather_results (Skynet::Job)
get (Skynet::Manager)
get (Skynet::Logger)
get_memory_size (Skynet::Worker)
get_unique_id (Skynet::GuidGenerator)
get_worker_version (Skynet::MessageQueueAdapter::Mysql)
get_worker_version (Skynet::Job::LocalMessageQueue)
get_worker_version (Skynet::ConsoleHelper)
get_worker_version (Skynet::MessageQueue)
get_worker_version (Skynet::MessageQueueAdapter::TupleSpace)
get_worker_version (Skynet::MessageQueueAdapter)
hard_restart_workers (Skynet::Manager)
hostname (Skynet::Manager)
hostname (Skynet::Worker)
in_use? (Skynet::Job::LocalMessageQueue)
inactive_workers (Skynet::Manager)
included (SkynetDebugger)
included (MapreduceHelper)
increment_worker_version (Skynet::MessageQueue)
increment_worker_version (Skynet::ConsoleHelper)
index (Admin::SkynetController)
info (Skynet::Loggable)
info (SkynetDebugger)
info (SkynetDebugger::ClassMethods)
init_with_ary (Rinda::Tuple)
interrupt (Skynet::Worker)
keep_map_tasks (Skynet::Job)
keep_reduce_tasks (Skynet::Job)
list (Skynet::MessageQueue)
list_results (Skynet::MessageQueueAdapter::TupleSpace)
list_results (Skynet::MessageQueueAdapter::Mysql)
list_results (Skynet::MessageQueueAdapter)
list_tasks (Skynet::MessageQueueAdapter::Mysql)
list_tasks (Skynet::MessageQueueAdapter)
list_tasks (Skynet::MessageQueueAdapter::TupleSpace)
load_worker_queue_from_file (Skynet::Manager)
local_manager_uri (Skynet::Manager)
local_master? (Skynet::Job)
local_mq (Skynet::Job)
local_mq_reset! (Skynet::Job)
log (SkynetDebugger)
log (Skynet::ConsoleHelper)
log (ActiveRecord::Mapreduce)
log (SkynetDebugger::ClassMethods)
log (ActiveRecord::Mapreduce)
log= (Skynet::Logger)
logfile_location (Skynet::Config)
manager (Skynet::ConsoleHelper)
manager (Skynet::Worker)
manager_send (Skynet::Worker)
manager_statfile_location (Skynet::Config)
map (Skynet::ProfileCountTest)
map (Skynet::ActiveRecordAsync)
map (MapreduceHelper)
map (ActiveRecord::Mapreduce)
map (Skynet::MapreduceTest)
map (ActiveRecord::Mapreduce)
map= (Skynet::Job)
map= (Skynet::AsyncJob)
map_data= (Skynet::Job)
map_enqueue (Skynet::Job)
map_local? (Skynet::Job)
map_reduce_class= (Skynet::Job)
map_results (Skynet::Job)
map_retry (Skynet::Job)
map_tasks (Skynet::Job)
mapreduce (Enumerable)
mapreduce (ActiveRecord::Mapreduce)
mark_worker_as_stopped (Skynet::Manager)
master? (Skynet::Job)
master_enqueue (Skynet::Job)
master_results (Skynet::Job)
master_retry (Skynet::Job)
master_task (Skynet::Job)
master_task (Skynet::Task)
max_memory_reached? (Skynet::Worker)
message_fields (Skynet::MessageQueue)
message_queue_proxy_class (Skynet::MessageQueue)
message_queue_proxy_class (Skynet::MessageQueue)
message_queue_table (Skynet::MessageQueueAdapter::Mysql)
message_to_conditions (Skynet::MessageQueueAdapter::Mysql)
message_to_hash (Skynet::MessageQueueAdapter::Mysql)
method_missing (Skynet::Config)
method_missing (Skynet::Config)
model_class (ActiveRecord::Mapreduce)
model_class (ActiveRecord::Mapreduce)
model_class= (ActiveRecord::Mapreduce)
model_klass (ActiveRecord::Mapreduce)
mq (Skynet::MessageQueue)
mq (Skynet::ConsoleHelper)
mq (Skynet::Job)
mq (Skynet::Job)
new (ExceptionReport)
new (Skynet::MessageQueueAdapter::TupleSpace)
new (Skynet::Job)
new (Skynet::Message)
new (Skynet::WorkerStatusMessage)
new (Skynet::Task)
new (Skynet::Worker)
new (Skynet::WorkerVersionMessage)
new (Skynet::MessageQueueAdapter::Mysql)
new (Skynet::MessageQueue)
new (Skynet::Job::LocalMessageQueue)
new (Skynet::AsyncJob)
new (Skynet::Manager)
new (ActiveRecord::Mapreduce)
new (Skynet::TaskIterator)
new_task_message (Skynet::Message)
new_version_respawn? (Skynet::Worker)
next_task_template (Skynet::Message)
notify_task_begun (Skynet::Worker)
notify_task_complete (Skynet::Worker)
notify_worker_started (Skynet::Worker)
notify_worker_stop (Skynet::Worker)
ok_to_mem_check? (Skynet::Worker)
outstanding_results_template (Skynet::Message)
outstanding_tasks_template (Skynet::Message)
parent_pid (Skynet::Manager)
partition_data (Skynet::Job)
payload (Skynet::Message)
payload= (Skynet::Message)
payload_type (Skynet::Worker)
payload_type= (Skynet::Message)
pid_id (Skynet::UniqueDBNumGenerator)
pidfile_location (Skynet::Config)
ping (Skynet::Manager)
print_stats (Skynet::MessageQueue)
printlog (SkynetDebugger::ClassMethods)
printlog (SkynetDebugger)
printlog (Skynet::Logger)
process= (Skynet::Task)
process_id (Skynet::Worker)
prune_inactive_worker_stats (Skynet::Manager)
queue_id_by_name (Skynet::Config)
queue_name_by_id (Skynet::Config)
raw_payload (Skynet::Message)
raw_payload= (Skynet::Message)
read_all_worker_statuses (Skynet::MessageQueueAdapter)
read_pid_file (Skynet::Manager)
reduce (MapreduceHelper)
reduce (Skynet::ProfileCountTest)
reduce (Skynet::MapreduceTest)
reduce= (Skynet::Job)
reduce= (Skynet::AsyncJob)
reduce_enqueue (Skynet::Job)
reduce_local? (Skynet::Job)
reduce_partition (Skynet::Partitioners::ArrayDataSplitByFirstEntry)
reduce_partition (Skynet::Partitioners::RecombineAndSplit)
reduce_partition (Skynet::Partitioners::SimplePartitionData)
reduce_results (Skynet::Job)
reduce_retry (Skynet::Job)
reduce_tasks (Skynet::Job)
remove_worker (Skynet::Manager)
remove_workers (Skynet::ConsoleHelper)
remove_workers (Skynet::Manager)
reset! (Skynet::Job)
reset! (Skynet::Job::LocalMessageQueue)
restart_worker (Skynet::Manager)
restart_workers (Skynet::Manager)
restart_workers (Skynet::ConsoleHelper)
result_message (Skynet::Message)
result_message (Skynet::Message)
result_template (Skynet::Message)
results (Skynet::Job)
results_by_job_id (Skynet::Job)
run (Skynet::Task)
run (Skynet::ProfileCountTest)
run (Skynet::Job)
run (Skynet::Manager)
run_job_for_batch (ActiveRecord::Mapreduce)
run_manager (Skynet::Manager)
run_master (Skynet::Job)
run_message (Skynet::Job::LocalMessageQueue)
save (ExceptionReport)
save_worker_queue_to_file (Skynet::Manager)
send_later (ActiveRecord::Base)
server_num (Skynet::UniqueDBNumGenerator)
set_worker_version (Skynet::MessageQueueAdapter)
set_worker_version (Skynet::MessageQueueAdapter::TupleSpace)
set_worker_version (Skynet::MessageQueueAdapter::Mysql)
set_worker_version (Skynet::MessageQueue)
set_worker_version (Skynet::ConsoleHelper)
setup_signals (Skynet::Manager)
shutdown (Skynet::Manager)
signal_workers (Skynet::Manager)
single? (Skynet::Job)
size (Skynet::TaskIterator)
solo? (Skynet::Job)
start (Skynet::Worker)
start (Skynet::TuplespaceServer)
start (Skynet::Manager)
start (Skynet::Worker)
start (Skynet::Console)
start_after= (Skynet::Job)
start_or_connect (Skynet::MessageQueueAdapter::Mysql)
start_or_connect (Skynet::MessageQueue)
start_worker_queue_thread (Skynet::Manager)
start_workers (Skynet::Manager)
stats (Skynet::MessageQueueAdapter::TupleSpace)
stats (Skynet::Manager)
stats (Skynet::MessageQueueAdapter::Mysql)
stats (Skynet::ConsoleHelper)
stats_for_hosts (Skynet::Manager)
status (Admin::SkynetController)
stderr (SkynetDebugger)
stderr (SkynetDebugger::ClassMethods)
stdout (SkynetDebugger)
stdout (SkynetDebugger::ClassMethods)
stop (Skynet::Manager)
take (Rinda::TupleSpaceProxy)
take (Rinda::TupleSpaceProxy)
take_next_task (Skynet::MessageQueueAdapter::TupleSpace)
take_next_task (Skynet::MessageQueueAdapter)
take_next_task (Skynet::MessageQueueAdapter::Mysql)
take_result (Skynet::MessageQueueAdapter::TupleSpace)
take_result (Skynet::MessageQueueAdapter)
take_result (Skynet::Job::LocalMessageQueue)
take_result (Skynet::MessageQueueAdapter::Mysql)
take_worker_status (Skynet::MessageQueueAdapter)
task (Skynet::Message)
task_id (Skynet::Job)
task_id (Skynet::Task)
task_or_master (Skynet::Task)
tasks_to_messages (Skynet::Job)
tasktype= (Skynet::Message)
template (Skynet::WorkerVersionMessage)
template (Skynet::WorkerVersionMessage)
template_to_conditions (Skynet::MessageQueueAdapter::Mysql)
terminate (Skynet::Manager)
timeout (Skynet::Message)
to_a (Skynet::Message)
to_a (Skynet::TaskIterator)
to_h (Skynet::Job)
to_h (Skynet::Message)
to_hash (Skynet::Message)
to_s (Skynet::Message)
unknown (Skynet::Loggable)
update_message_with_result (Skynet::MessageQueueAdapter::Mysql)
use_incremental_ids (Skynet::UniqueDBNumGenerator)
use_local_queue? (Skynet::Job)
version (Skynet::WorkerVersionMessage)
version (Skynet::Job)
version (Skynet::Worker)
version= (Skynet::Job)
version_active? (Skynet::MessageQueueAdapter::TupleSpace)
version_active? (Skynet::MessageQueueAdapter::Mysql)
version_active? (Skynet::MessageQueue)
warn (SkynetDebugger)
warn (Skynet::Loggable)
warn (SkynetDebugger::ClassMethods)
worker_alive? (Skynet::Manager)
worker_notify (Skynet::Manager)
worker_pids (Skynet::Manager)
worker_shutdown (Skynet::Manager)
worker_status_template (Skynet::WorkerStatusMessage)
workers_to_start (Skynet::Manager)
write_error (Skynet::MessageQueueAdapter)
write_error (Skynet::MessageQueueAdapter::Mysql)
write_error (Skynet::MessageQueueAdapter::TupleSpace)
write_fallback_message (Skynet::MessageQueueAdapter::Mysql)
write_message (Skynet::MessageQueueAdapter)
write_message (Skynet::Job::LocalMessageQueue)
write_message (Skynet::MessageQueueAdapter::Mysql)
write_message (Skynet::MessageQueueAdapter::TupleSpace)
write_pid_file (Skynet::Manager)
write_result (Skynet::MessageQueueAdapter::Mysql)
write_result (Skynet::MessageQueueAdapter)
write_result (Skynet::MessageQueueAdapter::TupleSpace)
write_worker_status (Skynet::MessageQueueAdapter)
write_worker_status (Skynet::Worker)