style: gofmt -s formatting

Author: Patel230

chunker.go

@@ -30,10 +30,10 @@ const (
 type ChunkOptions struct {
 	MaxTokens     int
 	MinTokens     int
-	MinChunkSize  int            // hard minimum; chunks below this get heavy DP penalty (default: DefaultMinChunkSize)
+	MinChunkSize  int // hard minimum; chunks below this get heavy DP penalty (default: DefaultMinChunkSize)
 	Language      string
-	Overlap       int            // number of tokens worth of content to repeat from previous chunk
-	KeepSeparator SeparatorKeep  // controls boundary line placement (default: SepLeft)
+	Overlap       int           // number of tokens worth of content to repeat from previous chunk
+	KeepSeparator SeparatorKeep // controls boundary line placement (default: SepLeft)
 }
 
 // DefaultMinChunkSize is the default minimum chunk size in tokens.
@@ -96,12 +96,12 @@ func GetLanguagePatterns(lang string) []string {
 // ---- Feature 1: Six-Level Separator Hierarchy ----
 
 var separatorLevels = []string{
-	"\n\n",                             // Level 1: paragraph breaks
-	"\n",                               // Level 2: line breaks
+	"\n\n",                          // Level 1: paragraph breaks
+	"\n",                            // Level 2: line breaks
 	". ", "? ", "! ", "。", "？", "！", // Level 3: sentence endings (incl CJK)
-	"; ", ": ", "— ", "；", "：",       // Level 4: clause breaks
-	", ", "，",                          // Level 5: comma breaks
-	" ",                                // Level 6: word breaks
+	"; ", ": ", "— ", "；", "：", // Level 4: clause breaks
+	", ", "，", // Level 5: comma breaks
+	" ", // Level 6: word breaks
 }
 
 // separatorsByLevel groups separators into their hierarchical levels.

internal/filter/compaction.go

@@ -26,7 +26,7 @@ type summaryResponse struct {
 	Tokens  int
 }
 
-func newSummarizer() *summarizer { return &summarizer{} }
+func newSummarizer() *summarizer        { return &summarizer{} }
 func (s *summarizer) IsAvailable() bool { return false }
 func (s *summarizer) SummarizeWithRequest(req summaryRequest) (summaryResponse, error) {
 	return summaryResponse{Summary: req.Content, Tokens: len(req.Content) / 4}, nil

internal/filter/pipeline_process.go

@@ -72,23 +72,23 @@ func (p *PipelineCoordinator) runGuardrailFallback(input string) (string, *Pipel
 		Mode:                   ModeMinimal,
 		EnableQualityGuardrail: false, // prevent infinite recursion
 		QueryIntent:            p.config.QueryIntent,
-		Budget:              p.config.Budget,
-		LLMEnabled:          p.config.LLMEnabled,
-		SessionTracking:     p.config.SessionTracking,
-		NgramEnabled:        p.config.NgramEnabled,
-		MultiFileEnabled:    p.config.MultiFileEnabled,
-		EnableEntropy:       p.config.EnableEntropy,
-		EnablePerplexity:    p.config.EnablePerplexity,
-		EnableAST:           p.config.EnableAST,
-		EnableGist:          p.config.EnableGist,
-		EnableHierarchical:  p.config.EnableHierarchical,
-		EnableCompaction:    p.config.EnableCompaction,
-		EnableAttribution:   p.config.EnableAttribution,
-		EnableH2O:           p.config.EnableH2O,
-		EnableAttentionSink: p.config.EnableAttentionSink,
-		EnableTOMLFilter:    p.config.EnableTOMLFilter,
-		CacheEnabled:        p.config.CacheEnabled,
-		CacheMaxSize:        p.config.CacheMaxSize,
+		Budget:                 p.config.Budget,
+		LLMEnabled:             p.config.LLMEnabled,
+		SessionTracking:        p.config.SessionTracking,
+		NgramEnabled:           p.config.NgramEnabled,
+		MultiFileEnabled:       p.config.MultiFileEnabled,
+		EnableEntropy:          p.config.EnableEntropy,
+		EnablePerplexity:       p.config.EnablePerplexity,
+		EnableAST:              p.config.EnableAST,
+		EnableGist:             p.config.EnableGist,
+		EnableHierarchical:     p.config.EnableHierarchical,
+		EnableCompaction:       p.config.EnableCompaction,
+		EnableAttribution:      p.config.EnableAttribution,
+		EnableH2O:              p.config.EnableH2O,
+		EnableAttentionSink:    p.config.EnableAttentionSink,
+		EnableTOMLFilter:       p.config.EnableTOMLFilter,
+		CacheEnabled:           p.config.CacheEnabled,
+		CacheMaxSize:           p.config.CacheMaxSize,
 	}
 	fallback := NewPipelineCoordinator(fallbackCfg)
 	return fallback.Process(input)

stream.go

@@ -12,13 +12,13 @@ import (
 // snapshot is always available without blocking.
 type StreamCompressor struct {
 	mu          sync.RWMutex
-	raw         []string  // accumulated raw segments
-	compressed  string    // latest compressed output (ready to read)
-	stats       Stats     // stats from last compression
-	opts        []Option  // compression options
-	threshold   int       // re-compress when raw tokens exceed this
-	dirty       bool      // new content since last compression
-	compressing bool      // background compression in progress
+	raw         []string // accumulated raw segments
+	compressed  string   // latest compressed output (ready to read)
+	stats       Stats    // stats from last compression
+	opts        []Option // compression options
+	threshold   int      // re-compress when raw tokens exceed this
+	dirty       bool     // new content since last compression
+	compressing bool     // background compression in progress
 	done        chan struct{}
 	wg          sync.WaitGroup // tracks in-progress compression goroutines
 }