Module: Smash::CloudPowers

Extended by:

Auth, Delegator

Includes:

AwsResources, Helper, Node, SelfAwareness, Storage, Synapse

Defined in:

lib/cloud_powers.rb,
lib/stubs/aws_stubs.rb,
lib/cloud_powers/auth.rb,
lib/cloud_powers/node.rb,
lib/cloud_powers/zenv.rb,
lib/cloud_powers/helper.rb,
lib/cloud_powers/context.rb,
lib/cloud_powers/storage.rb,
lib/cloud_powers/workflow.rb,
lib/cloud_powers/delegator.rb,
lib/cloud_powers/smash_error.rb,
lib/cloud_powers/aws_resources.rb,
lib/cloud_powers/self_awareness.rb,
lib/cloud_powers/synapse/synapse.rb,
lib/cloud_powers/synapse/pipe/pipe.rb,
lib/cloud_powers/synapse/queue/board.rb,
lib/cloud_powers/synapse/queue/queue.rb,
lib/cloud_powers/synapse/broadcast/broadcast.rb,
lib/cloud_powers/synapse/websocket/websocclient.rb,
lib/cloud_powers/synapse/websocket/websocserver.rb

Overview

The CloudPowers module contains all the other modules and classes that creates the CloudPowers gem.

Defined Under Namespace

Modules: Auth, AwsResources, AwsStubs, Delegator, Helper, Node, SelfAwareness, Storage, Synapse, Zenv Classes: Context, SmashError, Workflow

Method Summary

Methods included from Auth

creds, region

Methods included from Zenv

#env_vars, #file_tree_search, #i_vars, #project_root, #project_root=, #system_vars, #zfind

Methods included from Helper

#attr_map!, #available_resources, #called_from, #create_logger, #deep_modify_keys_with, #format_error_message, #log_file, #logger, #modify_keys_with, #smart_retry, #task_path, #task_require_path, #to_camel, #to_hyph, #to_i_var, #to_pascal, #to_ruby_file_name, #to_snake, #update_message_body, #valid_json?, #valid_url?

Methods included from Delegator

approved_task?, build

Methods included from Storage

#search, #send_logs_to_s3, #source_task

Methods included from AwsResources

#ec2, #image, #kinesis, #region, #s3, #sns, #sqs

Methods included from Node

#node_config, #spin_up_neurons

Methods included from SelfAwareness

#boot_time, #die!, #get_awareness!, #instance_id, #instance_url, #metadata_request, #run_time, #send_frequent_status_updates, #status, #task_name, #time_is_up?

Methods included from Synapse::Pipe

#create_stream, #flow_from_pipe, #flow_to_pipe, #from_pipe, #message_body_collection, #pipe_message_body, #pipe_to, #stream_config, #stream_exists?, #stream_status

Methods included from Synapse::Queue

#board_name, #build_queue, #create_queue!, #delete_queue_message, #get_queue_message_count, #pluck_queue_message, #poll, #queue_exists?, #queue_poller, #queue_search, #send_queue_message

Methods included from Synapse::WebSocServer

#create_websoc_server, #send

Methods included from Synapse::WebSocClient

#create_websoc_client

Methods included from Synapse::Broadcast

#create_channel!, #create_distributor, #delete_channel!, #listen_on, #real_channels, #send_broadcast