Class: LogstashRails::Transport::LogstashTcp
- Inherits:
-
LogstashRails::TransportBase
- Object
- LogstashRails::TransportBase
- LogstashRails::Transport::LogstashTcp
- Defined in:
- lib/logstash_rails/transport/logstash_tcp.rb
Instance Method Summary collapse
- #destroy ⇒ Object
-
#initialize(formatter, options) ⇒ LogstashTcp
constructor
A new instance of LogstashTcp.
- #push(json_event) ⇒ Object
Constructor Details
#initialize(formatter, options) ⇒ LogstashTcp
Returns a new instance of LogstashTcp.
5 6 7 8 9 10 |
# File 'lib/logstash_rails/transport/logstash_tcp.rb', line 5 def initialize(formatter, ) @host = [:host] || 'localhost' @port = .fetch(:port) super end |
Instance Method Details
#destroy ⇒ Object
20 21 22 23 |
# File 'lib/logstash_rails/transport/logstash_tcp.rb', line 20 def destroy super @socket.close end |
#push(json_event) ⇒ Object
12 13 14 15 16 17 18 |
# File 'lib/logstash_rails/transport/logstash_tcp.rb', line 12 def push(json_event) @socket.write(json_event) rescue Errno::EPIPE, Errno::ECONNREFUSED, NoMethodError => e log(e) connect! retry end |