Module: Legion::Extensions::Llm::Ledger::Transport

Extended by:
Transport
Defined in:
lib/legion/extensions/llm/ledger/transport/transport.rb,
lib/legion/extensions/llm/ledger/transport/exchanges/audit.rb,
lib/legion/extensions/llm/ledger/transport/exchanges/metering.rb,
lib/legion/extensions/llm/ledger/transport/exchanges/registry.rb,
lib/legion/extensions/llm/ledger/transport/queues/audit_tools.rb,
lib/legion/extensions/llm/ledger/transport/queues/audit_prompts.rb,
lib/legion/extensions/llm/ledger/transport/queues/metering_write.rb,
lib/legion/extensions/llm/ledger/transport/queues/registry_availability.rb

Defined Under Namespace

Modules: Exchanges, Queues

Class Method Summary collapse

Class Method Details

.additional_e_to_q ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
 
# File 'lib/legion/extensions/llm/ledger/transport/transport.rb', line 15

def self.additional_e_to_q
  [
    {
      from:        Legion::Extensions::Llm::Ledger::Transport::Exchanges::Metering,
      to:          Legion::Extensions::Llm::Ledger::Transport::Queues::MeteringWrite,
      routing_key: 'metering.#'
    },
    {
      from:        Legion::Extensions::Llm::Ledger::Transport::Exchanges::Audit,
      to:          Legion::Extensions::Llm::Ledger::Transport::Queues::AuditPrompts,
      routing_key: 'audit.prompt.#'
    },
    {
      from:        Legion::Extensions::Llm::Ledger::Transport::Exchanges::Audit,
      to:          Legion::Extensions::Llm::Ledger::Transport::Queues::AuditTools,
      routing_key: 'audit.tool.#'
    },
    {
      from:        Legion::Extensions::Llm::Ledger::Transport::Exchanges::Registry,
      to:          Legion::Extensions::Llm::Ledger::Transport::Queues::RegistryAvailability,
      routing_key: '#'
    }
  ]
end