search.agent.tests.test_integration module¶

Integration tests for search.agent with Kinesis.

class search.agent.tests.test_integration.TestKinesisIntegration(methodName='runTest')[source]¶

Bases: unittest.case.TestCase

Test MetadataRecordProcessor with a live Kinesis stream.

classmethod setUpClass()[source]¶: Spin up ES and index documents.

classmethod tearDownClass()[source]¶: Tear down Elasticsearch once all tests have run.

test_process(mock_metadata, mock_index)[source]¶: Add some records to the stream, and run processing loop for 5s.