Class: LogStash::Outputs::LogCourier
- Inherits:
-
Base
- Object
- Base
- LogStash::Outputs::LogCourier
- Defined in:
- lib/logstash/outputs/courier.rb
Overview
Send events using the Log Courier protocol
Instance Method Summary collapse
Instance Method Details
#receive(event) ⇒ Object
70 71 72 73 74 75 76 77 78 |
# File 'lib/logstash/outputs/courier.rb', line 70 def receive(event) return unless output?(event) if event == LogStash::SHUTDOWN @client.shutdown finished return end @client.publish event.to_hash end |
#register ⇒ Object
53 54 55 56 57 58 59 60 61 62 63 64 65 66 |
# File 'lib/logstash/outputs/courier.rb', line 53 def register require 'log-courier/client' @client = LogCourier::Client.new( addresses: @hosts, port: @port, ssl_ca: @ssl_ca, ssl_certificate: @ssl_certificate, ssl_key: @ssl_key, ssl_key_passphrase: @ssl_key_passphrase, spool_size: @spool_size, idle_timeout: @idle_timeout ) end |