Add new PubSub cfg to DSQA

At least the server address (port) needs to be exposed
This commit is contained in:
John Colvin committed 2024-06-06 09:15:17 -05:00
1 parent 9fc3c2618e
commit ca73220a2e
3 files changed
+74 -3

No files matched your search

@@ -23,7 +23,8 @@ static class Program {
async Task<int> RunAsync(DataStreamQueryAnalyzerConfig cfg) {
try {
cfg.MergeWithConfigFile();
PubSubConfig.SetGlobalConfig(PubSubConfig.Default());
cfg.MergeWith(DataStreamQueryAnalyzerConfig.Default());
PubSubConfig.SetGlobalConfig(Log.notnull(cfg.PubSub));
Configuration.initialize(cfg.Sparkd);
Log.Gen.info("Starting DataStreamQueryAnalyzer");
var service_ctx = ServiceContext.create(cfg.Sparkd);