summaryrefslogtreecommitdiff
path: root/internal/server/handlers/readcommand_server.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2026-03-02 10:42:33 +0200
committerPaul Buetow <paul@buetow.org>2026-03-02 10:42:33 +0200
commita426a2f9f33b1125a05d3aac29e7b98afdc36a99 (patch)
tree13d21a5aef7ec1e586e364ce5bebabb65fd77523 /internal/server/handlers/readcommand_server.go
parent3002bdcaa4ec22aa46b6c98eefda2f926dfff618 (diff)
server: use auth strategy registry and stabilize turbo EOF sync
Diffstat (limited to 'internal/server/handlers/readcommand_server.go')
-rw-r--r--internal/server/handlers/readcommand_server.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/internal/server/handlers/readcommand_server.go b/internal/server/handlers/readcommand_server.go
index 2c0a616..650dcf2 100644
--- a/internal/server/handlers/readcommand_server.go
+++ b/internal/server/handlers/readcommand_server.go
@@ -192,5 +192,6 @@ func (h *ServerHandler) turboManagerConfig() turboManagerConfig {
flushTimeout: durationFromMilliseconds(h.serverCfg.TurboFlushTimeoutMs, defaultTurboFlushTimeout),
flushPollInterval: durationFromMilliseconds(h.serverCfg.TurboFlushPollIntervalMs, defaultTurboFlushPollInterval),
readRetryInterval: durationFromMilliseconds(h.serverCfg.TurboReadRetryIntervalMs, defaultTurboReadRetryInterval),
+ eofAckQuietPeriod: durationFromMilliseconds(h.serverCfg.TurboTransmissionDelayMs, defaultTurboEOFAckQuietPeriod),
}
}