yaque
yaque copied to clipboard
tokahuke
Yaque is yet another disk-backed persistent queue for Rust.
I feel like this should be documented somewhere, if you happen to send some bytes that matches the header of yaque, then the queue may cease to function. Happened when...
`xor` in [header.rs](https://github.com/tokahuke/yaque/blob/master/src/header.rs#L76) does not actually compute the exclusive or of `a` and `b`. Instead it checks that `a` and `b` are either both true or both false, which is...
Here's an example: ```rust use std::path::Path; use tokio::{ sync::mpsc::{channel, Receiver, Sender}, }; use yaque::{self, TryRecvError, recovery}; const CHAN_BUF_SIZE: usize = 32; const BATCH_SIZE: usize = 50; const QUEUE_PATH: &str =...
In this example, we just send and receive to a yaque. After receiving, we commit on the `RecvGuard`. Is it intentional that on the next start of the program, the...
Hi! Cool library. My use case is an IoT system where data is buffered for transmission. In the event of flaky comms, I need to buffer data to disk instead...
I am running a yaque channel with a gRPC server as a sender and a worker on the other other end processing messages. If I start the application and send...
This was a long time coming (Issues #34 and https://github.com/tokahuke/yaque/issues/15). While it is not a complete solution for _all_ cases, this might help people with most problems.
As it turns out, `tokio` does not mix well with `notify` when `crossbeam-channels` are enabled (see [here](https://docs.rs/notify/latest/notify/#crossbeam-channel--tokio)). In my tests with `yaque` added this way to my deps, it seems...
