diff options
| author | Paul Buetow <paul@buetow.org> | 2025-06-18 09:34:06 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2025-06-18 09:34:06 +0300 |
| commit | 06de5147268508bb26702d2d08355b2b9600703e (patch) | |
| tree | 91caf91428bf972fba5dc249885c57234118725f /internal/io | |
| parent | a399c65856296f637ae6e9447928d3520b4a133d (diff) | |
Rename channelless functions to use cleaner naming
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 <noreply@anthropic.com>
Diffstat (limited to 'internal/io')
| -rw-r--r-- | internal/io/fs/directprocessor.go | 4 |
1 files changed, 2 insertions, 2 deletions
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 } |