Directories ¶
Path | Synopsis |
---|---|
Package processor is the smallest processor entity for which the watermark will strictly monotonically increase.
|
Package processor is the smallest processor entity for which the watermark will strictly monotonically increase. |
inmem
Package inmem package implements the watermark progression using in mem store as the KV store.
|
Package inmem package implements the watermark progression using in mem store as the KV store. |
jetstream
Package jetstream package implements the watermark progression using Jetstream as the KV store.
|
Package jetstream package implements the watermark progression using Jetstream as the KV store. |
Package wmb represents the offset-timeline pair and its corresponding encoder and decoder.
|
Package wmb represents the offset-timeline pair and its corresponding encoder and decoder. |
Click to show internal directories.
Click to hide internal directories.