Class: Legion::LLM::Fleet::Request

Inherits:

Transport::Message

• Object
• Transport::Message
• Transport::Message
• Legion::LLM::Fleet::Request

Defined in:

lib/legion/llm/fleet/request.rb

Constant Summary

PRIORITY_MAP =

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

Constants inherited from Transport::Message

Transport::Message::LLM_ENVELOPE_KEYS

Instance Method Summary

• #exchange ⇒ Object
• #expiration ⇒ Object
• #priority ⇒ Object
• #reply_to ⇒ Object
• #routing_key ⇒ Object
• #type ⇒ Object

Methods inherited from Transport::Message

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

Instance Method Details

#exchange ⇒ Object

# File 'lib/legion/llm/fleet/request.rb', line 12

def exchange    = Legion::LLM::Fleet::Exchange

#expiration ⇒ Object

# File 'lib/legion/llm/fleet/request.rb', line 16

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

#priority ⇒ Object

# File 'lib/legion/llm/fleet/request.rb', line 15

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

#reply_to ⇒ Object

# File 'lib/legion/llm/fleet/request.rb', line 14

def reply_to    = @options[:reply_to]

#routing_key ⇒ Object

# File 'lib/legion/llm/fleet/request.rb', line 13

def routing_key = @options[:routing_key]

#type ⇒ Object

# File 'lib/legion/llm/fleet/request.rb', line 11

def type        = 'llm.fleet.request'