//
pkg.gl
Category
github.com/numaproj/numaflow
pkg
shared
kvs
package
1.3.2
Repository:
https://github.com/numaproj/numaflow.git
Documentation:
pkg.go.dev
Overview
Versions
1
Dependencies
1
Dependents
9
Files
50 SLOC
#
Packages
inmem
Package inmem package implements the watermark progression using in mem store as the KV store.
jetstream
Package jetstream package implements the kv store and watcher using Jetstream.
noop
No description provided by the author
#
Constants
KVDelete
KVDelete represents a delete.
KVPurge
KVPurge is when the kv bucket is purged.
KVPut
KVPut indicates an element has been put/added into the KV store.
#
Interfaces
KVEntry
KVEntry defines what can be read on the Watch stream.
KVStorer
KVStorer defines the storage for publishing the watermark and sideinput.
#
Type aliases
KVWatchOp
KVWatchOp is the operation as detected by the KV watcher.