package
1.3.2
Repository: https://github.com/numaproj/numaflow.git
Documentation: pkg.go.dev

# Packages

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.
No description provided by the author

# Constants

KVDelete represents a delete.
KVPurge is when the kv bucket is purged.
KVPut indicates an element has been put/added into the KV store.

# Interfaces

KVEntry defines what can be read on the Watch stream.
KVStorer defines the storage for publishing the watermark and sideinput.

# Type aliases

KVWatchOp is the operation as detected by the KV watcher.