riemann.logstash
Forwards events to LogStash.
logstash
(logstash opts)
Returns a function which accepts an event and sends it to logstash. Silently drops events when logstash is down. Attempts to reconnect automatically every five seconds. Use:
(logstash {:host “logstash.local” :port 2003})
Options:
- :pool-size The number of connections to keep open. Default 4.
- :reconnect-interval How many seconds to wait between attempts to connect. Default 5.
-
:claim-timeout How many seconds to wait for a logstash connection from the pool. Default 0.1.
-
:block-start Wait for the pool’s initial connections to open before returning.
-
:protocol Protocol to use. Either :tcp (default), :tls or :udp.
TLS options:
- :key A PKCS8-encoded private key file
- :cert The corresponding public certificate
- :ca-cert The certificate of the CA which signed this key
LogStashClient
protocol
members
close
(close client)
Cleans up (closes sockets etc.)
open
(open client)
Creates a LogStash client
send-line
(send-line client line)
Sends a formatted line to LogStash