Class: OllamaAgent::Synthesis::SidekiqSynthesizer

Inherits:
Object
  • Object
show all
Defined in:
lib/ollama_agent/synthesis/sidekiq_synthesizer.rb

Overview

Aggregates worker FQCNs by queue from IntegrationExtractor output.

Instance Method Summary collapse

Constructor Details

#initialize(integration_extractor:) ⇒ SidekiqSynthesizer

Returns a new instance of SidekiqSynthesizer.



9
10
11
# File 'lib/ollama_agent/synthesis/sidekiq_synthesizer.rb', line 9

def initialize(integration_extractor:)
  @integration_extractor = integration_extractor
end

Instance Method Details

#synthesizeObject



13
14
15
16
17
18
19
20
21
# File 'lib/ollama_agent/synthesis/sidekiq_synthesizer.rb', line 13

def synthesize
  scan = @integration_extractor.extract
  by_queue = Hash.new { |h, k| h[k] = [] }
  scan.workers.each { |w| by_queue[w.queue] << w.fqcn }
  by_queue
    .transform_values { |fqs| fqs.uniq.sort }
    .sort
    .to_h
end