iggy
iggy copied to clipboard
iggy-rs
Iggy is the persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second.
Instead of ringbuffer or slow atomic-based global counter of used bytes.
Don't wrap in `Option`
Currently, we test only unencrypted TCP. The aim of this task is to add possibility to test encrypted TCP performance and compare it with QUIC, which is encrypted by default....
Currently, we have ubuntu + musl. I suggest checking alpine + musl and ubuntu + gnu.
- Implemented `fmt::Display` for `Partition`, `Segment` and `Stream` - Renamed `XXX_indexes` to `XXX_indices` - Renamed `topics_ids` to `topic_ids` - Closes #481
For example, the `load()` method expects an empty struct to be passed to load the data, while it's not the case anymore for some components.
Instead of writing: iggy/src/messages/send_messages.rs ```rust impl BytesSerializable for Message { fn as_bytes(&self) -> Vec { let mut bytes = Vec::with_capacity(self.get_size_bytes() as usize); bytes.put_u128_le(self.id); if let Some(headers) = &self.headers { let...