Method List
Search:
-
#<< RFlow::Component::PortCollection
-
#[] RFlow::Configuration::DataExtensionCollection
-
#[] RFlow::Component::HashPort
-
#[] RFlow::Configuration
-
[] RFlow::Configuration::Setting
-
#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::InputPort
-
#add_connection RFlow::Component::OutputPort
-
#add_connection RFlow::Component::HashPort
-
#all_connections RFlow::Component::HashPort
-
#all_required_options_present? RFlow::Configuration::Connection
-
available_components RFlow::Configuration
-
#available_components RFlow::Configuration
-
available_data_extensions RFlow::Configuration
-
available_data_types RFlow::Configuration
-
#brokers RFlow::Configuration::BrokeredZMQConnection
-
#brokers RFlow::Master
-
#brokers RFlow::Configuration::Connection
-
build RFlow::Component
-
build RFlow::Connection
-
build RFlow::Broker
-
#by_name RFlow::Component::PortCollection
-
#by_type RFlow::Component::PortCollection
-
#cleanup! RFlow::Component
-
#clear RFlow::Configuration::DataExtensionCollection
-
#clock_name RFlow::Components::Clock
-
#close RFlow::Logger
-
#collect_messages RFlow::Component::HashPort
-
#completed_at RFlow::Message::ProcessingEvent
-
#component RFlow::Configuration
-
#component RFlow::Component::Port
-
#component RFlow::Configuration::RubyDSL
-
#component_instance_uuid RFlow::Message::ProcessingEvent
-
#components RFlow::Configuration
-
#config RFlow::Shard
-
#config RFlow::Connection
-
#config RFlow::Components::Clock
-
configuration RFlow
-
configure RFlow::Configuration::RubyDSL
-
#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::InputPort
-
#connect! RFlow::Component::OutputPort
-
#connect! RFlow::Component::HashPort
-
#connect_components! RFlow::Shard::Worker
-
#connect_input! RFlow::Connection
-
#connect_input! RFlow::Connections::ZMQConnection
-
#connect_inputs! RFlow::Component
-
#connect_output! RFlow::Connections::ZMQConnection
-
#connect_output! RFlow::Connection
-
#connect_outputs! RFlow::Component
-
#connected RFlow::Component::Port
-
#connected? RFlow::Component::Port
-
#connection RFlow::Configuration::ZMQStreamer
-
#connections RFlow::Configuration
-
#connections RFlow::Component::HashSubPort
-
#connections_for RFlow::Component::HashPort
-
#context RFlow::Message::ProcessingEvent
-
#context_width RFlow::Logger
-
#count RFlow::Shard
-
create_zmq_context RFlow::Connections::ZMQConnection
-
#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
-
define_port RFlow::Component
-
defined_input_ports RFlow::Component
-
defined_output_ports RFlow::Component
-
#delivery RFlow::Configuration::NullConnectionConfiguration
-
#direct_connect RFlow::Component::HashSubPort
-
#direct_connect RFlow::Component::HashPort
-
#directory_path? RFlow::Configuration::Setting
-
down CreatePorts
-
down CreateShards
-
down CreateComponents
-
down CreateSettings
-
down CreateConnections
-
#each RFlow::Component::HashPort
-
#each RFlow::Component::HashSubPort
-
#each RFlow::Component::PortCollection
-
encode RFlow::Message
-
encode RFlow::Avro
-
establish_config_database_connection RFlow::Configuration
-
extended RFlow::Components::Log::Extensions::LogExtension
-
extended RFlow::Components::Raw::Extensions::RawExtension
-
extended RFlow::Components::Clock::Tick::Extension
-
from_avro RFlow::Message
-
#generate RFlow::Components::GenerateIntegerSequence
-
included RFlow::Configuration::UUIDKeyed
-
#index RFlow::Shard::Worker
-
inherited RFlow::Component
-
#initialize RFlow::MessageCollectingConnection
-
#initialize RFlow::Configuration::RubyDSL
-
#initialize RFlow::Component::PortCollection
-
#initialize RFlow::Connection
-
#initialize RFlow::ForwardToOutputPort
-
#initialize RFlow::Component::HashSubPort
-
#initialize RFlow::DaemonProcess
-
#initialize RFlow::Component
-
#initialize RFlow::Connections::ZMQConnection
-
#initialize RFlow::Component::HashPort
-
#initialize RFlow::PIDFile
-
#initialize RFlow::Message::Data
-
#initialize RFlow::Message
-
#initialize RFlow::Message::ProcessingEvent
-
#initialize RFlow::Connections::ZMQStreamer
-
#initialize RFlow::Master
-
#initialize RFlow::ForwardToInputPort
-
#initialize RFlow::Component::Port
-
#initialize RFlow::Logger
-
#initialize RFlow::Shard
-
#initialize RFlow::Shard::Worker
-
#initialize RFlow::Configuration
-
#initialize RFlow::Configuration::ZMQStreamer
-
#initialize RFlow::ChildProcess
-
#initialize RFlow::Configuration::DataExtensionCollection
-
initialize_database RFlow::Configuration
-
input_port RFlow::Component
-
#input_port_key RFlow::Connection
-
#input_port_key RFlow::Configuration::NullConnectionConfiguration
-
#input_ports RFlow::Component
-
#keys RFlow::Component::HashPort
-
#level RFlow::Components::Log::Extensions::LogExtension
-
#level= RFlow::Logger
-
#level= RFlow::Components::Log::Extensions::LogExtension
-
logger RFlow
-
master RFlow
-
#merge_default_options! RFlow::Configuration::Connection
-
merge_defaults! RFlow::Configuration
-
message_reader RFlow::Message
-
message_writer RFlow::Message
-
#messages RFlow::MessageCollectingConnection
-
#method_missing RFlow::Message::Data
-
migrate_database RFlow::Configuration
-
#name RFlow::Connection
-
#name RFlow::Configuration::NullConnectionConfiguration
-
#name RFlow::Component
-
#name RFlow::Components::Clock::Tick::Extension
-
#name RFlow::Shard
-
#name RFlow::Component::HashPort
-
#name RFlow::ChildProcess
-
#name= RFlow::Components::Clock::Tick::Extension
-
#options RFlow::Connection
-
#options RFlow::Configuration::NullConnectionConfiguration
-
output_port RFlow::Component
-
#output_port_key RFlow::Connection
-
#output_port_key RFlow::Configuration::NullConnectionConfiguration
-
#output_ports RFlow::Component
-
#pid RFlow::ChildProcess
-
#ports RFlow::Component
-
#ports RFlow::Component::PortCollection
-
#process RFlow::Configuration::RubyDSL
-
process_config_file RFlow::Configuration
-
#process_message RFlow::Component
-
#process_message RFlow::Components::RubyProcFilter
-
#process_message RFlow::Components::Replicate
-
#process_objects RFlow::Configuration::RubyDSL
-
#properties RFlow::Message
-
#provenance RFlow::Message
-
#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
-
#remove_connection RFlow::Component::HashPort
-
#reopen RFlow::Logger
-
required_options RFlow::Configuration::Connection
-
#run! RFlow::DaemonProcess
-
#run! RFlow::Component
-
#run! RFlow::Components::GenerateIntegerSequence
-
#run! RFlow::Components::Clock
-
#run! RFlow::Shard
-
run! RFlow
-
#run_child_process RFlow::ChildProcess
-
#run_components! RFlow::Shard::Worker
-
#run_process RFlow::ChildProcess
-
#run_process RFlow::Connections::ZMQStreamer
-
#run_process RFlow::Master
-
#run_process RFlow::Shard::Worker
-
#running? RFlow::PIDFile
-
#safe_unlink RFlow::PIDFile
-
#schema RFlow::Message::Data
-
schema RFlow::Message
-
#schema_string RFlow::Message::Data
-
#send_message RFlow::Component::HashPort
-
#send_message RFlow::Component::HashSubPort
-
#send_message RFlow::Component::ConnectionCollection
-
#send_message RFlow::ForwardToInputPort
-
#send_message RFlow::MessageCollectingConnection
-
#send_message RFlow::Connection
-
#send_message RFlow::ForwardToOutputPort
-
#send_message RFlow::Component::OutputPort
-
#send_message RFlow::Connections::ZMQConnection
-
#serialization_type RFlow::Message::Data
-
#setting RFlow::Configuration::RubyDSL
-
#settings RFlow::Configuration
-
#shard RFlow::Configuration
-
#shard RFlow::Configuration::RubyDSL
-
#shard RFlow::Component
-
#shard RFlow::Shard::Worker
-
#shards RFlow::Configuration
-
#shards RFlow::Master
-
#shutdown! RFlow::ChildProcess
-
#shutdown! RFlow::Component
-
#shutdown! RFlow::Shard::Worker
-
#shutdown! RFlow::DaemonProcess
-
#signal RFlow::PIDFile
-
#spawn! RFlow::ChildProcess
-
#spawn_subprocesses RFlow::Master
-
#spawn_subprocesses RFlow::DaemonProcess
-
#started_at RFlow::Message::ProcessingEvent
-
#subprocesses RFlow::Master
-
#subprocesses RFlow::DaemonProcess
-
#text RFlow::Components::Log::Extensions::LogExtension
-
#text= RFlow::Components::Log::Extensions::LogExtension
-
#thread RFlow::Configuration::RubyDSL
-
#tick RFlow::Components::Clock
-
#tick_interval RFlow::Components::Clock
-
#timestamp RFlow::Components::Clock::Tick::Extension
-
#timestamp RFlow::Components::Log::Extensions::LogExtension
-
#timestamp= RFlow::Components::Log::Extensions::LogExtension
-
#timestamp= RFlow::Components::Clock::Tick::Extension
-
#to_avro RFlow::Message::Data
-
#to_avro RFlow::Message
-
#to_hash RFlow::Message::ProcessingEvent
-
#to_s RFlow::Configuration
-
#to_s RFlow::Component
-
#to_s RFlow::PIDFile
-
#toggle_log_level RFlow::Logger
-
up CreatePorts
-
up CreateSettings
-
up CreateShards
-
up CreateConnections
-
up CreateComponents
-
#uuid RFlow::Component::HashPort
-
#uuid RFlow::Connection
-
#uuid RFlow::Component
-
#uuid RFlow::Configuration::NullConnectionConfiguration
-
#valid? RFlow::Message::Data
-
#valid_directory_path? RFlow::Configuration::Setting
-
#valid_writable_path? RFlow::Configuration::Setting
-
#worker RFlow::Component
-
#workers RFlow::Shard
-
#write RFlow::PIDFile
-
zmq_context RFlow::Connections::ZMQConnection
-
#zmq_context RFlow::Connections::ZMQConnection