@@ -30,7 +30,7 @@ module Katip.Scribes.ElasticSearch
3030
3131
3232-------------------------------------------------------------------------------
33−import Control.Applicative
33+import Control.Applicative as A
3434import Control.Concurrent
3535import Control.Concurrent.Async
3636import Control.Concurrent.STM.TBMQueue
@@ -193,7 +193,7 @@ chooseIxn :: IndexName -> IndexShardingPolicy -> Item a -> IndexName
193193chooseIxn (IndexName ixn) p i =
194194 IndexName (T.intercalate "-" (ixn:segs))
195195 where
196− segs = indexNameSegment <$> shardPolicySegs p i
196+ segs = indexNameSegment A.<$> shardPolicySegs p i
197197
198198
199199-------------------------------------------------------------------------------
@@ -277,18 +277,18 @@ mkEsScribe cfg@EsScribeCfg {..} server ix mapping sev verb = do
277277-------------------------------------------------------------------------------
278278baseMapping :: MappingName -> Value
279279baseMapping (MappingName mn) =
280− object [ mn .= object ["properties" .= object pairs] ]
281− where pairs = [ str "thread"
282− , str "sev"
283− , str "pid"
284− , str "ns"
285− , str "msg"
286− , "loc" .= locType
287− , str "host"
288− , str "env"
289− , "at" .= dateType
290− , str "app"
291− ]
280+ object [ mn .= object ["properties" .= object prs] ]
281+ where prs = [ str "thread"
282+ , str "sev"
283+ , str "pid"
284+ , str "ns"
285+ , str "msg"
286+ , "loc" .= locType
287+ , str "host"
288+ , str "env"
289+ , "at" .= dateType
290+ , str "app"
291+ ]
292292 str k = k .= object ["type" .= String "string"]
293293 locType = object ["properties" .= object locPairs]
294294 locPairs = [ str "loc_pkg"
@@ -305,7 +305,7 @@ baseMapping (MappingName mn) =
305305-------------------------------------------------------------------------------
306306-- | Handle both old-style aeson and picosecond-level precision
307307esDateFormat :: Text
308−esDateFormat = "yyyy-MM-dd'T'HH:mm:ss.SSSZ||yyyy-MM-dd'T'HH:mm:ss.SSSSSSSSSSSSZ"
308+esDateFormat = "yyyy-MM-dd'T'HH:mm:ssZ||yyyy-MM-dd'T'HH:mm:ss.SSSZ||yyyy-MM-dd'T'HH:mm:ss.SSSSSSSSSSSSZ"
309309
310310
311311-------------------------------------------------------------------------------
@@ -369,7 +369,8 @@ startWorker EsScribeCfg {..} env mapping q = go
369369 sendLog :: IndexName -> Value -> IO ()
370370 sendLog ixn v = void $ recovering essRetryPolicy [handler] $ const $ do
371371 did <- mkDocId
372− runBH env $ indexDocument ixn mapping defaultIndexDocumentSettings v did
372+ res <- runBH env $ indexDocument ixn mapping defaultIndexDocumentSettings v did
373+ return res
373374 eat _ = return ()
374375 handler _ = Handler $ \e ->
375376 case fromException e of