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