Module: Legion::Extensions::Llm::Ollama::Runners::FleetWorker

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

Overview

Runner entrypoint for Ollama 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. Fleet protocol v3: exact execution resolves the callable from the SSOT registry (the legacy provider-object path is gone).

Class Method Summary collapse

Class Method Details

.handle_fleet_request(**opts) ⇒ Object 



24
25
26
27
28
29
30
31
32
 
# File 'lib/legion/extensions/llm/ollama/runners/fleet_worker.rb', line 24

def handle_fleet_request(**opts)
  Legion::Extensions::Llm::Fleet::ProviderResponder.call(
    payload: opts,
    provider_family: Ollama::PROVIDER_FAMILY,
    registry: Legion::Extensions::Llm::Inventory::Registry,
    delivery: opts[:delivery],
    properties: opts[:properties]
  )
end