| Safe Haskell | None |
|---|
Data.Conduit.ElasticSearch
Description
This module exports Conduit interfaces to ElasticSearch. It has been used intensively in production for several month now, but at a single site.
- esConduit :: MonadResource m => Maybe (Request m) -> ByteString -> Int -> Text -> Conduit [LogstashMessage] m [Either (LogstashMessage, Value) Value]
- esSearchSource :: MonadResource m => Maybe (Request m) -> ByteString -> Int -> ByteString -> Value -> Int -> Int -> Producer m (Either Value [LogstashMessage])
- esScan :: Maybe (Request (ResourceT IO)) -> ByteString -> Int -> ByteString -> Int -> Producer (ResourceT IO) (Either Value [Value])
Documentation
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 ElasticSearch request along with the value in case of errors, or ElasticSearch's values in case of success.
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]) |
A source of Logstash messages generated from an ElasticSearch query.
Arguments
| :: Maybe (Request (ResourceT IO)) | 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 | Name of the index (Something like logstash-2013.12.06) |
| -> Int | Maximum size of each response |
| -> Producer (ResourceT IO) (Either Value [Value]) |