Expand description
The meaning of the timestamp number produced by data sources. This type is not concerned with the source of the timestamp (like if the data came from a Debezium consistency topic or a CDCv2 stream), instead only what the timestamp number means.
Some variants here have attached data used to differentiate incomparable instantiations. These attached data types should be expanded in the future if we need to tell apart more kinds of sources.
Variants
EpochMilliseconds
EpochMilliseconds means the timestamp is the number of milliseconds since the Unix epoch.
External(String)
External means the timestamp comes from an external data source and we don’t know what the number means. The attached String is the source’s name, which will result in different sources being incomparable.
User(String)
User means the user has manually specified a timeline. The attached String is specified by the user, allowing them to decide sources that are joinable.
Trait Implementations
sourceimpl Arbitrary for Timeline
impl Arbitrary for Timeline
type Parameters = (<String as Arbitrary>::Parameters, <String as Arbitrary>::Parameters)
type Parameters = (<String as Arbitrary>::Parameters, <String as Arbitrary>::Parameters)
arbitrary_with
accepts for configuration
of the generated Strategy
. Parameters must implement Default
. Read moretype Strategy = TupleUnion<((u32, Arc<fn() -> Timeline>), (u32, Arc<Map<<String as Arbitrary>::Strategy, fn(String) -> Timeline>>), (u32, Arc<Map<<String as Arbitrary>::Strategy, fn(String) -> Timeline>>))>
type Strategy = TupleUnion<((u32, Arc<fn() -> Timeline>), (u32, Arc<Map<<String as Arbitrary>::Strategy, fn(String) -> Timeline>>), (u32, Arc<Map<<String as Arbitrary>::Strategy, fn(String) -> Timeline>>))>
sourcefn arbitrary_with(_top: Self::Parameters) -> Self::Strategy
fn arbitrary_with(_top: Self::Parameters) -> Self::Strategy
sourceimpl<'de> Deserialize<'de> for Timeline
impl<'de> Deserialize<'de> for Timeline
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>,
sourceimpl Ord for Timeline
impl Ord for Timeline
1.21.0 · sourcefn max(self, other: Self) -> Self
fn max(self, other: Self) -> Self
1.21.0 · sourcefn min(self, other: Self) -> Self
fn min(self, other: Self) -> Self
1.50.0 · sourcefn clamp(self, min: Self, max: Self) -> Selfwhere
Self: PartialOrd<Self>,
fn clamp(self, min: Self, max: Self) -> Selfwhere
Self: PartialOrd<Self>,
sourceimpl PartialOrd<Timeline> for Timeline
impl PartialOrd<Timeline> for Timeline
sourcefn partial_cmp(&self, other: &Timeline) -> Option<Ordering>
fn partial_cmp(&self, other: &Timeline) -> Option<Ordering>
1.0.0 · sourcefn le(&self, other: &Rhs) -> bool
fn le(&self, other: &Rhs) -> bool
self
and other
) and is used by the <=
operator. Read moresourceimpl RustType<ProtoTimeline> for Timeline
impl RustType<ProtoTimeline> for Timeline
sourcefn into_proto(&self) -> ProtoTimeline
fn into_proto(&self) -> ProtoTimeline
Self
into a Proto
value.sourcefn from_proto(proto: ProtoTimeline) -> Result<Self, TryFromProtoError>
fn from_proto(proto: ProtoTimeline) -> Result<Self, TryFromProtoError>
impl Eq for Timeline
impl StructuralEq for Timeline
impl StructuralPartialEq for Timeline
Auto Trait Implementations
impl RefUnwindSafe for Timeline
impl Send for Timeline
impl Sync for Timeline
impl Unpin for Timeline
impl UnwindSafe for Timeline
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
sourceimpl<T> CallHasher for Twhere
T: Hash + ?Sized,
impl<T> CallHasher for Twhere
T: Hash + ?Sized,
sourceimpl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
sourcefn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
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>
T
in a tonic::Request
sourceimpl<T> Pointable for T
impl<T> Pointable for T
sourceimpl<T> ProgressEventTimestamp for Twhere
T: Data + Debug + Any,
impl<T> ProgressEventTimestamp for Twhere
T: Data + Debug + Any,
sourceimpl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
sourcefn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
RustType::from_proto
.sourcefn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
RustType::into_proto
.