Struct RedisBuffer 

pub struct RedisBuffer { /* private fields */ }

Redis缓冲区组件

Implementations

impl RedisBuffer

pub fn new(config: &RedisBufferConfig) -> Result<Self, Error>

创建一个新的Redis缓冲区组件

Trait Implementations

impl Buffer for RedisBuffer

fn push<'life0, 'life1, 'async_trait>( &'life0 self, msg: &'life1 Message, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

将消息推入缓冲区

fn pop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<Message>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

从缓冲区弹出消息

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

关闭缓冲区