Method List
Search:
-
#<< RFlow::Component::PortCollection
-
#[] RFlow::Configuration::DataExtensionCollection
-
[] RFlow::Configuration::Setting
-
#[] RFlow::Configuration
-
#[] RFlow::Component::HashPort
-
#add RFlow::Configuration::DataExtensionCollection
-
add_available_component RFlow::Configuration
-
add_available_data_extension RFlow::Configuration
-
add_available_data_type RFlow::Configuration
-
#add_connection RFlow::Component::OutputPort
-
#add_connection RFlow::Component::HashPort
-
#add_connection RFlow::Component::InputPort
-
#add_logging_context RFlow::Logger
-
#all_connections RFlow::Component::HashPort
-
#apply_logging_context RFlow::Logger
-
available_components RFlow::Configuration
-
#available_components RFlow::Configuration
-
available_data_extensions RFlow::Configuration
-
available_data_types RFlow::Configuration
-
#brokers RFlow::Configuration::Connection
-
#brokers RFlow::Configuration::BrokeredZMQConnection
-
#brokers RFlow::Master
-
build RFlow::Connection
-
build RFlow::Broker
-
build RFlow::Component
-
#by_name RFlow::Component::PortCollection
-
#by_type RFlow::Component::PortCollection
-
#cleanup! RFlow::Component
-
#clear RFlow::Configuration::DataExtensionCollection
-
#clear_logging_context RFlow::Logger
-
#clone_logging_context RFlow::Logger
-
#close RFlow::Logger
-
#collect_messages RFlow::Component::HashPort
-
#completed_at RFlow::Message::ProcessingEvent
-
#component RFlow::Component::Port
-
#component RFlow::Configuration
-
#component RFlow::Configuration::Port
-
#component_instance_uuid RFlow::Message::ProcessingEvent
-
#components RFlow::Configuration
-
#components RFlow::Configuration::Shard
-
#config RFlow::Connection
-
#config RFlow::Shard
-
configuration RFlow
-
#configure! RFlow::Component
-
#configure! RFlow::Components::GenerateIntegerSequence
-
#configure! RFlow::Components::RubyProcFilter
-
#configure! RFlow::Components::Clock
-
#connect! RFlow::Component::OutputPort
-
#connect! RFlow::Component::HashPort
-
#connect! RFlow::Component::InputPort
-
#connect_input! RFlow::Connections::ZMQConnection
-
#connect_input! RFlow::Connection
-
#connect_output! RFlow::Connection
-
#connect_output! RFlow::Connections::ZMQConnection
-
#connected RFlow::Component::Port
-
#connected? RFlow::Component::Port
-
#connection RFlow::Configuration::ZMQStreamer
-
#connections RFlow::Configuration::InputPort
-
#connections RFlow::Configuration::OutputPort
-
#connections RFlow::Component::HashSubPort
-
#connections RFlow::Configuration
-
#connections_for RFlow::Component::HashPort
-
#context RFlow::Message::ProcessingEvent
-
#context_width RFlow::Logger
-
#count RFlow::Shard
-
#daemonize! RFlow::DaemonProcess
-
#data RFlow::Message
-
#data_object RFlow::Message::Data
-
#data_type_name RFlow::Message
-
decode RFlow::Avro
-
default_options RFlow::Configuration::BrokeredZMQConnection
-
default_options RFlow::Configuration::ZMQConnection
-
default_options RFlow::Configuration::Connection
-
#direct_connect RFlow::Component::HashPort
-
#direct_connect RFlow::Component::HashSubPort
-
#dropped RFlow::Components::RubyProcFilter
-
#dump_threads RFlow::Logger
-
#each RFlow::Component::HashPort
-
#each RFlow::Component::PortCollection
-
#each RFlow::Component::HashSubPort
-
encode RFlow::Avro
-
#errored RFlow::Components::Replicate
-
#errored RFlow::Components::RubyProcFilter
-
establish_config_database_connection RFlow::Configuration
-
#even_odd_out RFlow::Components::GenerateIntegerSequence
-
#filtered RFlow::Components::RubyProcFilter
-
#in RFlow::Components::RubyProcFilter
-
#in RFlow::Components::Replicate
-
#index RFlow::Shard::Worker
-
#initialize RFlow::Connections::ZMQStreamer
-
#initialize RFlow::PIDFile
-
#initialize RFlow::Message::Data
-
#initialize RFlow::Message::ProcessingEvent
-
#initialize RFlow::Master
-
#initialize RFlow::DaemonProcess
-
#initialize RFlow::Connection
-
#initialize RFlow::Component::HashPort
-
#initialize RFlow::Component::Port
-
#initialize RFlow::Configuration
-
#initialize RFlow::Component
-
#initialize RFlow::ChildProcess
-
#initialize RFlow::ForwardToOutputPort
-
#initialize RFlow::MessageCollectingConnection
-
#initialize RFlow::ForwardToInputPort
-
#initialize RFlow::Configuration::DataExtensionCollection
-
#initialize RFlow::Component::HashSubPort
-
#initialize RFlow::Connections::ZMQConnection
-
#initialize RFlow::Component::PortCollection
-
#initialize RFlow::Message
-
#initialize RFlow::Logger
-
#initialize RFlow::Shard
-
#initialize RFlow::Shard::Worker
-
#initialize RFlow::Configuration::ZMQStreamer
-
initialize_database RFlow::Configuration
-
#input_connections RFlow::Configuration::InputPort
-
#input_port RFlow::Configuration::Connection
-
input_port RFlow::Component
-
#input_port_key RFlow::Connection
-
#input_ports RFlow::Component
-
#input_ports RFlow::Configuration::Component
-
#keys RFlow::Component::HashPort
-
#level RFlow::Message::Data::Log
-
#level= RFlow::Logger
-
logger RFlow
-
master RFlow
-
merge_defaults! RFlow::Configuration
-
#messages RFlow::MessageCollectingConnection
-
#method_missing RFlow::Message::Data
-
migrate_database RFlow::Configuration
-
#name RFlow::ChildProcess
-
#name RFlow::Connection
-
#name RFlow::Component::HashPort
-
#name RFlow::Component
-
#name RFlow::Shard
-
#name RFlow::Message::Clock::Tick
-
#options RFlow::Connection
-
#options RFlow::Configuration::Connection
-
#options RFlow::Configuration::Component
-
#out RFlow::Components::GenerateIntegerSequence
-
#out RFlow::Components::Replicate
-
#output_connections RFlow::Configuration::OutputPort
-
output_port RFlow::Component
-
#output_port RFlow::Configuration::Connection
-
#output_port_key RFlow::Connection
-
#output_ports RFlow::Configuration::Component
-
#output_ports RFlow::Component
-
#pid RFlow::ChildProcess
-
#ports RFlow::Component
-
#ports RFlow::Component::PortCollection
-
process_config_file RFlow::Configuration
-
#process_message RFlow::Component
-
#process_message RFlow::Components::RubyProcFilter
-
#process_message RFlow::Components::Replicate
-
#properties RFlow::Message
-
#provenance RFlow::Message
-
#raw RFlow::Message::Data::Raw
-
#read RFlow::PIDFile
-
#reconfigure RFlow::Logger
-
#recv_callback RFlow::Connection
-
#recv_callback= RFlow::Component::InputPort
-
#remove_connection RFlow::Component::HashPort
-
#reopen RFlow::Logger
-
required_options RFlow::Configuration::Connection
-
#run! RFlow::Component
-
#run! RFlow::Components::GenerateIntegerSequence
-
#run! RFlow::Shard
-
run! RFlow
-
#run! RFlow::Components::Clock
-
#run! RFlow::DaemonProcess
-
#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
-
#schema RFlow::Message::Data
-
#schema_string RFlow::Message::Data
-
#send_message RFlow::Component::OutputPort
-
#send_message RFlow::Component::HashPort
-
#send_message RFlow::Component::HashSubPort
-
#send_message RFlow::Connections::ZMQConnection
-
#send_message RFlow::ForwardToInputPort
-
#send_message RFlow::ForwardToOutputPort
-
#send_message RFlow::MessageCollectingConnection
-
#send_message RFlow::Connection
-
#serialization_type RFlow::Message::Data
-
#settings RFlow::Configuration
-
#shard RFlow::Configuration
-
#shard RFlow::Component
-
#shard RFlow::Configuration::Component
-
#shard RFlow::Shard::Worker
-
#shards RFlow::Configuration
-
#shards RFlow::Master
-
#shutdown! RFlow::DaemonProcess
-
#shutdown! RFlow::ChildProcess
-
#shutdown! RFlow::Component
-
#shutdown! RFlow::Shard::Worker
-
#signal RFlow::PIDFile
-
#spawn! RFlow::ChildProcess
-
#spawn_subprocesses RFlow::DaemonProcess
-
#spawn_subprocesses RFlow::Master
-
#started_at RFlow::Message::ProcessingEvent
-
#subprocesses RFlow::DaemonProcess
-
#subprocesses RFlow::Master
-
#text RFlow::Message::Data::Log
-
#tick_port RFlow::Components::Clock
-
#timestamp RFlow::Message::Data::Log
-
#timestamp RFlow::Message::Clock::Tick
-
#to_avro RFlow::Message::Data
-
#to_avro RFlow::Message
-
#to_hash RFlow::Message::ProcessingEvent
-
#to_s RFlow::Configuration
-
#to_s RFlow::Component
-
#toggle_log_level RFlow::Logger
-
#uuid RFlow::Component::HashPort
-
#uuid RFlow::Connection
-
#uuid RFlow::Component
-
#valid? RFlow::Message::Data
-
#worker RFlow::Component
-
#workers RFlow::Shard
-
#write RFlow::PIDFile
-
zmq_context RFlow::Connections::ZMQConnection
-
#zmq_context RFlow::Connections::ZMQConnection