c4d4adc46d
Add __version__ to __init__.py
2020-09-07 22:03:45 +02:00
2e71447150
Fix config typo
2020-09-07 22:03:45 +02:00
2dddf82886
Update config and SSL, i.e. make it work on aiven
2020-09-06 07:44:31 +02:00
189681c5fa
Move configuration code to its own module
2020-09-06 05:18:27 +02:00
524e27eafe
Fix async mocks and add test for consumer
2020-09-06 03:18:52 +02:00
99a99a6122
Increase caution in the consumer
...
- Fail on invalid data received from the broker.
- Remove the context manager since it's an unnecessary complication.
- Make most of the fields in the Check model mandatory.
- introduce more mandatory fields in the config models.
2020-09-06 01:52:54 +02:00
c6b4296c61
Up the lint score a bit
2020-09-06 01:06:33 +02:00
8ca5d145bd
Move the kafka consumer to the object
2020-09-06 00:56:52 +02:00
af6d59ca97
Put db in the constructor
2020-09-06 00:50:01 +02:00
3ec541c3f5
Fix formatting, log debug kafka calls
2020-09-06 00:42:21 +02:00
2b9435dddd
Add unit tests with 68% coverage, refactor a bit
2020-09-06 00:23:34 +02:00
7967b1d024
Handle broken messages, add logger to Db
2020-09-04 03:04:21 +02:00
0189f66cec
Implement database operations
2020-09-05 02:38:01 +02:00
fff8e6e4cc
Refactor once again
...
- Split collector and producer.
- Rename Application to Service.
- Use __call__() instead of run().
2020-09-05 00:06:57 +02:00
99785ab69c
Update docstrings + type annotations in Collector
2020-09-04 19:56:41 +02:00
eaf0b51fe9
Take out common code in a base class
2020-09-04 19:45:43 +02:00
916fcf1bab
Add logging
2020-09-04 19:45:18 +02:00
60a944cf5e
Refactor, rename and fix pydantic errors
2020-09-04 18:22:49 +02:00
