Trait QueueApi

pub trait QueueApi {
    // Required methods
    fn list_queues<'life0, 'async_trait>(
        &'life0 self,
        vhost: Option<String>,
        options: Option<RabbitMqRequestOptions>,
    ) -> Pin<Box<dyn Future<Output = Result<RabbitMqPaginatedResponse<RabbitMqQueue>, RabbitMqClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_queue<'life0, 'async_trait>(
        &'life0 self,
        vhost: String,
        name: String,
    ) -> Pin<Box<dyn Future<Output = Result<RabbitMqQueue, RabbitMqClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_queue_bindings<'life0, 'async_trait>(
        &'life0 self,
        vhost: String,
        name: String,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<RabbitMqBinding>, RabbitMqClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn create_queue<'life0, 'async_trait>(
        &'life0 self,
        vhost: String,
        queue: String,
        request: RabbitMqQueueRequest,
    ) -> Pin<Box<dyn Future<Output = Result<(), RabbitMqClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn update_queue<'life0, 'async_trait>(
        &'life0 self,
        vhost: String,
        queue: String,
        request: RabbitMqQueueRequest,
    ) -> Pin<Box<dyn Future<Output = Result<(), RabbitMqClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn delete_queue<'life0, 'async_trait>(
        &'life0 self,
        vhost: String,
        name: String,
    ) -> Pin<Box<dyn Future<Output = Result<(), RabbitMqClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn purge_queue<'life0, 'async_trait>(
        &'life0 self,
        vhost: String,
        name: String,
    ) -> Pin<Box<dyn Future<Output = Result<(), RabbitMqClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn set_queue_actions<'life0, 'async_trait>(
        &'life0 self,
        vhost: String,
        queue: String,
        action: RabbitMqQueueAction,
    ) -> Pin<Box<dyn Future<Output = Result<(), RabbitMqClientError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Required Methods

fn list_queues<'life0, 'async_trait>( &'life0 self, vhost: Option<String>, options: Option<RabbitMqRequestOptions>, ) -> Pin<Box<dyn Future<Output = Result<RabbitMqPaginatedResponse<RabbitMqQueue>, RabbitMqClientError>> + Send + 'async_trait>>

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

fn get_queue<'life0, 'async_trait>( &'life0 self, vhost: String, name: String, ) -> Pin<Box<dyn Future<Output = Result<RabbitMqQueue, RabbitMqClientError>> + Send + 'async_trait>>

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

fn get_queue_bindings<'life0, 'async_trait>( &'life0 self, vhost: String, name: String, ) -> Pin<Box<dyn Future<Output = Result<Vec<RabbitMqBinding>, RabbitMqClientError>> + Send + 'async_trait>>

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

fn create_queue<'life0, 'async_trait>( &'life0 self, vhost: String, queue: String, request: RabbitMqQueueRequest, ) -> Pin<Box<dyn Future<Output = Result<(), RabbitMqClientError>> + Send + 'async_trait>>

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

fn update_queue<'life0, 'async_trait>( &'life0 self, vhost: String, queue: String, request: RabbitMqQueueRequest, ) -> Pin<Box<dyn Future<Output = Result<(), RabbitMqClientError>> + Send + 'async_trait>>

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

fn delete_queue<'life0, 'async_trait>( &'life0 self, vhost: String, name: String, ) -> Pin<Box<dyn Future<Output = Result<(), RabbitMqClientError>> + Send + 'async_trait>>

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

fn purge_queue<'life0, 'async_trait>( &'life0 self, vhost: String, name: String, ) -> Pin<Box<dyn Future<Output = Result<(), RabbitMqClientError>> + Send + 'async_trait>>

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

fn set_queue_actions<'life0, 'async_trait>( &'life0 self, vhost: String, queue: String, action: RabbitMqQueueAction, ) -> Pin<Box<dyn Future<Output = Result<(), RabbitMqClientError>> + Send + 'async_trait>>

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

Implementors

impl QueueApi for RabbitMqClient