Enum mz_dataflow_types::logging::LogVariant
source · [−]pub enum LogVariant {
Timely(TimelyLog),
Differential(DifferentialLog),
Materialized(MaterializedLog),
}
Variants
Timely(TimelyLog)
Differential(DifferentialLog)
Materialized(MaterializedLog)
Implementations
sourceimpl LogVariant
impl LogVariant
sourcepub fn index_by(&self) -> Vec<usize>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where
A: Allocator,
pub fn index_by(&self) -> Vec<usize>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where
A: Allocator,
A: Allocator,
By which columns should the logs be indexed.
This is distinct from the keys
property of the type, which indicates uniqueness.
When keys exist these are good choices for indexing, but when they do not we still
require index guidance.
pub fn desc(&self) -> RelationDesc
sourcepub fn foreign_keys(&self) -> Vec<(LogVariant, Vec<(usize, usize)>)>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where
A: Allocator,
pub fn foreign_keys(&self) -> Vec<(LogVariant, Vec<(usize, usize)>)>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where
A: Allocator,
A: Allocator,
Foreign key relations from the log variant to other log collections.
The result is a list of other variants, and for each a list of local and other column identifiers that can be equated.
Trait Implementations
sourceimpl Arbitrary for LogVariant
impl Arbitrary for LogVariant
type Parameters = (<TimelyLog as Arbitrary>::Parameters, <DifferentialLog as Arbitrary>::Parameters, <MaterializedLog as Arbitrary>::Parameters)
type Parameters = (<TimelyLog as Arbitrary>::Parameters, <DifferentialLog as Arbitrary>::Parameters, <MaterializedLog as Arbitrary>::Parameters)
The type of parameters that arbitrary_with
accepts for configuration
of the generated Strategy
. Parameters must implement Default
. Read more
type Strategy = TupleUnion<((u32, Arc<Map<<TimelyLog as Arbitrary>::Strategy, fn(_: TimelyLog) -> Self>>), (u32, Arc<Map<<DifferentialLog as Arbitrary>::Strategy, fn(_: DifferentialLog) -> Self>>), (u32, Arc<Map<<MaterializedLog as Arbitrary>::Strategy, fn(_: MaterializedLog) -> Self>>))>
type Strategy = TupleUnion<((u32, Arc<Map<<TimelyLog as Arbitrary>::Strategy, fn(_: TimelyLog) -> Self>>), (u32, Arc<Map<<DifferentialLog as Arbitrary>::Strategy, fn(_: DifferentialLog) -> Self>>), (u32, Arc<Map<<MaterializedLog as Arbitrary>::Strategy, fn(_: MaterializedLog) -> Self>>))>
sourcefn arbitrary_with(_top: Self::Parameters) -> Self::Strategy
fn arbitrary_with(_top: Self::Parameters) -> Self::Strategy
sourceimpl Clone for LogVariant
impl Clone for LogVariant
sourcefn clone(&self) -> LogVariant
fn clone(&self) -> LogVariant
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
sourceimpl Debug for LogVariant
impl Debug for LogVariant
sourceimpl<'de> Deserialize<'de> for LogVariant
impl<'de> Deserialize<'de> for LogVariant
sourcefn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
sourceimpl Hash for LogVariant
impl Hash for LogVariant
sourceimpl PartialEq<LogVariant> for LogVariant
impl PartialEq<LogVariant> for LogVariant
sourcefn eq(&self, other: &LogVariant) -> bool
fn eq(&self, other: &LogVariant) -> bool
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
sourcefn ne(&self, other: &LogVariant) -> bool
fn ne(&self, other: &LogVariant) -> bool
This method tests for !=
.
sourceimpl ProtoMapEntry<LogVariant, GlobalId> for ProtoActiveLog
impl ProtoMapEntry<LogVariant, GlobalId> for ProtoActiveLog
fn from_rust<'a>(entry: (&'a LogVariant, &'a GlobalId)) -> Self
fn into_rust(self) -> Result<(LogVariant, GlobalId), TryFromProtoError>
sourceimpl RustType<ProtoLogVariant> for LogVariant
impl RustType<ProtoLogVariant> for LogVariant
sourcefn into_proto(&self) -> ProtoLogVariant
fn into_proto(&self) -> ProtoLogVariant
Convert a Self
into a Proto
value.
sourcefn from_proto(proto: ProtoLogVariant) -> Result<Self, TryFromProtoError>
fn from_proto(proto: ProtoLogVariant) -> Result<Self, TryFromProtoError>
Consume and convert a Proto
back into a Self
value. Read more
sourceimpl Serialize for LogVariant
impl Serialize for LogVariant
impl Eq for LogVariant
impl StructuralEq for LogVariant
impl StructuralPartialEq for LogVariant
Auto Trait Implementations
impl RefUnwindSafe for LogVariant
impl Send for LogVariant
impl Sync for LogVariant
impl Unpin for LogVariant
impl UnwindSafe for LogVariant
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> CallHasher for T where
T: Hash + ?Sized,
impl<T> CallHasher for T where
T: Hash + ?Sized,
sourceimpl<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,
sourcefn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to key
and return true
if they are equal.
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T
in a tonic::Request
sourceimpl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
impl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
sourceimpl<P, R> ProtoType<R> for P where
R: RustType<P>,
impl<P, R> ProtoType<R> for P where
R: RustType<P>,
sourcefn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See RustType::from_proto
.
sourcefn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See RustType::into_proto
.
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
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
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more