@@ -53,19 +53,19 @@ data DatadogAuth =
5353
5454
5555data DatadogScribeSettings = DatadogScribeSettings
56− { dataDogScribeSettings_connectionParams :: C.ConnectionParams
56+ { datadogScribeSettings_connectionParams :: C.ConnectionParams
5757 -- ^ Specify where the logs should go. If writing directly to the
5858 -- main intake API, you can use 'directAPIConnectionParams'. If
5959 -- writing to a local agent, we recommend
6060 -- 'localAgentConnectionParams'
61− , dataDogScribeSettings_auth :: DatadogAuth
62− , dataDogScribeSettings_poolStripes :: Int
61+ , datadogScribeSettings_auth :: DatadogAuth
62+ , datadogScribeSettings_poolStripes :: Int
6363 -- ^ How many stripes should be used in the connection pool. 1 is a reasonable default
64− , dataDogScribeSettings_connsPerStripe :: Int
64+ , datadogScribeSettings_connsPerStripe :: Int
6565 -- ^ How many TCP connections per stripe should be maintained in the pool.
66− , dataDogScribeSettings_connectionKeepalive :: NominalDiffTime
66+ , datadogScribeSettings_connectionKeepalive :: NominalDiffTime
6767 -- ^ How long should a TCP connection be kept open. 30 (seconds) is a reasonable default. Anything around 60 will tend to time out a lot.
68− , dataDogScribeSettings_retry :: Retry.RetryPolicyM IO
68+ , datadogScribeSettings_retry :: Retry.RetryPolicyM IO
6969 -- ^ How should exceptions during write be retried?
7070 }
7171
@@ -107,12 +107,12 @@ mkDatadogScribeSettings :: C.ConnectionParams -> DatadogAuth -> IO DatadogScribe
107107mkDatadogScribeSettings connectionParams auth = do
108108 capabilities <- Conc.getNumCapabilities
109109 pure $ DatadogScribeSettings
110− { dataDogScribeSettings_connectionParams = connectionParams
111− , dataDogScribeSettings_auth = auth
112− , dataDogScribeSettings_poolStripes = 1
113− , dataDogScribeSettings_connsPerStripe = capabilities
114− , dataDogScribeSettings_connectionKeepalive = 30
115− , dataDogScribeSettings_retry = Retry.exponentialBackoff 25000 <> Retry.limitRetries 5
110+ { datadogScribeSettings_connectionParams = connectionParams
111+ , datadogScribeSettings_auth = auth
112+ , datadogScribeSettings_poolStripes = 1
113+ , datadogScribeSettings_connsPerStripe = capabilities
114+ , datadogScribeSettings_connectionKeepalive = 30
115+ , datadogScribeSettings_retry = Retry.exponentialBackoff 25000 <> Retry.limitRetries 5
116116 }
117117
118118
@@ -127,18 +127,18 @@ mkDatadogScribe
127127mkDatadogScribe settings permit verb = do
128128 connectionContext <- C.initConnectionContext
129129 pool <- Pool.createPool
130− (C.connectTo connectionContext (dataDogScribeSettings_connectionParams settings))
130+ (C.connectTo connectionContext (datadogScribeSettings_connectionParams settings))
131131 C.connectionClose
132− (dataDogScribeSettings_poolStripes settings)
133− (dataDogScribeSettings_connectionKeepalive settings)
134− (dataDogScribeSettings_connsPerStripe settings)
132+ (datadogScribeSettings_poolStripes settings)
133+ (datadogScribeSettings_connectionKeepalive settings)
134+ (datadogScribeSettings_connsPerStripe settings)
135135 pure $ Scribe
136− { liPush = pushPool (dataDogScribeSettings_retry settings) pool keyBuilder verb
136+ { liPush = pushPool (datadogScribeSettings_retry settings) pool keyBuilder verb
137137 , scribeFinalizer = Pool.destroyAllResources pool
138138 , scribePermitItem = permit
139139 }
140140 where
141− !keyBuilder = case dataDogScribeSettings_auth settings of
141+ !keyBuilder = case datadogScribeSettings_auth settings of
142142 NoAuthLocal -> Nothing
143143 DirectAuth (APIKey k) -> Just (BB.fromByteString (T.encodeUtf8 k))
144144