pyra-streams 0.4.2

Redis Stream consumer infrastructure for Pyra services
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

use thiserror::Error;

/// Errors that can occur in stream consumer operations.
#[derive(Debug, Error)]
pub enum StreamError {
    #[error("Redis error: {0}")]
    Redis(#[from] redis::RedisError),

    #[error("Redis pool error: {0}")]
    Pool(#[from] deadpool_redis::PoolError),
}

pub type StreamResult<T> = Result<T, StreamError>;