@@ -1,4 +1,5 @@
1{-# LANGUAGE OverloadedStrings #-}
1{-# LANGUAGE OverloadedStrings #-}
2+{-# LANGUAGE RankNTypes #-}
2-- | Creates a scribe as a Custom Forwarder for Datadog that sends log
3-- | Creates a scribe as a Custom Forwarder for Datadog that sends log
3-- messages over TCP via their TLS endpoint.
4-- messages over TCP via their TLS endpoint.
4module Katip.Scribes.Datadog.TCP
5module Katip.Scribes.Datadog.TCP
@@ -118,12 +119,12 @@ mkDataDogScribeSettings connectionParams auth = do
118-------------------------------------------------------------------------------
119-------------------------------------------------------------------------------
119mkDataDogScribe
120mkDataDogScribe
120 :: DataDogScribeSettings
121 :: DataDogScribeSettings
121− -> Severity
122+ -> PermitFunc
122− -- ^ Severity level to observe
123+ -- ^ Function on whether to permit items, e.g. @permitItem InfoS@
123 -> Verbosity
124 -> Verbosity
124 -- ^ Verbosity level to observe
125 -- ^ Verbosity level to observe
125 -> IO Scribe
126 -> IO Scribe
126−mkDataDogScribe settings sev verb = do
127+mkDataDogScribe settings permit verb = do
127 connectionContext <- C.initConnectionContext
128 connectionContext <- C.initConnectionContext
128 pool <- Pool.createPool
129 pool <- Pool.createPool
129 (C.connectTo connectionContext (dataDogScribeSettings_connectionParams settings))
130 (C.connectTo connectionContext (dataDogScribeSettings_connectionParams settings))
@@ -134,7 +135,7 @@ mkDataDogScribe settings sev verb = do
134 pure $ Scribe
135 pure $ Scribe
135 { liPush = pushPool (dataDogScribeSettings_retry settings) pool keyBuilder verb
136 { liPush = pushPool (dataDogScribeSettings_retry settings) pool keyBuilder verb
136 , scribeFinalizer = Pool.destroyAllResources pool
137 , scribeFinalizer = Pool.destroyAllResources pool
137− , scribePermitItem = permitItem sev
138+ , scribePermitItem = permit
140 !keyBuilder = case dataDogScribeSettings_auth settings of
141 !keyBuilder = case dataDogScribeSettings_auth settings of