Enum ComputeEvent

pub enum ComputeEvent {
    Export(Export),
    ExportDropped(ExportDropped),
    Peek(PeekEvent),
    Frontier(Frontier),
    ImportFrontier(ImportFrontier),
    ArrangementHeapSize(ArrangementHeapSize),
    ArrangementHeapCapacity(ArrangementHeapCapacity),
    ArrangementHeapAllocations(ArrangementHeapAllocations),
    ArrangementHeapSizeOperator(ArrangementHeapSizeOperator),
    ArrangementHeapSizeOperatorDrop(ArrangementHeapSizeOperatorDrop),
    DataflowShutdown(DataflowShutdown),
    ErrorCount(ErrorCount),
    Hydration(Hydration),
    OperatorHydration(OperatorHydration),
    LirMapping(LirMapping),
    DataflowGlobal(DataflowGlobal),
}

A logged compute event.

Variants

Export(Export)

A dataflow export was created.

ExportDropped(ExportDropped)

A dataflow export was dropped.

Peek(PeekEvent)

Peek command.

Frontier(Frontier)

Available frontier information for dataflow exports.

ImportFrontier(ImportFrontier)

Available frontier information for dataflow imports.

ArrangementHeapSize(ArrangementHeapSize)

Arrangement heap size update

ArrangementHeapCapacity(ArrangementHeapCapacity)

Arrangement heap size update

ArrangementHeapAllocations(ArrangementHeapAllocations)

Arrangement heap size update

ArrangementHeapSizeOperator(ArrangementHeapSizeOperator)

Arrangement size operator address

ArrangementHeapSizeOperatorDrop(ArrangementHeapSizeOperatorDrop)

Arrangement size operator dropped

DataflowShutdown(DataflowShutdown)

All operators of a dataflow have shut down.

ErrorCount(ErrorCount)

The number of errors in a dataflow export has changed.

Hydration(Hydration)

A dataflow export was hydrated.

OperatorHydration(OperatorHydration)

A dataflow operator’s hydration status changed.

LirMapping(LirMapping)

An LIR operator was mapped to some particular dataflow operator.

Cf. ComputeLog::LirMaping

DataflowGlobal(DataflowGlobal)

Trait Implementations

impl Clone for ComputeEvent

fn clone(&self) -> ComputeEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Columnar for ComputeEvent

where Export: Columnar, ExportDropped: Columnar, PeekEvent: Columnar, Frontier: Columnar, ImportFrontier: Columnar, ArrangementHeapSize: Columnar, ArrangementHeapCapacity: Columnar, ArrangementHeapAllocations: Columnar, ArrangementHeapSizeOperator: Columnar, ArrangementHeapSizeOperatorDrop: Columnar, DataflowShutdown: Columnar, ErrorCount: Columnar, Hydration: Columnar, OperatorHydration: Columnar, LirMapping: Columnar, DataflowGlobal: Columnar,

type Container = ComputeEventContainer<<Export as Columnar>::Container, <ExportDropped as Columnar>::Container, <PeekEvent as Columnar>::Container, <Frontier as Columnar>::Container, <ImportFrontier as Columnar>::Container, <ArrangementHeapSize as Columnar>::Container, <ArrangementHeapCapacity as Columnar>::Container, <ArrangementHeapAllocations as Columnar>::Container, <ArrangementHeapSizeOperator as Columnar>::Container, <ArrangementHeapSizeOperatorDrop as Columnar>::Container, <DataflowShutdown as Columnar>::Container, <ErrorCount as Columnar>::Container, <Hydration as Columnar>::Container, <OperatorHydration as Columnar>::Container, <LirMapping as Columnar>::Container, <DataflowGlobal as Columnar>::Container>

The type that stores the columnar representation.

fn copy_from<'a>(&mut self, other: Ref<'a, Self>)

Repopulates self from a reference.

fn into_owned<'a>(other: Ref<'a, Self>) -> Self

