Safe Haskell | None |
---|
Receive logstash messages from the network, and process them with a conduit.
- logstashListener :: Int -> Sink (Either ByteString LogstashMessage) (ResourceT IO) () -> IO ()
Documentation
:: Int | Port number |
-> Sink (Either ByteString LogstashMessage) (ResourceT IO) () | |
-> IO () |
This creates a logstash network listener, given a TCP port. It will try to decode the Bytestring as UTF-8, and, if it fails, as Latin1.