Class: Legion::LLM::Transport::Messages::FleetRequest

Inherits:
Legion::LLM::Transport::Message show all
Defined in:
lib/legion/llm/transport/messages/fleet_request.rb

Constant Summary collapse

PRIORITY_MAP = 
{ critical: 9, high: 7, normal: 5, low: 2 }.freeze

Constants inherited from Legion::LLM::Transport::Message

Legion::LLM::Transport::Message::LLM_ENVELOPE_KEYS

Instance Method Summary collapse

Methods inherited from Legion::LLM::Transport::Message

#app_id, #correlation_id, #headers, #message, #message_context, #message_id, #tracing_headers

Instance Method Details

#exchange ⇒ Object 



13
 
# File 'lib/legion/llm/transport/messages/fleet_request.rb', line 13

def exchange    = Legion::LLM::Transport::Exchanges::Fleet

#expiration ⇒ Object 



17
 
# File 'lib/legion/llm/transport/messages/fleet_request.rb', line 17

def expiration  = @options[:ttl] ? (@options[:ttl] * 1000).to_s : super

#priority ⇒ Object 



16
 
# File 'lib/legion/llm/transport/messages/fleet_request.rb', line 16

def priority    = map_priority(@options[:priority])

#reply_to ⇒ Object 



15
 
# File 'lib/legion/llm/transport/messages/fleet_request.rb', line 15

def reply_to    = @options[:reply_to]

#routing_key ⇒ Object 



14
 
# File 'lib/legion/llm/transport/messages/fleet_request.rb', line 14

def routing_key = @options[:routing_key]

#type ⇒ Object 



12
 
# File 'lib/legion/llm/transport/messages/fleet_request.rb', line 12

def type        = 'llm.fleet.request'