module FFWD::Plugin::Protobuf
Constants
- DEFAULT_HOST
- DEFAULT_PORT
- DEFAULT_PROTOCOL
- INPUTS
- OUTPUTS
- VERSION
Public Class Methods
setup_input(config)
click to toggle source
# File lib/ffwd/plugin/protobuf.rb, line 120 def self.setup_input config config[:host] ||= DEFAULT_HOST config[:port] ||= DEFAULT_PORT config[:protocol] ||= DEFAULT_PROTOCOL protocol = FFWD.parse_protocol config[:protocol] unless connection = INPUTS[protocol.family] raise "No connection for protocol family: #{protocol.family}" end protocol.bind config, log, connection end
setup_output(config)
click to toggle source
# File lib/ffwd/plugin/protobuf.rb, line 106 def self.setup_output config config[:host] ||= DEFAULT_HOST config[:port] ||= DEFAULT_PORT config[:protocol] ||= DEFAULT_PROTOCOL protocol = FFWD.parse_protocol config[:protocol] unless handler = OUTPUTS[protocol.family] raise "No handler for protocol family: #{protocol.family}" end protocol.connect config, log, handler end