[−][src]Struct declarative_dataflow::LiveIndex
CollectionIndex that was imported into a scope.
Methods
impl<G, K, V, TrCount, TrPropose, TrValidate> LiveIndex<G, K, V, TrCount, TrPropose, TrValidate> where
G: Scope,
G::Timestamp: Lattice + Data,
K: Data,
V: Data,
TrCount: TraceReader<K, (), G::Timestamp, isize> + Clone,
TrPropose: TraceReader<K, V, G::Timestamp, isize> + Clone,
TrValidate: TraceReader<(K, V), (), G::Timestamp, isize> + Clone,
[src]
G: Scope,
G::Timestamp: Lattice + Data,
K: Data,
V: Data,
TrCount: TraceReader<K, (), G::Timestamp, isize> + Clone,
TrPropose: TraceReader<K, V, G::Timestamp, isize> + Clone,
TrValidate: TraceReader<(K, V), (), G::Timestamp, isize> + Clone,
pub fn enter<'a, TInner>(
&self,
child: &Child<'a, G, TInner>
) -> LiveIndex<Child<'a, G, TInner>, K, V, TraceEnter<K, (), G::Timestamp, isize, TrCount, TInner>, TraceEnter<K, V, G::Timestamp, isize, TrPropose, TInner>, TraceEnter<(K, V), (), G::Timestamp, isize, TrValidate, TInner>> where
TrCount::Batch: Clone,
TrPropose::Batch: Clone,
TrValidate::Batch: Clone,
K: 'static,
V: 'static,
G::Timestamp: Clone + Default + 'static,
TInner: Refines<G::Timestamp> + Lattice + Timestamp + Clone + Default + 'static,
[src]
&self,
child: &Child<'a, G, TInner>
) -> LiveIndex<Child<'a, G, TInner>, K, V, TraceEnter<K, (), G::Timestamp, isize, TrCount, TInner>, TraceEnter<K, V, G::Timestamp, isize, TrPropose, TInner>, TraceEnter<(K, V), (), G::Timestamp, isize, TrValidate, TInner>> where
TrCount::Batch: Clone,
TrPropose::Batch: Clone,
TrValidate::Batch: Clone,
K: 'static,
V: 'static,
G::Timestamp: Clone + Default + 'static,
TInner: Refines<G::Timestamp> + Lattice + Timestamp + Clone + Default + 'static,
Brings the index's traces into the specified scope.
pub fn enter_at<'a, TInner, FCount, FPropose, FValidate>(
&self,
child: &Child<'a, G, TInner>,
fcount: FCount,
fpropose: FPropose,
fvalidate: FValidate
) -> LiveIndex<Child<'a, G, TInner>, K, V, TraceEnterAt<K, (), G::Timestamp, isize, TrCount, TInner, FCount>, TraceEnterAt<K, V, G::Timestamp, isize, TrPropose, TInner, FPropose>, TraceEnterAt<(K, V), (), G::Timestamp, isize, TrValidate, TInner, FValidate>> where
TrCount::Batch: Clone,
TrPropose::Batch: Clone,
TrValidate::Batch: Clone,
K: 'static,
V: 'static,
G::Timestamp: Clone + Default + 'static,
TInner: Refines<G::Timestamp> + Lattice + Timestamp + Clone + Default + 'static,
FCount: Fn(&K, &(), &G::Timestamp) -> TInner + 'static,
FPropose: Fn(&K, &V, &G::Timestamp) -> TInner + 'static,
FValidate: Fn(&(K, V), &(), &G::Timestamp) -> TInner + 'static,
[src]
&self,
child: &Child<'a, G, TInner>,
fcount: FCount,
fpropose: FPropose,
fvalidate: FValidate
) -> LiveIndex<Child<'a, G, TInner>, K, V, TraceEnterAt<K, (), G::Timestamp, isize, TrCount, TInner, FCount>, TraceEnterAt<K, V, G::Timestamp, isize, TrPropose, TInner, FPropose>, TraceEnterAt<(K, V), (), G::Timestamp, isize, TrValidate, TInner, FValidate>> where
TrCount::Batch: Clone,
TrPropose::Batch: Clone,
TrValidate::Batch: Clone,
K: 'static,
V: 'static,
G::Timestamp: Clone + Default + 'static,
TInner: Refines<G::Timestamp> + Lattice + Timestamp + Clone + Default + 'static,
FCount: Fn(&K, &(), &G::Timestamp) -> TInner + 'static,
FPropose: Fn(&K, &V, &G::Timestamp) -> TInner + 'static,
FValidate: Fn(&(K, V), &(), &G::Timestamp) -> TInner + 'static,
Brings the index's traces into the specified scope.
Trait Implementations
impl<G, K, V, TrCount, TrPropose, TrValidate> Clone for LiveIndex<G, K, V, TrCount, TrPropose, TrValidate> where
G: Scope,
G::Timestamp: Lattice + Data,
K: Data,
V: Data,
TrCount: TraceReader<K, (), G::Timestamp, isize> + Clone,
TrPropose: TraceReader<K, V, G::Timestamp, isize> + Clone,
TrValidate: TraceReader<(K, V), (), G::Timestamp, isize> + Clone,
[src]
G: Scope,
G::Timestamp: Lattice + Data,
K: Data,
V: Data,
TrCount: TraceReader<K, (), G::Timestamp, isize> + Clone,
TrPropose: TraceReader<K, V, G::Timestamp, isize> + Clone,
TrValidate: TraceReader<(K, V), (), G::Timestamp, isize> + Clone,
Auto Trait Implementations
impl<G, K, V, TrCount, TrPropose, TrValidate> !Send for LiveIndex<G, K, V, TrCount, TrPropose, TrValidate>
impl<G, K, V, TrCount, TrPropose, TrValidate> !Sync for LiveIndex<G, K, V, TrCount, TrPropose, TrValidate>
Blanket Implementations
impl<T, U> Into for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
impl<T> From for T
[src]
impl<T, U> TryFrom for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T> Borrow for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> BorrowMut for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T, U> TryInto for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Data for T where
T: 'static + Clone,
[src]
T: 'static + Clone,