From 06de5147268508bb26702d2d08355b2b9600703e Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Wed, 18 Jun 2025 09:34:06 +0300 Subject: Rename channelless functions to use cleaner naming MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Now that channel-based code is completely removed, renamed all functions and references from "channelless" to more descriptive names: - startChannelless() → start() - readGlobChannelless() → readGlob() - readFilesChannelless() → readFiles() - readChannellessStdin() → readStdin() - createChannellessProcessor() → createProcessor() Updated comments and debug messages to use "direct processing" terminology. Renamed test file and functions to use "Direct" naming convention. Changed source IDs from "channelless" to "direct". All functionality preserved with improved code clarity and maintainability. 🤖 Generated with [Claude Code](https://claude.ai/code) Co-Authored-By: Claude --- internal/io/fs/directprocessor.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'internal/io') diff --git a/internal/io/fs/directprocessor.go b/internal/io/fs/directprocessor.go index 00ecedb..2b4e4df 100644 --- a/internal/io/fs/directprocessor.go +++ b/internal/io/fs/directprocessor.go @@ -21,7 +21,7 @@ import ( "github.com/mimecast/dtail/internal/regex" ) -// LineProcessor interface for channelless line-by-line processing +// LineProcessor interface for direct line-by-line processing type LineProcessor interface { ProcessLine(line []byte, lineNum int, filePath string, stats *stats, sourceID string) (result []byte, shouldSend bool) Flush() []byte // For any buffered output (e.g., MapReduce) @@ -153,7 +153,7 @@ func (dp *DirectProcessor) processReaderPreservingLineEndings(ctx context.Contex // Check if the accumulated data exceeds max line length if len(data) >= maxLineLength { if !warnedAboutLongLine { - // Note: we don't have server messages channel in channelless mode + // Note: we don't have server messages channel in direct processing mode // so we'll just split without warning warnedAboutLongLine = true } -- cgit v1.2.3