teslamotors / fleet-telemetry

Apache License 2.0

655 stars 73 forks source link

Add kafka metrics related to local queue size #158

Closed agbpatro closed 5 months ago

agbpatro commented 5 months ago

Description

Adds a go routine which periodically tracks pending messages to be sent to the broker.

Type of change

Please select all options that apply to this change:

[x] New feature (non-breaking change which adds functionality)
[ ] Breaking change (fix or feature that would cause existing functionality to not work as expected)
[ ] Bug fix (non-breaking change which fixes an issue)
[ ] Documentation update

Checklist:

Confirm you have completed the following steps:

[x] My code follows the style of this project.
[x] I have performed a self-review of my code.
[ ] I have made corresponding updates to the documentation.
[ ] I have added/updated unit tests to cover my changes.
[ ] I have added/updated integration tests to cover my changes.