hslogstash-0.3.1: A library to work with, or as, a logstash server

Safe HaskellNone

Data.Conduit.ElasticSearch

Description

This module exports Conduit interfaces to ElasticSearch. It is totally experimental.

Synopsis

Documentation

esConduitSource

Arguments

:: MonadResource m 
=> Maybe (Request m)

Defaults parameters for the http request to ElasticSearch. Use Nothing for defaults.

-> ByteString

Hostname of the ElasticSearch server

-> Int

Port of the HTTP interface (usually 9200)

-> Text

Prefix of the index (usually logstash)

-> Conduit [LogstashMessage] m [Either (LogstashMessage, Value) Value] 

Takes a LogstashMessage, and returns the result of the ES request along with the value in case of errors, or ES's values in case of success

esSearchSourceSource

Arguments

:: MonadResource m 
=> Maybe (Request m)

Defaults parameters for the http request to ElasticSearch. Use Nothing for defaults.

-> ByteString

Hostname of the ElasticSearch server

-> Int

Port of the HTTP interface (usually 9200)

-> ByteString

Prefix of the index (usually logstash)

-> Value

Request

-> Int

Maximum size of each response

-> Int

start

-> Producer m (Either Value [LogstashMessage])