Module differential_dataflow::capture[][src]

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.