Module: Legion::Extensions::Llm::Gemini::Runners::FleetWorker

Defined in:
lib/legion/extensions/llm/gemini/runners/fleet_worker.rb

Overview

Runner entrypoint for Gemini fleet request execution.

The Subscription dispatch path invokes this as runner_class.send(fn, **message) where message is the fleet request envelope merged with transport metadata (routing_key, message_id, headers, ...). The responder parses the envelope out of that hash; unknown keys are inert.

Class Method Summary collapse

Class Method Details

.handle_fleet_request(**opts) ⇒ Object 



21
22
23
24
25
26
27
28
29
30
 
# File 'lib/legion/extensions/llm/gemini/runners/fleet_worker.rb', line 21

def handle_fleet_request(**opts)
  Legion::Extensions::Llm::Fleet::ProviderResponder.call(
    payload: opts,
    provider_family: Gemini::PROVIDER_FAMILY,
    provider_class: Gemini::Provider,
    provider_instances: -> { Gemini.discover_instances },
    delivery: opts[:delivery],
    properties: opts[:properties]
  )
end