pswamp.test_utils.runners
=========================

.. py:module:: pswamp.test_utils.runners


Functions
---------

.. autoapisummary::

   pswamp.test_utils.runners.run_nqkafka_server
   pswamp.test_utils.runners.create_topics
   pswamp.test_utils.runners.publish_geo_data
   pswamp.test_utils.runners.publish_model_data
   pswamp.test_utils.runners.csv_to_c37118
   pswamp.test_utils.runners.c37118_to_kafka
   pswamp.test_utils.runners.csv_to_kafka
   pswamp.test_utils.runners.csv_to_kafka_2
   pswamp.test_utils.runners.create_database
   pswamp.test_utils.runners.run_apps


Module Contents
---------------

.. py:function:: run_nqkafka_server(*config_args, run_in_process=True)

.. py:function:: create_topics(*config_args, n_samples=6000)

.. py:function:: publish_geo_data(config, data, kafka_topic='pmu.coords')

.. py:function:: publish_model_data(config, kafka_topic='model.data')

.. py:function:: csv_to_c37118(config, data, ip=None, port=50000)

.. py:function:: c37118_to_kafka(config, ip=None, port=50000, pdc_id=1410, kafka_topic='pmudata', kafka_topic_meta='pmudata.meta')

.. py:function:: csv_to_kafka(config, data, speed=1, t_end=None, show_playback_control=False)

.. py:function:: csv_to_kafka_2(config, data_path, speed=1, n_samples=None, streamer_class=PMUDataStreamerKafka, show_playback_control=False, **kwargs)

.. py:function:: create_database(*config_args)

.. py:function:: run_apps(config)