Adds a protocol-based wrapper for interacting with KV state stores.
Includes some store-related utilities as well.
Nothing really jackdaw-specific here, but including in this library anyway.
Useful when dealing with explicit state stores using the lower-level Processor API
(for example via the Streams transform
method).
Adds a protocol-based wrapper for interacting with KV state stores. Includes some store-related utilities as well. Nothing really jackdaw-specific here, but including in this library anyway. Useful when dealing with explicit state stores using the lower-level Processor API (for example via the Streams `transform` method).
(get-all-kvs state-store)
Get all the keys/values in a KeyValueStore. Handy for dev debugging, but be careful not to call it on a huge store.
Get _all_ the keys/values in a KeyValueStore. Handy for dev debugging, but be careful not to call it on a huge store.
(get-json kvstore k)
(get-key this k)
Gets the value for key
Gets the value for key
(set-key this k v)
Sets the value for key; deletes key when value is nil.
Sets the value for key; deletes key when value is nil.
(set-json kvstore k v)
(state-store-builder store-name)
(state-store-builder store-name key-serde value-serde)
Returns a builder (for use with .addStateStore
) for a persistent store with the specified name and serdes. Defaults to String serdes.
Returns a builder (for use with `.addStateStore`) for a persistent store with the specified name and serdes. Defaults to String serdes.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close