QueueInfo

Struct QueueInfo 

Source
pub struct QueueInfo {
    pub name: String,
    pub queue_type: QueueType,
}
Expand description

Information about a Service Bus queue including name and type.

Represents a queue with its full name and type classification. Provides utility methods for working with main queues and their corresponding dead letter queues.

§Examples

use quetty_server::service_bus_manager::{QueueInfo, QueueType};

// Create a main queue
let main_queue = QueueInfo::main_queue("orders".to_string());
assert_eq!(main_queue.name, "orders");
assert_eq!(main_queue.queue_type, QueueType::Main);

// Get the corresponding dead letter queue
let dlq = main_queue.to_dlq();
assert_eq!(dlq.name, "orders/$deadletterqueue");
assert_eq!(dlq.queue_type, QueueType::DeadLetter);

Fields§

§name: String

Full name of the queue

§queue_type: QueueType

Type classification of the queue

Implementations§

Source§

impl QueueInfo

Source

pub fn new(name: String, queue_type: QueueType) -> Self

Creates a new QueueInfo with the specified name and type.

§Arguments
  • name - The full queue name
  • queue_type - The type of queue
§Returns

A new QueueInfo instance

Source

pub fn main_queue(name: String) -> Self

Creates a QueueInfo for a main queue.

§Arguments
  • name - The base name of the queue
§Returns

A QueueInfo representing a main queue

Source

pub fn dead_letter_queue(base_name: String) -> Self

Creates a QueueInfo for a dead letter queue.

Automatically appends the dead letter queue suffix to the base name.

§Arguments
  • base_name - The base name of the queue (without DLQ suffix)
§Returns

A QueueInfo representing the dead letter queue

Source

pub fn base_name(&self) -> String

Gets the base name of the queue without any type-specific suffixes.

For main queues, returns the name as-is. For dead letter queues, removes the /$deadletterqueue suffix to get the base name.

§Returns

The base queue name without type suffixes

Source

pub fn to_dlq(&self) -> Self

Creates a QueueInfo for the dead letter queue corresponding to this queue.

§Returns

A QueueInfo representing the dead letter queue for this queue’s base name

Source

pub fn to_main(&self) -> Self

Creates a QueueInfo for the main queue corresponding to this queue.

§Returns

A QueueInfo representing the main queue for this queue’s base name

Trait Implementations§

Source§

impl Clone for QueueInfo

Source§

fn clone(&self) -> QueueInfo

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for QueueInfo

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl PartialEq for QueueInfo

Source§

fn eq(&self, other: &QueueInfo) -> bool

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
Source§

impl Eq for QueueInfo

Source§

impl StructuralPartialEq for QueueInfo

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DynClone for T
where T: Clone,

Source§

fn __clone_box(&self, _: Private) -> *mut ()

Source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

Source§

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> SendBound for T
where T: Send,