promisqs 1.2.0

An ultra-low latency, cross-platform shared memory queue implementation for IPC
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use shared_memory::ShmemError;
use thiserror::Error;

#[derive(Error, Debug)]
pub enum PromisqsError {
    #[error(transparent)]
    ShmemError(#[from] ShmemError),
    #[error("Failed to open, queue is not initialized!")]
    BufferNotInitialized,
    #[error("Element size of queue in flink does not match T!")]
    ElementSizeMismatch,
    #[error("Push failed, queue is full!")]
    QueueFull,
    #[error("Queue operation failed first attempt!")]
    WouldBlock,
}