projects / osm / POL.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: a4e615d) | patch
Implements aiokafka and modifies code to support asyncio 89/6689/11
authorBenjamin Diaz <bdiaz@whitestack.com>
Thu, 11 Oct 2018 15:34:20 +0000 (12:34 -0300)
committerBenjamin Diaz <bdiaz@whitestack.com>
Tue, 16 Oct 2018 20:08:33 +0000 (17:08 -0300)
commit16256cbbf6cdfde8debc3254bf55ce0b8fa51b08
tree0895c8ae10e6717266513c5020941f90968fcceetree | snapshot
parenta4e615d9bab28eefa0ae1e713ad75289ed2f65cccommit | diff
Implements aiokafka and modifies code to support asyncio

Replaces multithreading with asyncronous calls to kafka.
Implements the async/await keywords in methods that needed
it.

Signed-off-by: Benjamin Diaz <bdiaz@whitestack.com>
Change-Id: Ic93054dc9a6b3835e2eaf1a480e5081c5eb9d4f5
debian/python3-osm-policy-module.postinst diff | blob | history
osm_policy_module/cmd/policy_module_agent.py diff | blob | history
osm_policy_module/common/lcm_client.py diff | blob | history
osm_policy_module/common/mon_client.py diff | blob | history
osm_policy_module/core/agent.py diff | blob | history
osm_policy_module/tests/integration/test_kafka_messages.py diff | blob | history
osm_policy_module/tests/integration/test_policy_agent.py diff | blob | history
requirements.txt diff | blob | history
setup.py diff | blob | history