úÎXWT´%      !"#$ None/The opaque counter type. It is actually just a % &. Gives you a new empty counter. FThis is a conduits-specific function that will increase a counter for G each piece of data that traverses this conduit. It will not alter the  data. Increments a counter. )Retrieve the current value of a counter. NThis registers a counter to a Collectd server. This can be used in this way : \ counter2collectd nbmsg "/var/run/collectd-unixsock" nodename "logstash-shipper" "messages" 'the counter to export path to the unix socket $name of the node, usually the server's fully qualified domain name name of the plugin + instance name of the counter instance '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 "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  Creates the plumbing0 that might be used to connect several conduits * together, based on a branching function. BA higher level function. Given a source, a branching function and ? a list of sinks, this will run the conduits until completion. ) 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. CA specialization of the previous Sink that opens a TCP connection. NoneEThis is a source that pops elements from a Redis list. It is capable > of poping several elements at once, and will return lists of ! ByteStrings. You might then use   or the  flushing facilities in Data.Conduit.Misc to work with individual  elements. GA Sink that will let you write ByteStrings to a redis queue. It can be H augmented with a logging function, that will be able to report errors. +,-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 oCommand used to log various errors. Defaults to BS.putStrLn. It must not fail, so be careful about exceptions. +,-None&The Logstash message, as described in  Lhttps://github.com/logstash/logstash/wiki/logstash's-internal-message-format. _Please note that it is good practice to forget about the timestamp when creating messages (set  to .F), as it should be a responsability of the Logstash server to 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 time format. 6This will try to convert an arbitrary JSON value into a LogstashMessage. 2Adds the current timestamp if it is not provided. "Adds a tag to a logstash message.  The tag to add /0   /0None!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"EA source of Logstash messages generated from an ElasticSearch query. #Takes a LogstashMessage6, and returns the result of the ElasticSearch request 9 along with the value in case of errors, or ElasticSearch's values in case of  success. 123456789:;<=>?@A"?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 B#?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) CDE"##" 123456789:;<=>?@A"B#CDE NoneFCDecodes JSON data from ByteStrings that can be encoded in UTF-8 or  latin1. $<This creates a logstash network listener, given a TCP port. E It will try to decode the Bytestring as UTF-8, and, if it fails, as  Latin1. F$ Port number $$F$G     !"#$%&'()*+, -./0123 456789:;<=.>?@ABBCDEFFGHIJJKLMNOPQRS TUhslogstash-0.3.2Logstash.CounterData.Conduit.MiscData.Conduit.BranchingData.Conduit.Network.RetryData.Conduit.RedisLogstash.Message Logstash.IOData.Conduit.ElasticSearchData.Conduit.LogstashconcatCounter newCounterincrementCounterConduitincrementCounter readCountercounter2collectdsimpleConcatFlush concatFlushconcatFlushSum groupFlushmchunk mapFlushMaybemkBranchingConduitbranchConduitssinkSocketRetry tcpSinkRetry redisSource redisSinkLogstashMessage logstashTypelogstashSource logstashTagslogstashFieldslogstashContent logstashTimeemptyLSMessagelogstashTimestampparseLogstashTimevalue2logstashaddLogstashTimeaddLogstashTagsendSingleMessageesSearchSource esConduitlogstashListenerbase GHC.Conc.SyncTVar integer-gmpGHC.Integer.TypeInteger conduit-1.0.8 Data.ConduitFlushmkSinknetwork-2.4.1.2Network.Socket.ByteStringsendAllmpsafePushpopN Data.MaybeNothing$fToJSONLogstashMessage$fFromJSONLogstashMessageSearchResponse _timedOut_hits_tookHits_rhits _maxScore_total SearchObject_source_index_score_id_type safeQuery$fFromJSONSearchResponse$fFromJSONHits$fFromJSONSearchObject tryDecode