úÎ/.-R     None=Converts a stream of lists into a stream of single elements. Converts a stream of [a]- into a stream of (Flush a). This is done by F sending a Flush when the input is the empty list, or that we reached  a certain threshold <Regroup a stream of (Flush a) into a stream of lists, using Flush as  the separator #Analogous to maybe, but for chunks @Like mapMaybe, but in a Flush. Will not touch the Flush values. NoneNumber of branches 0Branching function, where 0 is the first branch Returns a sink and N sources The source to branch from -The branching function (0 is the first sink) The destination sinks Results of the sinks None Tentative safe Sink for a Socket. It should try reopening the Socket every time the call to 1 fails. This means that some bytes might be sent Omultiple times, if the socket fails in the middle of the sendAll call. This is =targeted at protocols where only a full message makes sense. 5This is used to send a full JSON object to Logstash. CA specialization of the previous Sink that opens a TCP connection. None 4Warning, this outputs strings when things go wrong!  Hostname of the Redis server (Port of the Redis server (usually 6379) Name of the list "Number of elements to pop at once vTimeout of the brpop function in seconds, useful for getting Flush events into your conduit. Set to 0 for no timeout. Hostname of the Redis server (Port of the Redis server (usually 6379) Name of the list    None &The Logstash message, as described in  Lhttps://github.com/logstash/logstash/wiki/logstash's-internal-message-format. FPlease not there is no timestamp, as the logstash server will add it. AAs the name implies, this creates a dummy Logstash message, only updating the message field. 1This formats an UTCTime in what logstash expects  This parses the logstash format 6This will try to convert an arbitrary JSON value into a LogstashMessage. 2Adds the current timestamp if it is not provided.   !     !NoneGThis very simple function lets you send a single message to a Logstash >server, using the tcp input, configured in the following way:  input {  tcp {  debug => "true"  port => "12345"  data_timeout => -1 " format => "json_event" $ type => "somemessages"  }  } NoneTakes 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 "?Defaults parameters for the http request to ElasticSearch. Use Nothing for defaults. %Hostname of the ElasticSearch server *Port of the HTTP interface (usually 9200) "None##$      !"#$%&'()*+,-.hslogstash-0.2.3Data.Conduit.MiscData.Conduit.BranchingData.Conduit.Network.RetryData.Conduit.RedisLogstash.Message Logstash.IOData.Conduit.ElasticSearchData.Conduit.Logstashconcat concatFlush groupFlushmchunk mapFlushMaybemkBranchingConduitbranchConduitssinkSocketRetry tcpSinkRetry redisSource redisSinkLogstashMessage logstashTypelogstashSource logstashTagslogstashFieldslogstashContent logstashTimeemptyLSMessagelogstashTimestampparseLogstashTimevalue2logstashaddLogstashTimesendSingleMessage esConduitlogstashListenermkSinknetwork-2.4.1.0Network.Socket.ByteStringsendAllmpsafePushpopN$fToJSONLogstashMessage$fFromJSONLogstashMessage safeQuery tryDecode