Safe Haskell	Safe-Inferred
Language	Haskell2010

Cardano.Analysis.MachPerf

Synopsis

data TimelineAccum = TimelineAccum {
- aResAccums :: ResAccums
- aResTimestamp :: UTCTime
- aMempoolTxs :: Word64
- aBlockNo :: BlockNo
- aLastBlockSlot :: SlotNo
- aSlotStats :: [SlotStats UTCTime]
- aRunScalars :: RunScalars
- aTxsCollectedAt :: Map TId UTCTime
- aHost :: Host
- aLogObjects :: [LogObject]
}
data SlotStatsSummary = SlotStatsSummary {
- sssSpanLensCpu :: [Int]
- sssSpanLensCpuEpoch :: [Int]
- sssSpanLensCpuRwd :: [Int]
}
collectSlotStats :: Run -> [(JsonLogfile, [LogObject])] -> IO (Either Text [(JsonLogfile, (RunScalars, [SlotStats UTCTime]))])
timelineFromLogObjects :: Run -> (JsonLogfile, [LogObject]) -> Either Text (JsonLogfile, (RunScalars, [SlotStats UTCTime]))
timelineStep :: Run -> JsonLogfile -> TimelineAccum -> LogObject -> TimelineAccum
patchSlotGap :: Genesis -> SlotNo -> TimelineAccum -> TimelineAccum
addTimelineSlot :: Genesis -> SlotNo -> UTCTime -> TimelineAccum -> TimelineAccum
lastBlockSlot :: BlockNo -> TimelineAccum -> SlotNo
runSlotFilters :: NFData a => Run -> [ChainFilter] -> [(JsonLogfile, [SlotStats a])] -> IO (DataDomain I SlotNo, [(JsonLogfile, [SlotStats a])])
deltifySlotStats :: Genesis -> SlotStats UTCTime -> SlotStats NominalDiffTime
slotStatsSummary :: forall a. Run -> [SlotStats a] -> SlotStatsSummary
slotStatsMachPerf :: Run -> (JsonLogfile, [SlotStats NominalDiffTime]) -> Either Text (JsonLogfile, MachPerfOne)
summariseClusterPerf :: [Centile] -> [MachPerfOne] -> Either CDFError ClusterPerf
summariseMultiClusterPerf :: [Centile] -> [ClusterPerf] -> Either CDFError MultiClusterPerf

Documentation

data TimelineAccum Source #

The "fold" state that accumulates as we process LogObjects into a stream of SlotStats.

Constructors

TimelineAccum
Fields aResAccums :: ResAccums aResTimestamp :: UTCTime aMempoolTxs :: Word64 aBlockNo :: BlockNo aLastBlockSlot :: SlotNo aSlotStats :: [SlotStats UTCTime] aRunScalars :: RunScalars aTxsCollectedAt :: Map TId UTCTime aHost :: Host aLogObjects :: [LogObject]

data SlotStatsSummary Source #

Constructors

SlotStatsSummary
Fields sssSpanLensCpu :: [Int] sssSpanLensCpuEpoch :: [Int] sssSpanLensCpuRwd :: [Int]

collectSlotStats :: Run -> [(JsonLogfile, [LogObject])] -> IO (Either Text [(JsonLogfile, (RunScalars, [SlotStats UTCTime]))]) Source #

timelineFromLogObjects :: Run -> (JsonLogfile, [LogObject]) -> Either Text (JsonLogfile, (RunScalars, [SlotStats UTCTime])) Source #

timelineStep :: Run -> JsonLogfile -> TimelineAccum -> LogObject -> TimelineAccum Source #

patchSlotGap :: Genesis -> SlotNo -> TimelineAccum -> TimelineAccum Source #

addTimelineSlot :: Genesis -> SlotNo -> UTCTime -> TimelineAccum -> TimelineAccum Source #

lastBlockSlot :: BlockNo -> TimelineAccum -> SlotNo Source #

runSlotFilters :: NFData a => Run -> [ChainFilter] -> [(JsonLogfile, [SlotStats a])] -> IO (DataDomain I SlotNo, [(JsonLogfile, [SlotStats a])]) Source #

deltifySlotStats :: Genesis -> SlotStats UTCTime -> SlotStats NominalDiffTime Source #

slotStatsSummary :: forall a. Run -> [SlotStats a] -> SlotStatsSummary Source #

slotStatsMachPerf :: Run -> (JsonLogfile, [SlotStats NominalDiffTime]) -> Either Text (JsonLogfile, MachPerfOne) Source #

summariseClusterPerf :: [Centile] -> [MachPerfOne] -> Either CDFError ClusterPerf Source #

summariseMultiClusterPerf :: [Centile] -> [ClusterPerf] -> Either CDFError MultiClusterPerf Source #