WIP

Author: mgmeier

bench/locli/app/locli-quick.hs

@@ -8,6 +8,7 @@
 import           Cardano.Api (ExceptT, SlotNo (..), runExceptT)
 
 import           Cardano.Analysis.API.Ground (JsonInputFile (..))
+import           Cardano.Analysis.Quick.Types ()
 import           Cardano.Analysis.Reducer
 import           Cardano.Analysis.Reducer.Util
 import           Cardano.Unlog.BackendDB
@@ -291,22 +292,21 @@ parserQuickQuery =
   CMDQuery
     <$> pure ()
     <*> parseRuns
-    <*> pure []
+    <*> parseHosts
     <*> switch (short 'd' <> long "dump-only" <> help "dump result blob to stdout only; don't process")
   where
-    {-
-    parseScriptName =
-          strArgument (help "name of a known script"        <> metavar "NAME")
-      <|> strArgument (help "custom serialized script file" <> metavar "FILE" <> completer (bashCompleter "file"))
-    parseParamPath =
-      strOption $ long "param" <> metavar "JSON" <> completer (bashCompleter "file")
-        <> help "protocol parameter file; default: data/protocol-parameters-v10.json"
-    parseBudgetHint =
-      option auto $ long "hint" <> metavar "BUDGET"
-        <> help "Which budget does the script target? <Mem|Steps>"
-    -}
+    parseHosts = parseNodes <|> parseAllNodes
+
+    parseAllNodes =
+      flag' [] $ long "all-nodes"
+        <> help "explicitly query all nodes; potentially expensive operation"
+
+    parseNodes =
+      option readCommaSepList $ long "nodes" <> short 'n' <> metavar "node(s)"
+        <> help "comma-separated list of node names (e.g. node-10,node20) to query"
+
     parseRuns =
-      option readCommaSepList $ long "run" <> short 'r' <> metavar "run(s)"
+      option readCommaSepList $ long "runs" <> short 'r' <> metavar "run(s)"
         <> help "comma-separated list of run dirs or log manifest JSONs, or a single SQLite DB"
 
 readCommaSepList :: Opt.ReadM [String]

bench/locli/src-quick/Cardano/Analysis/Quick/Types.hs

@@ -17,6 +17,7 @@ import           Cardano.Unlog.LogObjectDB (SummaryDB (..))
 import           Cardano.Util (I)
 
 import           Codec.Serialise (Serialise (..))
+import           Data.Map.Strict (Map)
 import           Data.Profile (ProfileEntry)
 import           Data.Text.Short (ShortText, fromShortByteString, toShortByteString)
 import           GHC.Generics (Generic)
@@ -59,7 +60,7 @@ data RemoteQueryMeta = QueryRemote
 data RemoteQueryResult
   = RemoteQueryResult
     { rqrQuery  :: ()
-    , rqrResult :: RunLogs LoadRawResult
+    , rqrResult :: Map String (RunLogs LoadRawResult)     -- map key: runId
     }
   | RemoteQueryError
     { rqrError  :: String