Skip to content

Dev#70

Merged
maldwg merged 13 commits into
mainfrom
dev
Jul 17, 2026
Merged

Dev#70
maldwg merged 13 commits into
mainfrom
dev

Conversation

@maldwg

@maldwg maldwg commented Jul 17, 2026

Copy link
Copy Markdown
Member

No description provided.

maldwg and others added 9 commits July 14, 2026 17:00
- revalidation of config.yaml on every consume and produce
- batched consumption of kafka messages
- proper eos sementaics implemented
- allow correct threading for monitoring agent
- rearragne schema marshmallowing so that it does occur only once
- allow batching for the montioring agent
@github-actions

github-actions Bot commented Jul 17, 2026

Copy link
Copy Markdown
Contributor

☂️ Python Coverage

current status: ✅

Overall Coverage

Lines Covered Coverage Threshold Status
3120 2671 86% 0% 🟢

New Files

File Coverage Status
src/base/kafka/_init_.py 100% 🟢
src/base/kafka/client.py 100% 🟢
src/base/kafka/config.py 100% 🟢
src/base/kafka/consumer.py 83% 🟢
src/base/kafka/errors.py 100% 🟢
src/base/kafka/producer.py 92% 🟢
src/base/kafka/records.py 100% 🟢
src/base/kafka/resilience.py 89% 🟢
src/base/kafka/serialization.py 92% 🟢
src/base/kafka/topics.py 82% 🟢
TOTAL 94% 🟢

Modified Files

File Coverage Status
src/alerter/alerter.py 45% 🟢
src/base/clickhouse_kafka_sender.py 94% 🟢
src/base/retry.py 91% 🟢
src/detector/detector.py 85% 🟢
src/inspector/inspector.py 90% 🟢
src/logcollector/batch_handler.py 98% 🟢
src/logcollector/collector.py 90% 🟢
src/logserver/server.py 88% 🟢
src/monitoring/clickhouse_batch_sender.py 97% 🟢
src/monitoring/monitoring_agent.py 93% 🟢
src/prefilter/prefilter.py 92% 🟢
TOTAL 88% 🟢

updated for commit: 9a79358 by action🐍

@maldwg
maldwg merged commit 915f8fe into main Jul 17, 2026
16 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant