master..63faa91 · typeable/katip

.gitignore−1

since splitsnapshots

unifiedsplit

@@ -7,4 +7,3 @@ TAGS

7*.hi

8*.dyn_o

9*.dyn_hi

10−stack.yaml.lock

.travis.yml+9−8

@@ -9,19 +9,21 @@ addons:

9 apt:

10 packages:

11 - libgmp-dev

12+ - oracle-java8-installer

12

13

13# The different configurations we want to test. You could also do things like

14# The different configurations we want to test. You could also do things like

14# change flags or use --stack-yaml to point to a different file.

15# change flags or use --stack-yaml to point to a different file.

15matrix:

16matrix:

16 include:

17 include:

17− - env: ARGS="--resolver=lts-16" ESVERSION=5.5.0 ESURL=https://artifacts.elastic.co/downloads/elasticsearch ESTESTARGS="--es-version 5" ES_JAVA_OPTS="-Xms500m -Xmx750m"

18+ - env: ARGS="--resolver=lts-10" ESVERSION=1.5.2 ESURL=https://download.elastic.co/elasticsearch/elasticsearch ESTESTARGS="--es-version 1"

19+ - env: ARGS="--resolver=lts-11" ESVERSION=1.5.2 ESURL=https://download.elastic.co/elasticsearch/elasticsearch ESTESTARGS="--es-version 1"

18− - env: ARGS="--resolver=lts-16" ESVERSION=6.2.2 ESURL=https://artifacts.elastic.co/downloads/elasticsearch ESTESTARGS="--es-version 5" ES_JAVA_OPTS="-Xms500m -Xmx750m"

20+ - env: ARGS="--resolver=lts-12" ESVERSION=1.5.2 ESURL=https://download.elastic.co/elasticsearch/elasticsearch ESTESTARGS="--es-version 1"

19− - env: ARGS="--resolver=nightly" ESVERSION=5.5.0 ESURL=https://artifacts.elastic.co/downloads/elasticsearch ESTESTARGS="--es-version 5" ES_JAVA_OPTS="-Xms500m -Xmx750m"

21+ - env: ARGS="--resolver=nightly" ESVERSION=5.5.0 ESURL=https://artifacts.elastic.co/downloads/elasticsearch ESTESTARGS="--es-version 5" ES_JAVA_OPTS="-Xms500m -Xmx750m" JAVA_HOME=/usr/lib/jvm/java-8-oracle

20− - env: ARGS="--resolver=nightly" ESVERSION=6.2.2 ESURL=https://artifacts.elastic.co/downloads/elasticsearch ESTESTARGS="--es-version 5" ES_JAVA_OPTS="-Xms500m -Xmx750m"

22+ - env: ARGS="--resolver=nightly" ESVERSION=6.2.2 ESURL=https://artifacts.elastic.co/downloads/elasticsearch ESTESTARGS="--es-version 5" ES_JAVA_OPTS="-Xms500m -Xmx750m" JAVA_HOME=/usr/lib/jvm/java-8-oracle

21− # nightlies may fail usually due to lagging dependencies

23+ # nightlies may fail from time to time

22 allow_failures:

24 allow_failures:

23− - env: ARGS="--resolver=nightly" ESVERSION=5.5.0 ESURL=https://artifacts.elastic.co/downloads/elasticsearch ESTESTARGS="--es-version 5" ES_JAVA_OPTS="-Xms500m -Xmx750m"

25+ - env: ARGS="--resolver=nightly" ESVERSION=5.5.0 ESURL=https://artifacts.elastic.co/downloads/elasticsearch ESTESTARGS="--es-version 5" ES_JAVA_OPTS="-Xms500m -Xmx750m" JAVA_HOME=/usr/lib/jvm/java-8-oracle

24− - env: ARGS="--resolver=nightly" ESVERSION=6.2.2 ESURL=https://artifacts.elastic.co/downloads/elasticsearch ESTESTARGS="--es-version 5" ES_JAVA_OPTS="-Xms500m -Xmx750m"

26+ - env: ARGS="--resolver=nightly" ESVERSION=6.2.2 ESURL=https://artifacts.elastic.co/downloads/elasticsearch ESTESTARGS="--es-version 5" ES_JAVA_OPTS="-Xms500m -Xmx750m" JAVA_HOME=/usr/lib/jvm/java-8-oracle

25

27

26before_install:

28before_install:

