tokio-prometheus-metered-channel
| Crates.io | tokio-prometheus-metered-channel |
| lib.rs | tokio-prometheus-metered-channel |
| version | 0.1.0 |
| source | src |
| created_at | 2024-11-29 18:41:09.887319 |
| updated_at | 2024-11-29 18:41:09.887319 |
| description | Metered tokio channels with Prometheus metrics integration |
| homepage | |
| repository | https://github.com/huitseeker/tokio-prometheus-metered-channel |
| max_upload_size | |
| id | 1465911 |
| size | 51,755 |
François Garillot (huitseeker)
documentation
https://docs.rs/tokio-prometheus-metered-channel
README
Tokio Prometheus metered channel
Add the following to your Cargo.toml:
tokio-prometheus-metered-channel = "0.1.0"
Metered Bounded Channel
The metered bounded channel is a specialized threading utility designed to handle communication between threads with an upper limit on capacity while tracking the channel's occupancy through Prometheus metrics.
Functionality
- Bounded Capacity: This channel ensures that no more than a predefined number of messages are held in the channel at any given time.
- Backpressure Handling: When the channel reaches its capacity, any additional attempts to send messages will be blocked, allowing for backpressure management until the channel has available space.
- Prometheus Integration: The current occupancy of the channel is exposed as a Prometheus metric, enabling real-time monitoring of how "full" the channel is.