[−][src]Struct mcai_worker_sdk::Channel
Re-export from lapin Channel
Implementations
impl Channel
[src]
Re-export from lapin Channel
pub fn status(&self) -> &ChannelStatus
[src]
pub fn id(&self) -> u16
[src]
pub fn close(
&self,
reply_code: u16,
reply_text: &str
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
reply_code: u16,
reply_text: &str
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn exchange_declare(
&self,
exchange: &str,
kind: ExchangeKind,
options: ExchangeDeclareOptions,
arguments: FieldTable
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
exchange: &str,
kind: ExchangeKind,
options: ExchangeDeclareOptions,
arguments: FieldTable
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn wait_for_confirms(
&self
) -> PinkySwear<Result<Vec<BasicReturnMessage>, Error>, Result<Confirmation, Error>>
[src]
&self
) -> PinkySwear<Result<Vec<BasicReturnMessage>, Error>, Result<Confirmation, Error>>
impl Channel
[src]
Re-export from lapin Channel
pub fn channel_flow(
&self,
options: ChannelFlowOptions
) -> PinkySwear<Result<bool, Error>, Result<(), Error>>
[src]
&self,
options: ChannelFlowOptions
) -> PinkySwear<Result<bool, Error>, Result<(), Error>>
pub fn access_request(
&self,
realm: &str,
options: AccessRequestOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
realm: &str,
options: AccessRequestOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn exchange_delete(
&self,
exchange: &str,
options: ExchangeDeleteOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
exchange: &str,
options: ExchangeDeleteOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
Delete an exchange
pub fn exchange_bind(
&self,
destination: &str,
source: &str,
routing_key: &str,
options: ExchangeBindOptions,
arguments: FieldTable
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
destination: &str,
source: &str,
routing_key: &str,
options: ExchangeBindOptions,
arguments: FieldTable
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn exchange_unbind(
&self,
destination: &str,
source: &str,
routing_key: &str,
options: ExchangeUnbindOptions,
arguments: FieldTable
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
destination: &str,
source: &str,
routing_key: &str,
options: ExchangeUnbindOptions,
arguments: FieldTable
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn queue_declare(
&self,
queue: &str,
options: QueueDeclareOptions,
arguments: FieldTable
) -> PinkySwear<Result<Queue, Error>, Result<(), Error>>
[src]
&self,
queue: &str,
options: QueueDeclareOptions,
arguments: FieldTable
) -> PinkySwear<Result<Queue, Error>, Result<(), Error>>
pub fn queue_bind(
&self,
queue: &str,
exchange: &str,
routing_key: &str,
options: QueueBindOptions,
arguments: FieldTable
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
queue: &str,
exchange: &str,
routing_key: &str,
options: QueueBindOptions,
arguments: FieldTable
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn queue_purge(
&self,
queue: &str,
options: QueuePurgeOptions
) -> PinkySwear<Result<u32, Error>, Result<(), Error>>
[src]
&self,
queue: &str,
options: QueuePurgeOptions
) -> PinkySwear<Result<u32, Error>, Result<(), Error>>
pub fn queue_delete(
&self,
queue: &str,
options: QueueDeleteOptions
) -> PinkySwear<Result<u32, Error>, Result<(), Error>>
[src]
&self,
queue: &str,
options: QueueDeleteOptions
) -> PinkySwear<Result<u32, Error>, Result<(), Error>>
pub fn queue_unbind(
&self,
queue: &str,
exchange: &str,
routing_key: &str,
arguments: FieldTable
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
queue: &str,
exchange: &str,
routing_key: &str,
arguments: FieldTable
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn basic_qos(
&self,
prefetch_count: u16,
options: BasicQosOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
prefetch_count: u16,
options: BasicQosOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn basic_consume(
&self,
queue: &str,
consumer_tag: &str,
options: BasicConsumeOptions,
arguments: FieldTable
) -> PinkySwear<Result<Consumer, Error>, Result<(), Error>>
[src]
&self,
queue: &str,
consumer_tag: &str,
options: BasicConsumeOptions,
arguments: FieldTable
) -> PinkySwear<Result<Consumer, Error>, Result<(), Error>>
pub fn basic_cancel(
&self,
consumer_tag: &str,
options: BasicCancelOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
consumer_tag: &str,
options: BasicCancelOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn basic_publish(
&self,
exchange: &str,
routing_key: &str,
options: BasicPublishOptions,
payload: Vec<u8>,
properties: AMQPProperties
) -> PinkySwear<Result<PublisherConfirm, Error>, Result<(), Error>>
[src]
&self,
exchange: &str,
routing_key: &str,
options: BasicPublishOptions,
payload: Vec<u8>,
properties: AMQPProperties
) -> PinkySwear<Result<PublisherConfirm, Error>, Result<(), Error>>
pub fn basic_get(
&self,
queue: &str,
options: BasicGetOptions
) -> PinkySwear<Result<Option<BasicGetMessage>, Error>, Result<(), Error>>
[src]
&self,
queue: &str,
options: BasicGetOptions
) -> PinkySwear<Result<Option<BasicGetMessage>, Error>, Result<(), Error>>
pub fn basic_ack(
&self,
delivery_tag: u64,
options: BasicAckOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
delivery_tag: u64,
options: BasicAckOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn basic_reject(
&self,
delivery_tag: u64,
options: BasicRejectOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
delivery_tag: u64,
options: BasicRejectOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn basic_recover_async(
&self,
options: BasicRecoverAsyncOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
options: BasicRecoverAsyncOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn basic_recover(
&self,
options: BasicRecoverOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
options: BasicRecoverOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn basic_nack(
&self,
delivery_tag: u64,
options: BasicNackOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
delivery_tag: u64,
options: BasicNackOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
pub fn tx_select(&self) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
pub fn tx_commit(&self) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
pub fn tx_rollback(&self) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
pub fn confirm_select(
&self,
options: ConfirmSelectOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
[src]
&self,
options: ConfirmSelectOptions
) -> PinkySwear<Result<(), Error>, Result<(), Error>>
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Channel
impl Send for Channel
impl Sync for Channel
impl Unpin for Channel
impl !UnwindSafe for Channel
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,