27# Download and unpack the stack executable

29# Download and unpack the stack executable

@@ -34,7 +36,6 @@ install:

34 - tar xzf elasticsearch-$ESVERSION.tar.gz

36 - tar xzf elasticsearch-$ESVERSION.tar.gz

35 # set up a repo for snapshot testing. Required in ES >= 1.6

37 # set up a repo for snapshot testing. Required in ES >= 1.6

36 - echo "path.repo = [\"/tmp\"]" >> ./elasticsearch-$ESVERSION/elasticsearch.yml

38 - echo "path.repo = [\"/tmp\"]" >> ./elasticsearch-$ESVERSION/elasticsearch.yml

37− - java -version

38 - ./elasticsearch-$ESVERSION/bin/elasticsearch &

39 - ./elasticsearch-$ESVERSION/bin/elasticsearch &

39 # Bloodhound seems to take a while to build and can sometimes stall out the build when travis detects no output.

40 # Bloodhound seems to take a while to build and can sometimes stall out the build when travis detects no output.

40

41

katip-datadog/changelog.md−4

@@ -1,7 +1,3 @@

1−0.2.0.0

2−==========

3−* Remove import of deprecated Network module

4−

50.1.0.0

10.1.0.0

6==========

2==========

7* Initial release

3* Initial release

katip-datadog/katip-datadog.cabal+1−1

@@ -1,5 +1,5 @@

1name: katip-datadog

2−version: 0.2.0.0

2+version: 0.1.0.0

3synopsis: Datadog scribe for the Katip logging framework

4description: See README.md for more details.

5license: BSD3

katip-datadog/src/Katip/Scribes/Datadog/TCP.hs+1−1

@@ -33,8 +33,8 @@ import qualified Data.Text.Lazy.Builder as B

33import Data.Time (NominalDiffTime)

34import Katip

35import Katip.Core (LocJs (..))

36+import qualified Network as Net

36import qualified Network.Connection as C

37import qualified Network.Connection as C

37−import qualified Network.Socket as Net

38import qualified System.Posix.Types as POSIX

39-------------------------------------------------------------------------------

40

katip-elasticsearch/bench/Main.hs+3−3

@@ -15,11 +15,11 @@ import qualified Data.HashMap.Strict as HM

15import Data.Proxy (Proxy (..))

16import System.Random

17import qualified Data.Text as T

18−import Database.Bloodhound.Types

18+import Database.V1.Bloodhound.Types

19import Numeric

20-------------------------------------------------------------------------------

21import Katip.Scribes.ElasticSearch

22−import Katip.Scribes.ElasticSearch.Internal (ESV5)

22+import Katip.Scribes.ElasticSearch.Internal (ESV1)

23-------------------------------------------------------------------------------

24

25main :: IO ()

@@ -34,7 +34,7 @@ main = do

34mkDocIdBenchmark :: Benchmark

35mkDocIdBenchmark = bgroup "mkDocId"

36 [

37− bench "mkDocId (randomIO)" $ nfIO (mkDocId (Proxy :: Proxy ESV5))

37+ bench "mkDocId (randomIO)" $ nfIO (mkDocId (Proxy :: Proxy ESV1))

38 , bench "mkDocId' (shared )" $ nfIO mkDocId'

39 ]

40

katip-elasticsearch/changelog.md−10

@@ -1,13 +1,3 @@

1−0.7.0.0

2−=======

3−* Make compatible with unreleased bloodhound 0.17

4−* Deprecate use of ES version 1 which has been removed from bloodhound

5− 0.17. All users should move over to ESV5 which should work for

6− versions 5 and up.

7−* Default configuration to ESV5

8−* Add deprecation warnings for ESV1. Support for ESV1 will be removed

9− in the future.

10−

110.6.0.0

10.6.0.0

12=======

2=======

13* Update to katip-0.8.0.0 `PermitFunc` convention. To update, for

3* Update to katip-0.8.0.0 `PermitFunc` convention. To update, for

katip-elasticsearch/docker-compose.ymldeleted−10

@@ -1,10 +0,0 @@

1−version: "3.7"

2−services:

3− # https://hub.docker.com/_/elasticsearch

4− elasticsearch:

5− image: elasticsearch:5-alpine

6− ports:

7− - target: 9200

8− published: 9200

9− protocol: tcp

10− mode: host

katip-elasticsearch/examples/example.hs+1−1

@@ -6,7 +6,7 @@ module Main

