Module: Smash::CloudPowers::Synapse

Includes:

Helper, Broadcast, Pipe, Queue

Included in:

Smash::CloudPowers

Defined in:

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

Overview

The Synapse module provides all communications functionality

• Broadcast is a module that is useful for sending 1 message to multiple recipients
• Pipe is a module that is useful for sending large result sets, data to be processed or loaded, logging info and any other high-throughput/data-centric application with
• Queue is a module that is primarily used for asynchronous communications between a sender and any number of users or apps that might need to use it

Defined Under Namespace

Modules: Broadcast, Pipe, Queue

Method Summary

Methods included from Helper

#attr_map!, #called_from, #create_logger, #errors, #format_error_message, #log_file, #logger, #smart_retry, #task_path, #task_require_path, #to_camel, #to_i_var, #to_pascal, #to_ruby_file_name, #to_snake, #update_message_body, #valid_json?

Methods included from 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 AwsResources

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

Methods included from Zenv

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

Methods included from Auth

creds, region

Methods included from Pipe

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

Methods included from Broadcast

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