From 077bdbfe10e1f955e2a869516fde55be1bff371b Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Wed, 18 Jun 2025 21:10:57 +0300 Subject: Complete file splitting and add remaining processor files MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - Add split processor files: aggregateprocessor.go, catprocessor.go, grepprocessor.go, mapprocessor.go, tailprocessor.go - Update directprocessor.go with core functionality only - Fix server channel buffer sizes in healthhandler.go and serverhandler.go - Update CLAUDE.md with integration testing guidelines 🤖 Generated with [Claude Code](https://claude.ai/code) Co-Authored-By: Claude --- internal/server/handlers/healthhandler.go | 2 +- internal/server/handlers/serverhandler.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) (limited to 'internal/server/handlers') diff --git a/internal/server/handlers/healthhandler.go b/internal/server/handlers/healthhandler.go index 362fe24..6214084 100644 --- a/internal/server/handlers/healthhandler.go +++ b/internal/server/handlers/healthhandler.go @@ -23,7 +23,7 @@ func NewHealthHandler(user *user.User) *HealthHandler { h := HealthHandler{ baseHandler: baseHandler{ done: internal.NewDone(), - lines: make(chan *line.Line, 100), + lines: make(chan *line.Line, 1000), serverMessages: make(chan string, 10), maprMessages: make(chan string, 10), ackCloseReceived: make(chan struct{}), diff --git a/internal/server/handlers/serverhandler.go b/internal/server/handlers/serverhandler.go index 0cd6409..5ef8a1d 100644 --- a/internal/server/handlers/serverhandler.go +++ b/internal/server/handlers/serverhandler.go @@ -31,7 +31,7 @@ func NewServerHandler(user *user.User, catLimiter, h := ServerHandler{ baseHandler: baseHandler{ done: internal.NewDone(), - lines: make(chan *line.Line, 100), + lines: make(chan *line.Line, 1000), serverMessages: make(chan string, 10), maprMessages: make(chan string, 10), ackCloseReceived: make(chan struct{}), -- cgit v1.2.3