Produce an instance of Self from Self::Ref<'a>.

fn as_columns<'a, I>(selves: I) -> Self::Container

where I: IntoIterator<Item = &'a Self>, Self: 'a,

Converts a sequence of the references to the type into columnar form.

fn into_columns<I>(selves: I) -> Self::Container

where I: IntoIterator<Item = Self>, Self: Sized,

Converts a sequence of the type into columnar form.

fn reborrow<'b, 'a>( thing: <Self::Container as Container>::Ref<'a>, ) -> <Self::Container as Container>::Ref<'b>

where 'a: 'b,

Reborrows the reference type to a shorter lifetime.

impl Debug for ComputeEvent

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

Formats the value using the given formatter.

impl PartialEq for ComputeEvent

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PartialOrd for ComputeEvent

fn partial_cmp(&self, other: &ComputeEvent) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

Tests less than (for self and other) and is used by the < operator.

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

Tests less than or equal to (for self and other) and is used by the <= operator.

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

Tests greater than (for self and other) and is used by the > operator.

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

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl<'columnar, C0, C1, C2, C3, C4, C5, C6, C7, C8, C9, C10, C11, C12, C13, C14, C15> Push<&'columnar ComputeEvent> for ComputeEventContainer<C0, C1, C2, C3, C4, C5, C6, C7, C8, C9, C10, C11, C12, C13, C14, C15>

where C0: Len + Push<&'columnar Export>, C1: Len + Push<&'columnar ExportDropped>, C2: Len + Push<&'columnar PeekEvent>, C3: Len + Push<&'columnar Frontier>, C4: Len + Push<&'columnar ImportFrontier>, C5: Len + Push<&'columnar ArrangementHeapSize>, C6: Len + Push<&'columnar ArrangementHeapCapacity>, C7: Len + Push<&'columnar ArrangementHeapAllocations>, C8: Len + Push<&'columnar ArrangementHeapSizeOperator>, C9: Len + Push<&'columnar ArrangementHeapSizeOperatorDrop>, C10: Len + Push<&'columnar DataflowShutdown>, C11: Len + Push<&'columnar ErrorCount>, C12: Len + Push<&'columnar Hydration>, C13: Len + Push<&'columnar OperatorHydration>, C14: Len + Push<&'columnar LirMapping>, C15: Len + Push<&'columnar DataflowGlobal>,

fn push(&mut self, item: &'columnar ComputeEvent)

Pushes an item onto self.

fn extend(&mut self, iter: impl IntoIterator<Item = T>)

Pushes elements of an iterator onto self.

impl<C0, C1, C2, C3, C4, C5, C6, C7, C8, C9, C10, C11, C12, C13, C14, C15> Push<ComputeEvent> for ComputeEventContainer<C0, C1, C2, C3, C4, C5, C6, C7, C8, C9, C10, C11, C12, C13, C14, C15>

where C0: Len + Push<Export>, C1: Len + Push<ExportDropped>, C2: Len + Push<PeekEvent>, C3: Len + Push<Frontier>, C4: Len + Push<ImportFrontier>, C5: Len + Push<ArrangementHeapSize>, C6: Len + Push<ArrangementHeapCapacity>, C7: Len + Push<ArrangementHeapAllocations>, C8: Len + Push<ArrangementHeapSizeOperator>, C9: Len + Push<ArrangementHeapSizeOperatorDrop>, C10: Len + Push<DataflowShutdown>, C11: Len + Push<ErrorCount>, C12: Len + Push<Hydration>, C13: Len + Push<OperatorHydration>, C14: Len + Push<LirMapping>, C15: Len + Push<DataflowGlobal>,

fn push(&mut self, item: ComputeEvent)

Pushes an item onto self.

fn extend(&mut self, iter: impl IntoIterator<Item = T>)

Pushes elements of an iterator onto self.

impl StructuralPartialEq for ComputeEvent