Class: Legion::Extensions::Llm::Ollama::Actor::FleetWorker
- Inherits:
-
Actors::Subscription
- Object
- Actors::Subscription
- Legion::Extensions::Llm::Ollama::Actor::FleetWorker
- Defined in:
- lib/legion/extensions/llm/ollama/actors/fleet_worker.rb
Overview
Subscription actor for Ollama fleet request consumption.
Instance Method Summary collapse
- #enabled? ⇒ Boolean
-
#runner_class ⇒ Object
The Subscription dispatch path (use_runner? == false) calls runner_class.send(fn, **message) — a String cannot be send-ed, so the runner must be the resolved module constant.
- #runner_function ⇒ Object
- #use_runner? ⇒ Boolean
Instance Method Details
#enabled? ⇒ Boolean
39 40 41 |
# File 'lib/legion/extensions/llm/ollama/actors/fleet_worker.rb', line 39 def enabled? Legion::Extensions::Llm::Fleet::ProviderResponder.enabled_for?(Ollama.discover_instances) end |
#runner_class ⇒ Object
The Subscription dispatch path (use_runner? == false) calls runner_class.send(fn, **message) — a String cannot be send-ed, so the runner must be the resolved module constant.
27 28 29 |
# File 'lib/legion/extensions/llm/ollama/actors/fleet_worker.rb', line 27 def runner_class Legion::Extensions::Llm::Ollama::Runners::FleetWorker end |
#runner_function ⇒ Object
31 32 33 |
# File 'lib/legion/extensions/llm/ollama/actors/fleet_worker.rb', line 31 def runner_function 'handle_fleet_request' end |
#use_runner? ⇒ Boolean
35 36 37 |
# File 'lib/legion/extensions/llm/ollama/actors/fleet_worker.rb', line 35 def use_runner? false end |