Struct IngressBuilder 

pub struct IngressBuilder { /* private fields */ }

Temporary struct for accumulating ingress configuration before finalizing it into a Ingress. This builder intends to apply validation only at meaningful states of the configuration, as opposed to every intermediary state.

Implementations

impl IngressBuilder

pub fn new() -> Self

Creates a new Ingress builder.

pub fn with_name(self, name: impl AsRef<str>) -> Self

Recreates this ingress definition builder with the given name.

pub fn with_exchange(self, exchange: Exchange) -> Self

Recreates this ingress definition builder with the given exchange.

pub fn with_queue(self, queue: Queue) -> Self

Recreates this ingress definition builder with the given queue.

pub fn with_queue_named(self, queue: impl AsRef<str>) -> Self

Recreates this ingress definition builder with a queue with the given name.

pub fn with_durable(self, durable: bool) -> Self

Recreates this ingress definition builder with the given durable flag.

pub fn with_exclusive(self, exclusive: bool) -> Self

Recreates this ingress definition builder with the given exclusive flag.

pub fn with_auto_delete(self, auto_delete: bool) -> Self

Recreates this ingress definition builder with the given auto_delete flag.

pub fn with_batch_size(self, batch_size: NonZeroUsize) -> Self

Recreates this ingress definition builder with the given batch size.

pub fn with_batch_timeout(self, batch_timeout: Duration) -> Self

Recreates this ingress definition builder with the given batch timeout.

pub fn with_prefetch_count(self, prefetch_count: Option<NonZeroU16>) -> Self

Recreates this ingress definition builder with the given prefetch count.

pub fn with_acking_behavior(self, acking_behavior: AckingBehavior) -> Self

Recreates this ingress definition builder with the given acking behavior.

pub fn with_gibberish_behavior( self, gibberish_behavior: FinalizationKind, ) -> Self

Recreates this ingress definition builder with the given gibberish behavior.

pub fn with_binding_key(self, binding_key: impl Into<String>) -> Self

Recreates this ingress definition builder, adding the given binding key to the ones already included.

pub fn with_replaced_binding_keys(self, binding_keys: HashSet<String>) -> Self

Recreates this ingress definition builder with the given binding keys.

This will replace any previously added binding keys.

pub fn with_binding_header<V>(self, key: impl Into<String>, value: V) -> Self

where Header: From<V>,

Recreates this ingress definition builder, adding the given binding header to the ones already included.

pub fn with_replaced_binding_headers( self, binding_headers: HashMap<String, Header>, ) -> Self

Recreates this ingress definition builder with the given binding headers.

This will replace any previously added binding headers.

pub fn with_matching_all_headers(self) -> Self

Recreates this ingress definition builder with the headers matching behavior set to all (all headers must match).

pub fn with_matching_any_headers(self) -> Self

Recreates this ingress definition builder with the headers matching behavior set to any (at least one header must match).

pub fn with_headers_behavior( self, headers_behavior: HeadersMatchingBehavior, ) -> Self

Recreates this ingress definition builder with the given headers behavior.

pub fn build(self) -> Result<Ingress, IngressError>

Finalizes the builder, validates its state, and, assuming valid state, returns the Ingress.

Trait Implementations

impl Debug for IngressBuilder

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

Formats the value using the given formatter.