6

7-------------------------------------------------------------------------------

8import Control.Exception

9−import Database.Bloodhound

9+import Database.V5.Bloodhound

10import Network.HTTP.Client

11-------------------------------------------------------------------------------

12import Katip

katip-elasticsearch/katip-elasticsearch.cabal+4−1

@@ -1,7 +1,7 @@

1name: katip-elasticsearch

2synopsis: ElasticSearch scribe for the Katip logging framework.

3description: See README.md for more details.

4−version: 0.7.0.0

4+version: 0.6.0.0

5license: BSD3

6license-file: LICENSE

7author: Ozgun Ataman, Michael Xavier

@@ -108,4 +108,7 @@ test-suite test

108 , bytestring

109 , tagged

110

111+ if flag(lib-Werror)

112+ ghc-options: -Wall -Werror

113+

111 ghc-options: -threaded -rtsopts

114 ghc-options: -threaded -rtsopts

katip-elasticsearch/src/Katip/Scribes/ElasticSearch.hs−5

@@ -1,4 +1,3 @@

1−{-# LANGUAGE CPP #-}

2-- | Includes a scribe that can be used to log structured, JSON log

1-- | Includes a scribe that can be used to log structured, JSON log

3-- messages to ElasticSearch. These logs can be explored easily using

2-- messages to ElasticSearch. These logs can be explored easily using

4-- <https://www.elastic.co/products/kibana kibana> or your tool of

3-- <https://www.elastic.co/products/kibana kibana> or your tool of

@@ -68,16 +67,12 @@ module Katip.Scribes.ElasticSearch

68 , essIndexSettings

67 , essIndexSettings

69 , essIndexSharding

68 , essIndexSharding

70 , defaultEsScribeCfg

69 , defaultEsScribeCfg

71−#if !MIN_VERSION_bloodhound(0,17,0)

72 , defaultEsScribeCfgV1

70 , defaultEsScribeCfgV1

73−#endif

74 , defaultEsScribeCfgV5

71 , defaultEsScribeCfgV5

75 -- ** Version-Proxied APIS

72 -- ** Version-Proxied APIS

76 -- $versionproxies

73 -- $versionproxies

77 , defaultEsScribeCfg'

74 , defaultEsScribeCfg'

78−#if !MIN_VERSION_bloodhound(0,17,0)

79 , ESV1

75 , ESV1

80−#endif

81 , ESV5

76 , ESV5

82 -- * Utilities

77 -- * Utilities

83 , mkDocId

78 , mkDocId

katip-elasticsearch/src/Katip/Scribes/ElasticSearch/Internal.hs+7−18

@@ -28,7 +28,7 @@ import Control.Retry (RetryPolicy,

28import Data.Aeson

29import Data.ByteString.Lazy (ByteString)

30import Data.List.NonEmpty (NonEmpty (..))

31−import Data.Monoid as Monoid

31+import Data.Monoid ((<>))

32import Data.Text (Text)

33import qualified Data.Text as T

34import qualified Data.Text.Encoding as T

@@ -37,12 +37,8 @@ import Data.Time.Calendar.WeekDate

37import Data.Typeable as Typeable

38import Data.UUID

39import qualified Data.UUID.V4 as UUID4

40−#if MIN_VERSION_bloodhound(0,17,0)

41−import qualified Database.Bloodhound as V5

42−#else

43import qualified Database.V1.Bloodhound as V1

40import qualified Database.V1.Bloodhound as V1

44import qualified Database.V5.Bloodhound as V5

41import qualified Database.V5.Bloodhound as V5

45−#endif

46import Network.HTTP.Client

42import Network.HTTP.Client

47import Network.HTTP.Types.Status

43import Network.HTTP.Types.Status

48import Text.Printf (printf)

44import Text.Printf (printf)

@@ -99,7 +95,7 @@ data EsScribeCfg v = EsScribeCfg {

99-- * DailyIndexSharding

95-- * DailyIndexSharding

100defaultEsScribeCfg' :: ESVersion v => proxy v -> EsScribeCfg v

96defaultEsScribeCfg' :: ESVersion v => proxy v -> EsScribeCfg v

101defaultEsScribeCfg' prx = EsScribeCfg {

97defaultEsScribeCfg' prx = EsScribeCfg {

102− essRetryPolicy = exponentialBackoff 25000 Monoid.<> limitRetries 5

98+ essRetryPolicy = exponentialBackoff 25000 <> limitRetries 5

103 , essQueueSize = EsQueueSize 1000

99 , essQueueSize = EsQueueSize 1000

104 , essPoolSize = EsPoolSize 2

100 , essPoolSize = EsPoolSize 2

105 , essAnnotateTypes = False

101 , essAnnotateTypes = False

@@ -108,22 +104,19 @@ defaultEsScribeCfg' prx = EsScribeCfg {

108 }

104 }

109

105

110

106

111−

112−

113-------------------------------------------------------------------------------

107-------------------------------------------------------------------------------

114−-- | Alias of 'defaultEsScribeCfgV5' to minimize API

108+-- | Alias of 'defaultEsScribeCfgV1' to minimize API

115-- breakage. Previous versions of katip-elasticsearch only supported

109-- breakage. Previous versions of katip-elasticsearch only supported

116−-- ES version 1 and defaulted to it.

110+-- ES version 1.

117−defaultEsScribeCfg :: EsScribeCfg ESV5

111+defaultEsScribeCfg :: EsScribeCfg ESV1

118−defaultEsScribeCfg = defaultEsScribeCfgV5

112+defaultEsScribeCfg = defaultEsScribeCfgV1

119

113

120

114

121-------------------------------------------------------------------------------

115-------------------------------------------------------------------------------

122−#if !MIN_VERSION_bloodhound(0,17,0)

123-- | EsScribeCfg that will use ElasticSearch V1

116-- | EsScribeCfg that will use ElasticSearch V1

124defaultEsScribeCfgV1 :: EsScribeCfg ESV1

117defaultEsScribeCfgV1 :: EsScribeCfg ESV1

125defaultEsScribeCfgV1 = defaultEsScribeCfg' (Typeable.Proxy :: Typeable.Proxy ESV1)

118defaultEsScribeCfgV1 = defaultEsScribeCfg' (Typeable.Proxy :: Typeable.Proxy ESV1)

126−#endif

119+

127

120

128-------------------------------------------------------------------------------

121-------------------------------------------------------------------------------

129-- | EsScribeCfg that will use ElasticSearch V5

122-- | EsScribeCfg that will use ElasticSearch V5

@@ -491,10 +484,7 @@ class ESVersion v where

491

484

492

485

493

486

494−#if !MIN_VERSION_bloodhound(0,17,0)

495data ESV1 = ESV1

487data ESV1 = ESV1

496−{-# DEPRECATED ESV1 "ESV1 is deprecated and removed in bloodhound >= 0.17.0" #-}

497−

498

488

499instance ESVersion ESV1 where

489instance ESVersion ESV1 where

500 type BHEnv ESV1 = V1.BHEnv

490 type BHEnv ESV1 = V1.BHEnv

@@ -534,7 +524,6 @@ instance ESVersion ESV1 where

534 [ "type" .= String "string"

524 [ "type" .= String "string"

535 , "index" .= String "analyzed"

525 , "index" .= String "analyzed"

536 ]

526 ]

537−#endif

538

527

539

528

540data ESV5 = ESV5

529data ESV5 = ESV5

katip-elasticsearch/test/Main.hs+7−23

@@ -34,12 +34,8 @@ import Data.Time

34import Data.Time.Calendar.WeekDate

35import Data.Typeable as Typeable

36import qualified Data.Vector as V

37−#if MIN_VERSION_bloodhound(0,17,0)

38−import qualified Database.Bloodhound as V5

39−#else

40import qualified Database.V1.Bloodhound as V1

37import qualified Database.V1.Bloodhound as V1

41import qualified Database.V5.Bloodhound as V5

38import qualified Database.V5.Bloodhound as V5

42−#endif

43import Network.HTTP.Client

39import Network.HTTP.Client

44import Network.HTTP.Types.Status

40import Network.HTTP.Types.Status

45import Test.QuickCheck.Instances ()

41import Test.QuickCheck.Instances ()

@@ -58,10 +54,8 @@ main :: IO ()

58main = defaultMainWithIngredients ings $ askOption $ \vers -> testGroup "katip-elasticsearch"

54main = defaultMainWithIngredients ings $ askOption $ \vers -> testGroup "katip-elasticsearch"

59 [

55 [

60 case vers of

56 case vers of

61−#if !MIN_VERSION_bloodhound(0,17,0)

62− TestV1 -> esTests (Typeable.Proxy :: Typeable.Proxy ESV1)

57+ TestV1 -> esTests (Typeable.Proxy :: Typeable.Proxy ESV1)

63−#endif

64− TestV5 -> esTests (Typeable.Proxy :: Typeable.Proxy ESV5)

58+ TestV5 -> esTests (Typeable.Proxy :: Typeable.Proxy ESV5)

65 , typeAnnotatedTests

59 , typeAnnotatedTests

66 , roundToSundayTests

60 , roundToSundayTests

67 ]

61 ]

@@ -70,26 +64,18 @@ main = defaultMainWithIngredients ings $ askOption $ \vers -> testGroup "katip-e

70

64

71

65

72-------------------------------------------------------------------------------

66-------------------------------------------------------------------------------

73−data TestWithESVersion = TestV5

67+data TestWithESVersion = TestV1

74−#if !MIN_VERSION_bloodhound(0,17,0)

68+ | TestV5

75− | TestV1

76−#endif

77− deriving (Typeable)

69+ deriving (Typeable)

78

70

79

71

80instance IsOption TestWithESVersion where

72instance IsOption TestWithESVersion where

81− defaultValue = TestV5

73+ defaultValue = TestV1

82−#if !MIN_VERSION_bloodhound(0,17,0)

83 parseValue "1" = Just TestV1

74 parseValue "1" = Just TestV1

84−#endif

85 parseValue "5" = Just TestV5

75 parseValue "5" = Just TestV5

86 parseValue _ = Nothing

76 parseValue _ = Nothing

87 optionName = Tagged "es-version"

77 optionName = Tagged "es-version"

88−#if MIN_VERSION_bloodhound(0,17,0)

89− optionHelp = Tagged "Version of ES to test against, either 1 or 5, defaulting to 5."

78+ optionHelp = Tagged "Version of ES to test against, either 1 or 5, defaulting to 1."

90−#else

91− optionHelp = Tagged "Version of ES to test against, only v5 is supported, but should work for higher versions."

92−#endif

93

79

94

80

95class ESVersion v => TestESVersion v where

81class ESVersion v => TestESVersion v where

@@ -115,7 +101,6 @@ class ESVersion v => TestESVersion v where

115 searchByIndex :: proxy v -> IndexName v -> Search v -> BH v IO (Response ByteString)

101 searchByIndex :: proxy v -> IndexName v -> Search v -> BH v IO (Response ByteString)

116

102

117

103

118−#if !MIN_VERSION_bloodhound(0,17,0)

119instance TestESVersion ESV1 where

104instance TestESVersion ESV1 where

120 type Server ESV1 = V1.Server

105 type Server ESV1 = V1.Server

121 toServer _ = V1.Server

106 toServer _ = V1.Server

@@ -137,7 +122,6 @@ instance TestESVersion ESV1 where

137 refreshIndex _ = V1.refreshIndex

122 refreshIndex _ = V1.refreshIndex

138 withBH _ = V1.withBH

123 withBH _ = V1.withBH

139 searchByIndex _ = V1.searchByIndex

124 searchByIndex _ = V1.searchByIndex

140−#endif

141

125

142

126

143instance TestESVersion ESV5 where

127instance TestESVersion ESV5 where

katip/README.md+1−1

@@ -16,7 +16,7 @@ Kâtip (pronounced kah-tip) is the Turkish word for scribe.

16 add context that will be automatically merged in with existing log

17 context.

18

19−* *Easy Integration:* Katip was designed to be easily integrated

19+* *Easy to Integration:* Katip was designed to be easily integrated

20 into existing monads. By using typeclasses for logging facilities,

21 individual subsystems and even libraries can easily add their own

22 namespacing and context without having any knowledge of their

katip/changelog.md−17

@@ -1,20 +1,3 @@

1−0.8.5.0

2−=======

3−* Add MonadResource instances [#121](https://github.com/Soostone/katip/pull/121)

4−

5−0.8.4.0

6−=======

7−* Add support for unliftio-core 0.2 while maintaining backwards-compatible support for 0.1

8−

9−0.8.3.0

10−=======

11−

12−* Add `logKatipItem` function and reimplement `logItem` to use it. [vlatkoB](https://github.com/vlatkoB)

13−

14−0.8.2.0

15−=======

16−* Add `MonadFail` instances for `base` >= 4.9.0.0 [Koray Al](https://github.com/korayal)

17−

180.8.1.0

10.8.1.0

19=======

2=======

20* Export `logLoc`. Credit to [Brian McKenna](https://github.com/puffnfresh)

3* Export `logLoc`. Credit to [Brian McKenna](https://github.com/puffnfresh)

katip/katip.cabal+2−2

@@ -1,5 +1,5 @@

1name: katip

2−version: 0.8.5.0

2+version: 0.8.1.0

3synopsis: A structured logging framework.

4description:

5 Katip is a structured logging framework. See README.md for more details.

@@ -87,7 +87,7 @@ library

87 if flag(lib-Werror)

88 ghc-options: -Werror

89 if os(windows)

90− build-depends: Win32 >=2.3 && <2.9

90+ build-depends: Win32 >=2.3 && <2.6

91 exposed-modules: Katip.Compat

92 else

93 build-depends: unix >= 2.5 && <2.8

katip/src/Katip.hs−1

@@ -161,7 +161,6 @@ module Katip

161 , logT

162 , logLoc

163 , logItem

164− , logKatipItem

165 , logException

164 , logException

166 -- ** 'KatipContext': Logging With Context

165 -- ** 'KatipContext': Logging With Context

167 -- $katipcontextlogging

166 -- $katipcontextlogging

katip/src/Katip/Core.hs+19−36

@@ -44,8 +44,7 @@ import Control.Monad.Trans.Either

44import Control.Monad.Trans.Except

45import Control.Monad.Trans.Maybe

46import Control.Monad.Trans.Reader

47−import Control.Monad.Trans.Resource (MonadResource, ResourceT,

47+import Control.Monad.Trans.Resource (ResourceT, transResourceT)

48− transResourceT)

49import Control.Monad.Trans.RWS.Lazy (RWST, mapRWST)

48import Control.Monad.Trans.RWS.Lazy (RWST, mapRWST)

50import qualified Control.Monad.Trans.RWS.Strict as Strict (RWST, mapRWST)

49import qualified Control.Monad.Trans.RWS.Strict as Strict (RWST, mapRWST)

51import Control.Monad.Trans.State.Lazy (StateT, mapStateT)

50import Control.Monad.Trans.State.Lazy (StateT, mapStateT)

@@ -665,7 +664,7 @@ makeLenses ''LogEnv

665

664

666

665

667-------------------------------------------------------------------------------

666-------------------------------------------------------------------------------

668−-- | Create a reasonable default InitLogEnv. Uses an 'AutoUpdate' which

667+-- | Create a reasonable default InitLogEnv. Uses an 'AutoUdate' which

669-- updates the timer every 1ms. If you need even more timestamp

668-- updates the timer every 1ms. If you need even more timestamp

670-- precision at the cost of performance, consider setting

669-- precision at the cost of performance, consider setting

671-- '_logEnvTimer' with 'getCurrentTime'.

670-- '_logEnvTimer' with 'getCurrentTime'.

@@ -880,8 +879,7 @@ instance (Katip m) => Katip (ResourceT m) where

880-- opposed to implementing 'Katip' for your monad.

879-- opposed to implementing 'Katip' for your monad.

881newtype KatipT m a = KatipT { unKatipT :: ReaderT LogEnv m a }

880newtype KatipT m a = KatipT { unKatipT :: ReaderT LogEnv m a }

882 deriving ( Functor, Applicative, Monad, MonadIO

881 deriving ( Functor, Applicative, Monad, MonadIO

883− , MonadMask, MonadCatch, MonadThrow, MonadResource, MonadTrans

882+ , MonadMask, MonadCatch, MonadThrow, MonadTrans, MonadBase b)

884− , MonadBase b)

885

883

886

884

887instance MonadIO m => Katip (KatipT m) where

885instance MonadIO m => Katip (KatipT m) where

@@ -903,14 +901,9 @@ instance (MonadBaseControl b m) => MonadBaseControl b (KatipT m) where

903 restoreM = defaultRestoreM

901 restoreM = defaultRestoreM

904

902

905instance MonadUnliftIO m => MonadUnliftIO (KatipT m) where

903instance MonadUnliftIO m => MonadUnliftIO (KatipT m) where

906−#if MIN_VERSION_unliftio_core(0, 2, 0)

907− withRunInIO inner = KatipT $ ReaderT $ \le -> withRunInIO $ \run ->

908− inner (run . runKatipT le)

909−#else

910 askUnliftIO = KatipT $

904 askUnliftIO = KatipT $

911− withUnliftIO $ \u ->

905+ withUnliftIO $ \u ->

912− pure (UnliftIO (unliftIO u . unKatipT))

906+ pure (UnliftIO (unliftIO u . unKatipT))

913−#endif

914

907

915#if MIN_VERSION_base(4, 9, 0)

908#if MIN_VERSION_base(4, 9, 0)

916instance MF.MonadFail m => MF.MonadFail (KatipT m) where

909instance MF.MonadFail m => MF.MonadFail (KatipT m) where

@@ -948,29 +941,19 @@ logItem

948 -> m ()

941 -> m ()

949logItem a ns loc sev msg = do

942logItem a ns loc sev msg = do

950 LogEnv{..} <- getLogEnv

943 LogEnv{..} <- getLogEnv

951− logKatipItem =<< liftIO

944+ liftIO $ do

945+ item <- Item

952− (Item <$> pure _logEnvApp

946+ <$> pure _logEnvApp

953− <*> pure _logEnvEnv

947+ <*> pure _logEnvEnv

954− <*> pure sev

948+ <*> pure sev

955− <*> (mkThreadIdText <$> myThreadId)

949+ <*> (mkThreadIdText <$> myThreadId)

956− <*> pure _logEnvHost

950+ <*> pure _logEnvHost

957− <*> pure _logEnvPid

951+ <*> pure _logEnvPid

958− <*> pure a

952+ <*> pure a

959− <*> pure msg

953+ <*> pure msg

960− <*> _logEnvTimer

954+ <*> _logEnvTimer

961− <*> pure (_logEnvApp <> ns)

955+ <*> pure (_logEnvApp <> ns)

962− <*> pure loc)

956+ <*> pure loc

963−

964−-- | Log already constructed 'Item'. This is the lowest level function that other log*

965−-- functions use.

966−-- It can be useful when implementing centralised logging services.

967−logKatipItem

968− :: (A.Applicative m, LogItem a, Katip m)

969− => Item a

970− -> m ()

971−logKatipItem item = do

972− LogEnv{..} <- getLogEnv

973− liftIO $

974 FT.forM_ (M.elems _logEnvScribes) $ \ ScribeHandle {..} -> do

957 FT.forM_ (M.elems _logEnvScribes) $ \ ScribeHandle {..} -> do

975 whenM (scribePermitItem shScribe item) $

958 whenM (scribePermitItem shScribe item) $

976 void $ atomically (tryWriteTBQueue shChan (NewItem item))

959 void $ atomically (tryWriteTBQueue shChan (NewItem item))

@@ -1019,7 +1002,7 @@ logException

1019logException a ns sev action = action `catchAny` \e -> f e >> throwM e

1002logException a ns sev action = action `catchAny` \e -> f e >> throwM e

1020 where

1003 where

1021 f e = logF a ns sev (msg e)

1004 f e = logF a ns sev (msg e)

1022− msg e = ls (T.pack "An exception has occurred: ") <> showLS e

1005+ msg e = ls (T.pack "An exception has occured: ") <> showLS e

1023

1006

1024

1007

1025-------------------------------------------------------------------------------

1008-------------------------------------------------------------------------------

katip/src/Katip/Monadic.hs+6−20

@@ -58,8 +58,7 @@ import Control.Monad.Trans.Either (EitherT, mapEitherT)

58import Control.Monad.Trans.Except (ExceptT, mapExceptT)

59import Control.Monad.Trans.Identity (IdentityT, mapIdentityT)

60import Control.Monad.Trans.Maybe (MaybeT, mapMaybeT)

61−import Control.Monad.Trans.Resource (MonadResource,

61+import Control.Monad.Trans.Resource (ResourceT, transResourceT)

62− ResourceT, transResourceT)

63import Control.Monad.Trans.RWS (RWST, mapRWST)

62import Control.Monad.Trans.RWS (RWST, mapRWST)

64import qualified Control.Monad.Trans.RWS.Strict as Strict (RWST, mapRWST)

63import qualified Control.Monad.Trans.RWS.Strict as Strict (RWST, mapRWST)

65import qualified Control.Monad.Trans.State.Strict as Strict (StateT, mapStateT)

64import qualified Control.Monad.Trans.State.Strict as Strict (StateT, mapStateT)

@@ -316,7 +315,7 @@ logExceptionM

316logExceptionM action sev = action `catchAny` \e -> f e >> throwM e

315logExceptionM action sev = action `catchAny` \e -> f e >> throwM e

317 where

316 where

318 f e = logFM sev (msg e)

317 f e = logFM sev (msg e)

319− msg e = ls ("An exception has occurred: " :: Text) Semi.<> showLS e

318+ msg e = ls ("An exception has occured: " :: Text) Semi.<> showLS e

320

319

321

320

322-------------------------------------------------------------------------------

321-------------------------------------------------------------------------------

@@ -350,7 +349,6 @@ newtype KatipContextT m a = KatipContextT {

350 , MonadWriter w

349 , MonadWriter w

351 , MonadError e

350 , MonadError e

352 , MonadPlus

351 , MonadPlus

353− , MonadResource

354 , Alternative

352 , Alternative

355 , MonadFix

353 , MonadFix

356 , MonadTrans

354 , MonadTrans

@@ -397,15 +395,9 @@ instance (MonadIO m) => KatipContext (KatipContextT m) where

397 localKatipNamespace f (KatipContextT m) = KatipContextT $ local (\s -> s { ltsNamespace = f (ltsNamespace s)}) m

395 localKatipNamespace f (KatipContextT m) = KatipContextT $ local (\s -> s { ltsNamespace = f (ltsNamespace s)}) m

398

396

399instance MonadUnliftIO m => MonadUnliftIO (KatipContextT m) where

397instance MonadUnliftIO m => MonadUnliftIO (KatipContextT m) where

400−#if MIN_VERSION_unliftio_core(0, 2, 0)

401− withRunInIO inner = KatipContextT $ ReaderT $ \lts -> withRunInIO $ \run ->

402− inner (run . runKatipContextT (ltsLogEnv lts) (ltsContext lts) (ltsNamespace lts))

403−#else

404 askUnliftIO = KatipContextT $

398 askUnliftIO = KatipContextT $

405− withUnliftIO $ \u ->

399+ withUnliftIO $ \u ->

406− pure (UnliftIO (unliftIO u . unKatipContextT))

400+ pure (UnliftIO (unliftIO u . unKatipContextT))

407−#endif

408−

409

401

410#if MIN_VERSION_base(4, 9, 0)

402#if MIN_VERSION_base(4, 9, 0)

411instance MF.MonadFail m => MF.MonadFail (KatipContextT m) where

403instance MF.MonadFail m => MF.MonadFail (KatipContextT m) where

@@ -490,15 +482,9 @@ instance MonadBaseControl b m => MonadBaseControl b (NoLoggingT m) where

490 restoreM = NoLoggingT . restoreM

482 restoreM = NoLoggingT . restoreM

491

483

492instance MonadUnliftIO m => MonadUnliftIO (NoLoggingT m) where

484instance MonadUnliftIO m => MonadUnliftIO (NoLoggingT m) where

493−#if MIN_VERSION_unliftio_core(0, 2, 0)

494− withRunInIO inner = NoLoggingT $ withRunInIO $ \run ->

495− inner (run . runNoLoggingT)

496−#else

497 askUnliftIO = NoLoggingT $

485 askUnliftIO = NoLoggingT $

498− withUnliftIO $ \u ->

486+ withUnliftIO $ \u ->

499− pure (UnliftIO (unliftIO u . runNoLoggingT))

487+ pure (UnliftIO (unliftIO u . runNoLoggingT))

500−#endif

501−

502

488

503instance MonadIO m => Katip (NoLoggingT m) where

489instance MonadIO m => Katip (NoLoggingT m) where

504 getLogEnv = liftIO (initLogEnv "NoLoggingT" "no-logging")

490 getLogEnv = liftIO (initLogEnv "NoLoggingT" "no-logging")

stack.yaml+3−5

@@ -1,14 +1,12 @@

1−resolver: lts-16.18

1+resolver: lts-12.26

2packages:

3 - katip

4 - katip-elasticsearch

5 - katip-datadog

6 - katip-logzio

7extra-deps:

8− # ghc 8.8 support

9− - github: wireapp/bloodhound

8+ - bloodhound-0.16.0.0

10− commit: b409f52b518f20a4c20651b5893c31b7b85cb9b1

9+ - unliftio-core-0.1.2.0

11−allow-newer: true

12flags:

10flags:

13 katip:

11 katip:

14 lib-Werror: true

12 lib-Werror: true