Module differential_dataflow::capture

Logic related to capture and replay of differential collections.

This module defines a protocol for capturing and replaying differential collections to streaming storage that may both duplicate and reorder messages. It records facts about the collection that once true stay true, such as the exact changes data undergo at each time, and the number of distinct updates at each time.

The methods are parameterized by implementors of byte sources and byte sinks. For example implementations of these traits, consult the commented text at the end of this file.

Modules

• iterator
  A deduplicating, re-ordering iterator.
• sink
  Methods for recording update streams to binary bundles.
• source
  Methods for recovering update streams from binary bundles.

Structs

• Progress
  An irrevocable statement about the number of updates at times within an interval.
• YieldingIter
  An iterator that yields with a None every so often.

Enums

• Message
  A message in the CDC V2 protocol.

Traits

• Writer
  A simple sink for byte slices.