Expand description
This module contains the event metadata required to track an event as it flows through transforms, being duplicated and merged, and then report its status when the last copy is delivered or dropped.
Structs§
- Batch
Notifier - A batch notifier contains the status of the current batch along with a one-shot notifier to send that status back to the source. It is shared among all events of a batch.
- Batch
Status Receiver - A convenience newtype wrapper for the one-shot receiver for an individual batch status.
- Event
Finalizer - An event finalizer is the shared data required to handle tracking the status of an event, and updating the status of a batch with that when the event is dropped.
- Event
Finalizers - A collection of event finalizers.
- Owned
Batch Notifier - The non-shared data underlying the shared
BatchNotifier
Enums§
- Batch
Status - The status of an individual batch.
- Event
Status - The status of an individual event.
Traits§
- AddBatch
Notifier - An object to which we can add a batch notifier.
- Finalizable
- An object that can be finalized.