diff options
Diffstat (limited to 'internal/server/handlers/readcommand_server.go')
| -rw-r--r-- | internal/server/handlers/readcommand_server.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/internal/server/handlers/readcommand_server.go b/internal/server/handlers/readcommand_server.go index 6d7a095..d073682 100644 --- a/internal/server/handlers/readcommand_server.go +++ b/internal/server/handlers/readcommand_server.go @@ -55,6 +55,7 @@ type readCommandTurbo interface { type readCommandTiming interface { ReadGlobRetryInterval() time.Duration ReadRetryInterval() time.Duration + MaxLineLength() int AggregateLinesChannelBufferSize() int TurboDataTransmissionDelay() time.Duration TurboEOFWaitDuration(fileCount int) time.Duration @@ -205,6 +206,11 @@ func (h *ServerHandler) ReadRetryInterval() time.Duration { return durationFromMilliseconds(h.serverCfg.ReadRetryIntervalMs, 2*time.Second) } +// MaxLineLength returns the configured max line length for file readers. +func (h *ServerHandler) MaxLineLength() int { + return positiveIntOrDefault(h.serverCfg.MaxLineLength, 1024*1024) +} + // AggregateLinesChannelBufferSize returns the aggregate lines channel buffer size. func (h *ServerHandler) AggregateLinesChannelBufferSize() int { return positiveIntOrDefault(h.serverCfg.ReadAggregateLineBufferSize, 10000) |