nv_ingest_api.util.message_brokers package

Subpackages

• nv_ingest_api.util.message_brokers.simple_message_broker package
  • Submodules
  • nv_ingest_api.util.message_brokers.simple_message_broker.broker module
    • SimpleMessageBroker
      • allow_reuse_address
    • SimpleMessageBrokerHandler
      • handle()
  • nv_ingest_api.util.message_brokers.simple_message_broker.ordered_message_queue module
    • OrderedMessageQueue
      • acknowledge()
      • can_push()
      • empty()
      • full()
      • pop()
      • push()
      • qsize()
      • return_message()
  • nv_ingest_api.util.message_brokers.simple_message_broker.simple_client module
    • SimpleClient
      • fetch_message()
      • get_client()
      • ping()
      • size()
      • submit_message()
  • Module contents
    • ResponseSchema
      • response
      • response_code
      • response_reason
      • trace_id
      • transaction_id
    • SimpleClient
      • fetch_message()
      • get_client()
      • ping()
      • size()
      • submit_message()
    • SimpleMessageBroker
      • allow_reuse_address

Module contents