micromegas::analytics::lakehouse::view_registry

Enum BuildPurpose

pub enum BuildPurpose {
    LiveSnapshot,
    Probe,
}

Expand description

What a build_factory call is for, which decides how a skipped definition is reported.

Variants§

§

LiveSnapshot

The snapshot current() will serve: a skipped definition is real degradation – something that used to work no longer does, or never did – so it is warn!-logged and metered.

§

Probe

A speculative build the DDL executor runs inside its own transaction, on row sets that may deliberately be missing a view another one reads. A skip here is the expected signal, not degradation: it is returned in BuildFailure for the caller to act on – either to refuse the statement, naming the definition and reason, or to ignore a row that was already broken before the mutation. Logging it would report a rejected statement, or a pre-existing breakage the live build already reports every tick, as a fresh registry failure.

BuildPurpose

Enum BuildPurpose Copy item path

Variants§

LiveSnapshot

Probe

Trait Implementations§

impl Clone for BuildPurpose

fn clone(&self) -> BuildPurpose

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

impl Copy for BuildPurpose

impl Debug for BuildPurpose

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

impl Eq for BuildPurpose

impl PartialEq for BuildPurpose

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

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

impl StructuralPartialEq for BuildPurpose

Auto Trait Implementations§

impl Freeze for BuildPurpose

impl RefUnwindSafe for BuildPurpose

impl Send for BuildPurpose

impl Sync for BuildPurpose

impl Unpin for BuildPurpose

impl UnsafeUnpin for BuildPurpose

impl UnwindSafe for BuildPurpose

Blanket Implementations§

impl<T> Allocation for Twhere T: RefUnwindSafe + Send + Sync,

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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

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> DynEq for Twhere T: Eq + Any,

fn dyn_eq(&self, other: &(dyn Any + 'static)) -> bool

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

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

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

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

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ

fn with_current_context(self) -> WithContext<Self> ⓘ

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> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘwhere F: FnOnce(&Self) -> bool,

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

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: Sized + Policy<B, E>, P: Policy<B, E>,

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

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

impl<T> Same for T

type Output = T

impl<T> Scope for T

fn with<F, R>(self, f: F) -> Rwhere Self: Sized, F: FnOnce(Self) -> R,

fn with_ref<F, R>(&self, f: F) -> Rwhere F: FnOnce(&Self) -> R,

Enum BuildPurpose

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

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

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

impl<T> DynEq for T
where T: Eq + Any,

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

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

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

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

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

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

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

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

fn with<F, R>(self, f: F) -> R
where Self: Sized, F: FnOnce(Self) -> R,

fn with_ref<F, R>(&self, f: F) -> R
where F: FnOnce(&Self) -> R,

fn with_mut<F, R>(&mut self, f: F) -> R
where F: FnOnce(&mut Self) -> R,

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>,

impl<T> Value for T
where T: Send + Sync + 'static,

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