Package inmem package implements the watermark progression using in mem store as the KV store.

Package jetstream package implements the kv store and watcher using Jetstream.

KVDelete represents a delete.

KVPurge is when the kv bucket is purged.

KVPut indicates an element has been put/added into the KV store.

KVEntry defines what can be read on the Watch stream.

KVStorer defines the storage for publishing the watermark and sideinput.

KVWatchOp is the operation as detected by the KV watcher.