CerebralCortex Test Suite

Submodules

cerebralcortex.test_suite.test_kafka module

class TestKafkaMessaging[source]

Bases: object

test_01_produce_message()[source]

Produce a message on kafka topic

test_02_consume_message()[source]

Consume kafka messages in a topic

cerebralcortex.test_suite.test_main module

class TestCerebralCortex(methodName='runTest')[source]

Bases: unittest.case.TestCase, cerebralcortex.test_suite.test_stream.DataStreamTest

setUp()[source]

Setup test params to being testing with.

Notes

DO NOT CHANGE PARAMS DEFINED UNDER TEST-PARAMS! OTHERWISE TESTS WILL FAIL. These values are hardcoded in util/data_helper file as well.

test_00()[source]

This test will create required entries in sql database.

test_9999_last()[source]

Delete all the sample test data folder/files and sql entries

cerebralcortex.test_suite.test_object_storage module

class TestObjectStorage[source]

Bases: object

test_01_bucket()[source]

Perform all bucket related tests

test_03_bucket_objects()[source]

Perform all object related tests

cerebralcortex.test_suite.test_sql_storage module

class SqlStorageTest[source]

Bases: object

test_01_is_stream()[source]
test_02_get_stream_versions()[source]
test_03_get_stream_name()[source]
test_04_get_stream_metadata_hash()[source]
test_05_get_user_id()[source]
test_06_get_user_name()[source]
test_07_get_all_users()[source]
test_08_get_user_metadata()[source]
test_09_encrypt_user_password()[source]
test_10_connect()[source]

cerebralcortex.test_suite.test_stream module

class DataStreamTest[source]

Bases: object

test_01_save_stream()[source]

Test functionality related to save a stream

test_05_map_window_to_stream()[source]

Module contents