Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KVEntry ¶
type KVEntry interface { // Key is the key that was retrieved. Key() string // Value is the retrieved value. Value() []byte // Operation returns `KVWatchOp`. Operation() KVWatchOp }
KVEntry defines what can be read on the Watch stream.
type KVStorer ¶
type KVStorer interface { // GetAllKeys the keys from KV store. GetAllKeys(context.Context) ([]string, error) // DeleteKey deletes the key from KV store. DeleteKey(context.Context, string) error // PutKV inserts a key-value pair into the KV store. PutKV(context.Context, string, []byte) error // GetValue gets the value of the given key. GetValue(context.Context, string) ([]byte, error) // GetStoreName returns the bucket name of the KV store. GetStoreName() string // Watch starts watching the KV store for changes. It returns a channel of KVEntry and a done channel. // The KVEntry channel is used to read the KVEntry and the done channel is used to indicate the end of the watch. Watch(context.Context) (<-chan KVEntry, <-chan struct{}) // Close closes the backend connection Close() }
KVStorer defines the storage for publishing the watermark and sideinput
Directories ¶
Path | Synopsis |
---|---|
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. |
Package jetstream package implements the kv store and watcher using Jetstream.
|
Package jetstream package implements the kv store and watcher using Jetstream. |
Click to show internal directories.
Click to hide internal directories.