| Safe Haskell | None |
|---|
Data.Conduit.FireHose
Description
A firehose sink, letting client get through a port and read the sink output.
- fireHose :: MonadIO m => Int -> Int -> IO (Conduit LogstashMessage m LogstashMessage)
Documentation
Arguments
| :: MonadIO m | |
| => Int | Port |
| -> Int | Buffer size for the fire hose threads |
| -> IO (Conduit LogstashMessage m LogstashMessage) |
A web server will be launched on the specified port. The request URL must be of the form /type1,type2,type3. The client will be fed all messages matching those types.