Table of Contents - rflow-1.3.2 Documentation
Classes and Modules
- CreateComponents
- CreateConnections
- CreatePorts
- CreateSettings
- CreateShards
- RFlow
- RFlow::Avro
- RFlow::Broker
- RFlow::ChildProcess
- RFlow::Component
- RFlow::Component::ConnectionCollection
- RFlow::Component::HashPort
- RFlow::Component::HashSubPort
- RFlow::Component::InputPort
- RFlow::Component::OutputPort
- RFlow::Component::Port
- RFlow::Component::PortCollection
- RFlow::Components
- RFlow::Components::Clock
- RFlow::Components::Clock::Tick
- RFlow::Components::Clock::Tick::Extension
- RFlow::Components::GenerateIntegerSequence
- RFlow::Components::Log
- RFlow::Components::Log::Extensions
- RFlow::Components::Log::Extensions::LogExtension
- RFlow::Components::Raw
- RFlow::Components::Raw::Extensions
- RFlow::Components::Raw::Extensions::RawExtension
- RFlow::Components::Replicate
- RFlow::Components::RubyProcFilter
- RFlow::Configuration
- RFlow::Configuration::BrokeredZMQConnection
- RFlow::Configuration::Component
- RFlow::Configuration::ConfigurationItem
- RFlow::Configuration::Connection
- RFlow::Configuration::Connection::ConnectionInvalid
- RFlow::Configuration::DataExtensionCollection
- RFlow::Configuration::InputPort
- RFlow::Configuration::NullConnectionConfiguration
- RFlow::Configuration::OutputPort
- RFlow::Configuration::Port
- RFlow::Configuration::ProcessShard
- RFlow::Configuration::RubyDSL
- RFlow::Configuration::Setting
- RFlow::Configuration::Shard
- RFlow::Configuration::Shard::ShardInvalid
- RFlow::Configuration::ThreadShard
- RFlow::Configuration::UUIDKeyed
- RFlow::Configuration::ZMQConnection
- RFlow::Configuration::ZMQStreamer
- RFlow::Connection
- RFlow::Connections
- RFlow::Connections::BrokeredZMQConnection
- RFlow::Connections::ZMQConnection
- RFlow::Connections::ZMQStreamer
- RFlow::DaemonProcess
- RFlow::ForwardToInputPort
- RFlow::ForwardToOutputPort
- RFlow::Logger
- RFlow::Master
- RFlow::Message
- RFlow::Message::Data
- RFlow::Message::ProcessingEvent
- RFlow::MessageCollectingConnection
- RFlow::PIDFile
- RFlow::Shard
- RFlow::Shard::Worker
Methods
- ::[] — RFlow::Configuration::Setting
- ::add_available_component — RFlow::Configuration
- ::add_available_data_extension — RFlow::Configuration
- ::add_available_data_type — RFlow::Configuration
- ::available_components — RFlow::Configuration
- ::available_data_extensions — RFlow::Configuration
- ::available_data_types — RFlow::Configuration
- ::build — RFlow::Broker
- ::build — RFlow::Component
- ::build — RFlow::Connection
- ::chdir_application_directory — RFlow
- ::configure — RFlow::Configuration::RubyDSL
- ::create_zmq_context — RFlow::Connections::ZMQConnection
- ::decode — RFlow::Avro
- ::default_error_callback — RFlow
- ::default_options — RFlow::Configuration::Connection
- ::default_options — RFlow::Configuration::ZMQConnection
- ::default_options — RFlow::Configuration::BrokeredZMQConnection
- ::defer — RFlow
- ::define_port — RFlow::Component
- ::defined_input_ports — RFlow::Component
- ::defined_output_ports — RFlow::Component
- ::down — CreateSettings
- ::down — CreateShards
- ::down — CreateComponents
- ::down — CreatePorts
- ::down — CreateConnections
- ::encode — RFlow::Avro
- ::encode — RFlow::Message
- ::establish_config_database_connection — RFlow::Configuration
- ::establish_configuration — RFlow
- ::extended — RFlow::Components::Clock::Tick::Extension
- ::extended — RFlow::Components::Log::Extensions::LogExtension
- ::extended — RFlow::Components::Raw::Extensions::RawExtension
- ::from_avro — RFlow::Message
- ::included — RFlow::Configuration::UUIDKeyed
- ::inherited — RFlow::Component
- ::initialize_database — RFlow::Configuration
- ::input_port — RFlow::Component
- ::merge_defaults! — RFlow::Configuration
- ::message_reader — RFlow::Message
- ::message_writer — RFlow::Message
- ::migrate_database — RFlow::Configuration
- ::new — RFlow::ChildProcess
- ::new — RFlow::Component
- ::new — RFlow::Component::PortCollection
- ::new — RFlow::Component::Port
- ::new — RFlow::Component::HashSubPort
- ::new — RFlow::Component::HashPort
- ::new — RFlow::Configuration
- ::new — RFlow::Configuration::DataExtensionCollection
- ::new — RFlow::Configuration::ZMQStreamer
- ::new — RFlow::Configuration::RubyDSL
- ::new — RFlow::Connection
- ::new — RFlow::MessageCollectingConnection
- ::new — RFlow::ForwardToOutputPort
- ::new — RFlow::ForwardToInputPort
- ::new — RFlow::Connections::ZMQConnection
- ::new — RFlow::Connections::ZMQStreamer
- ::new — RFlow::DaemonProcess
- ::new — RFlow::Logger
- ::new — RFlow::Master
- ::new — RFlow::Message
- ::new — RFlow::Message::ProcessingEvent
- ::new — RFlow::Message::Data
- ::new — RFlow::PIDFile
- ::new — RFlow::Shard
- ::new — RFlow::Shard::Worker
- ::next_tick — RFlow
- ::next_tick_and_wait — RFlow
- ::output_port — RFlow::Component
- ::process_config_file — RFlow::Configuration
- ::required_options — RFlow::Configuration::Connection
- ::run! — RFlow
- ::schema — RFlow::Message
- ::setup_logger — RFlow
- ::start_master_node — RFlow
- ::up — CreateSettings
- ::up — CreateShards
- ::up — CreateComponents
- ::up — CreatePorts
- ::up — CreateConnections
- #<< — RFlow::Component::PortCollection
- #[] — RFlow::Component::HashPort
- #[] — RFlow::Configuration
- #[] — RFlow::Configuration::DataExtensionCollection
- #add — RFlow::Configuration::DataExtensionCollection
- #add_connection — RFlow::Component::HashPort
- #add_connection — RFlow::Component::InputPort
- #add_connection — RFlow::Component::OutputPort
- #add_logging_context — RFlow::Logger
- #all_connections — RFlow::Component::HashPort
- #all_required_options_present? — RFlow::Configuration::Connection
- #apply_logging_context — RFlow::Logger
- #available_components — RFlow::Configuration
- #brokers — RFlow::Configuration::Connection
- #brokers — RFlow::Configuration::BrokeredZMQConnection
- #check_address — RFlow::Connections::ZMQConnection
- #cleanup! — RFlow::Component
- #clear — RFlow::Configuration::DataExtensionCollection
- #clear_logging_context — RFlow::Logger
- #clock_name — RFlow::Components::Clock
- #clone_logging_context — RFlow::Logger
- #close — RFlow::Logger
- #close_stdio_streams — RFlow::DaemonProcess
- #collect_messages — RFlow::Component::HashPort
- #component — RFlow::Configuration
- #component — RFlow::Configuration::RubyDSL
- #components — RFlow::Configuration
- #configure! — RFlow::Component
- #configure! — RFlow::Components::Clock
- #configure! — RFlow::Components::GenerateIntegerSequence
- #configure! — RFlow::Components::RubyProcFilter
- #configure_components! — RFlow::Shard::Worker
- #configure_input_port! — RFlow::Component
- #configure_output_port! — RFlow::Component
- #connect — RFlow::Configuration::RubyDSL
- #connect! — RFlow::Component::HashPort
- #connect! — RFlow::Component::InputPort
- #connect! — RFlow::Component::OutputPort
- #connect_components! — RFlow::Shard::Worker
- #connect_input! — RFlow::Connection
- #connect_input! — RFlow::Connections::ZMQConnection
- #connect_inputs! — RFlow::Component
- #connect_output! — RFlow::Connection
- #connect_output! — RFlow::Connections::ZMQConnection
- #connect_outputs! — RFlow::Component
- #connected? — RFlow::Component::Port
- #connections — RFlow::Component::HashSubPort
- #connections — RFlow::Configuration
- #connections_for — RFlow::Component::HashPort
- #current_process? — RFlow::PIDFile
- #daemonize! — RFlow::DaemonProcess
- #daemonize_process — RFlow::DaemonProcess
- #detach_process_group — RFlow::ChildProcess
- #direct_connect — RFlow::Component::HashSubPort
- #direct_connect — RFlow::Component::HashPort
- #directory_path? — RFlow::Configuration::Setting
- #drop_database_connections — RFlow::ChildProcess
- #drop_database_connections — RFlow::DaemonProcess
- #dump_threads — RFlow::Logger
- #each — RFlow::Component::PortCollection
- #each — RFlow::Component::HashSubPort
- #each — RFlow::Component::HashPort
- #establish_child_pipe — RFlow::ChildProcess
- #establish_daemon_pipe — RFlow::DaemonProcess
- #establish_internal_logger — RFlow::Logger
- #exist? — RFlow::PIDFile
- #exit_after_daemon_starts — RFlow::DaemonProcess
- #generate — RFlow::Components::GenerateIntegerSequence
- #generate_uuid — RFlow::Configuration::UUIDKeyed
- #get_config_line — RFlow::Configuration::RubyDSL
- #handle_signals — RFlow::ChildProcess
- #handle_signals — RFlow::DaemonProcess
- #hook_up_logfile — RFlow::Logger
- #hook_up_stdout — RFlow::Logger
- #input_port_key — RFlow::Connection
- #input_ports — RFlow::Component
- #keys — RFlow::Component::HashPort
- #level — RFlow::Components::Log::Extensions::LogExtension
- #level= — RFlow::Logger
- #level= — RFlow::Components::Log::Extensions::LogExtension
- #merge_default_options! — RFlow::Configuration::Connection
- #method_missing — RFlow::Message::Data
- #name — RFlow::Components::Clock::Tick::Extension
- #name= — RFlow::Components::Clock::Tick::Extension
- #output_port_key — RFlow::Connection
- #output_ports — RFlow::Component
- #parse_connection_string — RFlow::Configuration::RubyDSL
- #process — RFlow::Configuration::RubyDSL
- #process_connection_specs — RFlow::Configuration::RubyDSL
- #process_message — RFlow::Component
- #process_message — RFlow::Components::Replicate
- #process_message — RFlow::Components::RubyProcFilter
- #process_objects — RFlow::Configuration::RubyDSL
- #process_setting_specs — RFlow::Configuration::RubyDSL
- #process_shard_specs — RFlow::Configuration::RubyDSL
- #raw — RFlow::Components::Raw::Extensions::RawExtension
- #raw= — RFlow::Components::Raw::Extensions::RawExtension
- #read — RFlow::PIDFile
- #reconfigure — RFlow::Logger
- #recv_callback — RFlow::Connection
- #recv_callback= — RFlow::Component::InputPort
- #register_logging_context — RFlow::ChildProcess
- #register_logging_context — RFlow::DaemonProcess
- #register_logging_context — RFlow::Logger
- #remove_connection — RFlow::Component::HashPort
- #remove_pid_file — RFlow::DaemonProcess
- #reopen — RFlow::Logger
- #return_after_child_starts — RFlow::ChildProcess
- #run! — RFlow::Component
- #run! — RFlow::Components::Clock
- #run! — RFlow::Components::GenerateIntegerSequence
- #run! — RFlow::DaemonProcess
- #run! — RFlow::Shard
- #run_child_process — RFlow::ChildProcess
- #run_components! — RFlow::Shard::Worker
- #run_process — RFlow::ChildProcess
- #run_process — RFlow::Connections::ZMQStreamer
- #run_process — RFlow::DaemonProcess
- #run_process — RFlow::Master
- #run_process — RFlow::Shard::Worker
- #running? — RFlow::PIDFile
- #safe_unlink — RFlow::PIDFile
- #send_message — RFlow::Component::HashSubPort
- #send_message — RFlow::Component::HashPort
- #send_message — RFlow::Component::OutputPort
- #send_message — RFlow::Connection
- #send_message — RFlow::MessageCollectingConnection
- #send_message — RFlow::ForwardToOutputPort
- #send_message — RFlow::ForwardToInputPort
- #send_message — RFlow::Connections::ZMQConnection
- #send_message — RFlow::Component::ConnectionCollection
- #setting — RFlow::Configuration::RubyDSL
- #settings — RFlow::Configuration
- #shard — RFlow::Component
- #shard — RFlow::Configuration
- #shard — RFlow::Configuration::RubyDSL
- #shards — RFlow::Configuration
- #shutdown! — RFlow::ChildProcess
- #shutdown! — RFlow::Component
- #shutdown! — RFlow::DaemonProcess
- #shutdown! — RFlow::Shard::Worker
- #signal — RFlow::PIDFile
- #signal_subprocesses — RFlow::DaemonProcess
- #signal_successful_start — RFlow::DaemonProcess
- #spawn! — RFlow::ChildProcess
- #spawn_subprocesses — RFlow::DaemonProcess
- #spawn_subprocesses — RFlow::Master
- #subprocesses — RFlow::DaemonProcess
- #subprocesses — RFlow::Master
- #text — RFlow::Components::Log::Extensions::LogExtension
- #text= — RFlow::Components::Log::Extensions::LogExtension
- #thread — RFlow::Configuration::RubyDSL
- #tick — RFlow::Components::Clock
- #timestamp — RFlow::Components::Clock::Tick::Extension
- #timestamp — RFlow::Components::Log::Extensions::LogExtension
- #timestamp= — RFlow::Components::Clock::Tick::Extension
- #timestamp= — RFlow::Components::Log::Extensions::LogExtension
- #to_avro — RFlow::Message
- #to_avro — RFlow::Message::Data
- #to_hash — RFlow::Message::ProcessingEvent
- #to_s — RFlow::Component
- #to_s — RFlow::Configuration
- #to_s — RFlow::PIDFile
- #toggle_log_level — RFlow::Logger
- #trap_signal — RFlow::ChildProcess
- #trap_signal — RFlow::DaemonProcess
- #unhandle_signals — RFlow::ChildProcess
- #unhandle_signals — RFlow::DaemonProcess
- #unlink — RFlow::PIDFile
- #update_process_name — RFlow::ChildProcess
- #update_process_name — RFlow::DaemonProcess
- #valid? — RFlow::Message::Data
- #valid_directory_path? — RFlow::Configuration::Setting
- #valid_writable_path? — RFlow::Configuration::Setting
- #validate? — RFlow::PIDFile
- #validate_options! — RFlow::Connections::ZMQConnection
- #write — RFlow::PIDFile
- #write_pid_file — RFlow::DaemonProcess
- #zmq_context — RFlow::Connections::ZMQConnection