Struct DlqConfig

Source

pub struct DlqConfig {
    pub sink: Arc<dyn Sink>,
    pub on_batch_error: OnBatchError,
    pub max_failures_per_page: Option<usize>,
    pub max_failures_total: Option<usize>,
    pub include_original_payload: bool,
}

Expand description

Pipeline-level DLQ wiring.

Fields§

§sink: Arc<dyn Sink>

Sink that receives DLQ envelopes.

§on_batch_error: OnBatchError

What to do when the main sink fails wholesale.

§max_failures_per_page: Option<usize>

Per-page failure budget. None = unlimited.

This budget is shared across both sink-side row failures and quality-check quarantines: a record routed to the DLQ by a quarantine quality check counts against it just as a sink-side row failure does.

§max_failures_total: Option<usize>

Cumulative failure budget across the run. None = unlimited.

This budget is shared across both sink-side row failures and quality-check quarantines: records quarantined by the quality pass accumulate in this counter alongside sink-side failures.

§include_original_payload: bool

Always true in v1. Reserved for a future “headers-only” mode.

Struct DlqConfig Copy item path

Fields§

Implementations§

impl DlqConfig

pub fn new(sink: Arc<dyn Sink>) -> Self

Trait Implementations§

impl Clone for DlqConfig

fn clone(&self) -> DlqConfig

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

impl Debug for DlqConfig

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

Auto Trait Implementations§

impl Freeze for DlqConfig

impl !RefUnwindSafe for DlqConfig

impl Send for DlqConfig

impl Sync for DlqConfig

impl Unpin for DlqConfig

impl UnsafeUnpin for DlqConfig

impl !UnwindSafe for DlqConfig

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> CloneToUninit for Twhere T: Clone,

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

impl<T> DynClone for Twhere T: Clone,

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

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

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

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

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

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

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

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

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

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

type Error = Infallible

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

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

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

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

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

fn vzip(self) -> V

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct DlqConfig

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

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

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

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

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

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

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

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

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

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

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

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

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

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