Class: FFWD::Plugin::Riemann::InputTCP

Inherits:
Connection
  • Object
show all
Includes:
EM::Protocols::ObjectProtocol, Connection, Shared
Defined in:
lib/ffwd/plugin/riemann.rb

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Connection

#initialize, #receive_object, #serializer

Methods included from Shared

#make_event, #make_message, #make_metric, #read_attributes, #read_event, #read_message, #read_tags, #read_time, #write_attributes, #write_tags, #write_time

Class Method Details

.plugin_type ⇒ Object 



90
91
92
 
# File 'lib/ffwd/plugin/riemann.rb', line 90

def self.plugin_type
  "riemann_in"
end

Instance Method Details

#send_error(e) ⇒ Object 



99
100
101
102
 
# File 'lib/ffwd/plugin/riemann.rb', line 99

def send_error(e)
  send_object(::Riemann::Message.new(
    :ok => false, :error => e.to_s))
end

#send_ok ⇒ Object 



94
95
96
97
 
# File 'lib/ffwd/plugin/riemann.rb', line 94

def send_ok
  send_object(::Riemann::Message.new(
    :ok => true))
end