search.agent package

The search agent is responsible for updating the index as papers are published.

The agent consumes notifications on the MetadataIsAvailable stream. For each notification, the agent retrieves metadata for the most recent version of the indicated paper from the search.services.metadata service. The agent also retrieves metadata for earlier versions, if there are multiple versions available. Each version is passed to the search.services.index service, and becomes available for discovery via search.routes.ui.

search.agent.process_stream(duration=None)

Configure and run the record processor.

Parameters:duration (int) – Time (in seconds) to run record processing. If None (default), will run “forever”. Return type:None

Subpackages

• search.agent.tests package
  • Submodules
    • search.agent.tests.test_integration module
    • search.agent.tests.test_record_processor module

Submodules

• search.agent.consumer module