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) or :udp.

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