Struct celery::broker::RedisBroker
source · pub struct RedisBroker { /* private fields */ }
Trait Implementations§
source§impl Broker for RedisBroker
impl Broker for RedisBroker
source§fn consume<'life0, 'life1, 'async_trait>(
&'life0 self,
queue: &'life1 str,
error_handler: Box<dyn Fn(BrokerError) + Send + Sync + 'static>
) -> Pin<Box<dyn Future<Output = Result<(String, Box<dyn DeliveryStream>), BrokerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn consume<'life0, 'life1, 'async_trait>( &'life0 self, queue: &'life1 str, error_handler: Box<dyn Fn(BrokerError) + Send + Sync + 'static> ) -> Pin<Box<dyn Future<Output = Result<(String, Box<dyn DeliveryStream>), BrokerError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
Consume messages from a queue.
If the connection is successful, this should return a future stream of Result
s where an Ok
value is a Self::Delivery
type that can be coerced into a Message
and an Err
value is a
Self::DeliveryError
type.
source§fn ack<'life0, 'life1, 'async_trait>(
&'life0 self,
delivery: &'life1 dyn Delivery
) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn ack<'life0, 'life1, 'async_trait>( &'life0 self, delivery: &'life1 dyn Delivery ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
Acknowledge a Delivery
for deletion.
source§fn retry<'life0, 'life1, 'async_trait>(
&'life0 self,
delivery: &'life1 dyn Delivery,
eta: Option<DateTime<Utc>>
) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn retry<'life0, 'life1, 'async_trait>( &'life0 self, delivery: &'life1 dyn Delivery, eta: Option<DateTime<Utc>> ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
Retry a delivery.
source§fn send<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
message: &'life1 Message,
queue: &'life2 str
) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn send<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, message: &'life1 Message, queue: &'life2 str ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,
Send a Message
into a queue.
source§fn increase_prefetch_count<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn increase_prefetch_count<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
Increase the prefetch_count
. This has to be done when a task with a future
ETA is consumed.
source§fn decrease_prefetch_count<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn decrease_prefetch_count<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
Decrease the prefetch_count
. This has to be done after a task with a future
ETA is executed.
source§fn close<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn close<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
Clone all channels and connection.
source§fn cancel<'life0, 'life1, 'async_trait>(
&'life0 self,
_consumer_tag: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn cancel<'life0, 'life1, 'async_trait>( &'life0 self, _consumer_tag: &'life1 str ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
Cancel the consumer with the given
consumer_tag
.Auto Trait Implementations§
impl !RefUnwindSafe for RedisBroker
impl Send for RedisBroker
impl Sync for RedisBroker
impl Unpin for RedisBroker
impl !UnwindSafe for RedisBroker
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more