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