úÎ=;9¿&      !"#$% NoneNone=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 "This is a more general version of  , where you  provide your own fold. A generalized version of  where some value is  summed and the && is sent when it reaches a 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.  9Convert your input value into an Integer, usually a size The threshold value    None'Number 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. None4Warning, 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 QCommand used to log various errors. Defaults to BS.putStrLn. It shoud not fail ! )*+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.  !,- ! !  !,-None"GThis 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"  }  } """"None$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 ./0123456789:;<=>#?Defaults parameters for the http request to ElasticSearch. Use Nothing for defaults. %Hostname of the ElasticSearch server *Port of the HTTP interface (usually 9200) 'Prefix of the index (usually logstash) Request Maximum size of each response start ?$?Defaults parameters for the http request to ElasticSearch. Use Nothing for defaults. %Hostname of the ElasticSearch server *Port of the HTTP interface (usually 9200) 'Prefix of the index (usually logstash) @AB#$$# ./0123456789:;<=>#?$@AB NoneC%%%C%D      !"#$%&'()*+, -./0123456789::;<=>>?@ABBCDEFGHIJK LMhslogstash-0.3.0Logstash.CounterData.Conduit.MiscData.Conduit.BranchingData.Conduit.Network.RetryData.Conduit.RedisLogstash.Message Logstash.IOData.Conduit.ElasticSearchData.Conduit.LogstashCounter newCounterincrementCounterConduitincrementCounter readCountercounter2collectdconcatsimpleConcatFlush concatFlushconcatFlushSum groupFlushmchunk mapFlushMaybemkBranchingConduitbranchConduitssinkSocketRetry tcpSinkRetry redisSource redisSinkLogstashMessage logstashTypelogstashSource logstashTagslogstashFieldslogstashContent logstashTimeemptyLSMessagelogstashTimestampparseLogstashTimevalue2logstashaddLogstashTimeaddLogstashTagsendSingleMessageesSearchSource esConduitlogstashListener conduit-1.0.8 Data.ConduitFlushmkSinknetwork-2.4.1.2Network.Socket.ByteStringsendAllmpsafePushpopN$fToJSONLogstashMessage$fFromJSONLogstashMessageSearchResponse _timedOut_hits_tookHits_rhits _maxScore_total SearchObject_source_index_score_id_type safeQuery$fFromJSONSearchResponse$fFromJSONHits$fFromJSONSearchObject tryDecode