Skip to content
This repository was archived by the owner on Nov 7, 2025. It is now read-only.

Commit 4c23724

Browse files
committed
Adding dual_write_proxy_v2.go a new quesma v2 http entry point
1 parent c344ae7 commit 4c23724

File tree

3 files changed

+584
-10
lines changed

3 files changed

+584
-10
lines changed

quesma/main.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,6 +160,7 @@ func constructQuesma(cfg *config.QuesmaConfiguration, sl clickhouse.TableDiscove
160160
if cfg.TransparentProxy {
161161
return quesma.NewQuesmaTcpProxy(phoneHomeAgent, cfg, quesmaManagementConsole, logChan, false)
162162
} else {
163-
return quesma.NewHttpProxy(phoneHomeAgent, lm, ip, sl, im, schemaRegistry, cfg, quesmaManagementConsole, abResultsrepository, indexRegistry)
163+
const quesma_v2 = true
164+
return quesma.NewHttpProxy(phoneHomeAgent, lm, ip, sl, im, schemaRegistry, cfg, quesmaManagementConsole, abResultsrepository, indexRegistry, quesma_v2)
164165
}
165166
}

0 commit comments

Comments
 (0)