mirror of
https://github.com/hasura/graphql-engine.git
synced 2024-12-25 08:24:00 +03:00
11a454c2d6
This commit applies ormolu to the whole Haskell code base by running `make format`. For in-flight branches, simply merging changes from `main` will result in merge conflicts. To avoid this, update your branch using the following instructions. Replace `<format-commit>` by the hash of *this* commit. $ git checkout my-feature-branch $ git merge <format-commit>^ # and resolve conflicts normally $ make format $ git commit -a -m "reformat with ormolu" $ git merge -s ours post-ormolu https://github.com/hasura/graphql-engine-mono/pull/2404 GitOrigin-RevId: 75049f5c12f430c615eafb4c6b8e83e371e01c8e
57 lines
2.5 KiB
Haskell
57 lines
2.5 KiB
Haskell
{-# LANGUAGE DuplicateRecordFields #-}
|
|
|
|
module Hasura.Server.TelemetrySpec (spec) where
|
|
|
|
import Data.Aeson qualified as A
|
|
import Hasura.Prelude
|
|
import Hasura.Server.Telemetry.Counters
|
|
import Test.Hspec
|
|
|
|
spec :: Spec
|
|
spec = do
|
|
telemetryCountersTests
|
|
|
|
-- NOTE: this test is effectful/stateful; if we need to we can implement an
|
|
-- operation to clear metric store.
|
|
telemetryCountersTests :: Spec
|
|
telemetryCountersTests = do
|
|
describe "request timing counters" $ do
|
|
it "is at first empty" $ do
|
|
fmap serviceTimingMetrics dumpServiceTimingMetrics `shouldReturn` []
|
|
|
|
-- excercise accumulating and buckets:
|
|
let expected =
|
|
sort
|
|
-- NOTE: since ordering is arbitrary here (and hence fragile), we sort the results before comparing
|
|
[ ServiceTimingMetric
|
|
{ dimensions = RequestDimensions Mutation Local HTTP,
|
|
bucket = RunningTimeBucket {bucketGreaterThan = 0.050},
|
|
metrics = RequestTimingsCount {telemTimeIO = 2, telemTimeTot = 1.050, telemCount = 2}
|
|
},
|
|
ServiceTimingMetric
|
|
{ dimensions = RequestDimensions Mutation Local HTTP,
|
|
bucket = RunningTimeBucket {bucketGreaterThan = 0},
|
|
metrics = RequestTimingsCount {telemTimeIO = 2, telemTimeTot = 0.001, telemCount = 2}
|
|
},
|
|
ServiceTimingMetric
|
|
{ dimensions = RequestDimensions Query Remote WebSocket,
|
|
bucket = RunningTimeBucket {bucketGreaterThan = 1.000},
|
|
metrics = RequestTimingsCount {telemTimeIO = 1, telemTimeTot = 5.000, telemCount = 1}
|
|
}
|
|
]
|
|
|
|
it "accumulates as expected" $ do
|
|
-- bucket 0sec - 1ms:
|
|
recordTimingMetric (RequestDimensions Mutation Local HTTP) (RequestTimings 1 0.0001)
|
|
recordTimingMetric (RequestDimensions Mutation Local HTTP) (RequestTimings 1 0.0009)
|
|
-- bucket 50ms - 1 sec:
|
|
recordTimingMetric (RequestDimensions Mutation Local HTTP) (RequestTimings 1 0.0510)
|
|
recordTimingMetric (RequestDimensions Mutation Local HTTP) (RequestTimings 1 0.9990)
|
|
-- bucket 1 sec - 1 hour:
|
|
recordTimingMetric (RequestDimensions Query Remote WebSocket) (RequestTimings 1 5.0000)
|
|
fmap (sort . serviceTimingMetrics) dumpServiceTimingMetrics `shouldReturn` expected
|
|
|
|
it "serializes and deserializes properly" $ do
|
|
fmap (fmap (sort . serviceTimingMetrics) . A.eitherDecode . A.encode) dumpServiceTimingMetrics
|
|
`shouldReturn` Right expected
|