nats.kv — no.cjohansen/clj-nats 0.2025.12.1

cas clj

(cas conn k v rev)

(cas conn bucket-name k v rev)

Compare and swap. Sets the value of k to v, only if the current revision is still rev.

Returns the new revision number for the key.

(cas conn :bucket/key "val" 32)
(cas conn "bucket" "key" "val" 32)

configure clj

(configure conn key-value-options)

Re-configure the KeyValue management instance. Returns a new conn with the new configuration, does not change the original conn.

key-value-options is a map of:

• :nats.kv/stream-options - JetStream configuration, see nats.stream/configure for details.
• :nats.kv/domain
• :nats.kv/prefix
• :nats.kv/request-timeout

create-bucket clj

(create-bucket conn config)

Create a key/value bucket. config is a map of:

• :nats.kv/bucket-name
• :nats.kv/description
• :nats.kv/replicas
• :nats.kv/storage-type - See nats.stream/storage-types
• :nats.kv/ttl - Number of milliseconds, or a java.time.Duration
• :nats.kv/compression?
• :nats.kv/max-bucket-size
• :nats.kv/max-history-per-key
• :nats.kv/max-value-size
• :nats.kv/metadata - A map of {string|keyword string}
• :nats.kv/mirror - A map, see below
• :nats.kv/placement - A map, see below
• :nats.kv/republish - A map, see below
• :nats.kv/sources - A collection of sources, see below

Keys in the :nats.kv/mirror map and entries in the :nats.kv/sources collection:

• :nats.source/domain
• :nats.source/external
• :nats.source/filter-subject
• :nats.source/name
• :nats.source/source-name
• :nats.source/start-seq
• :nats.source/start-time
• :nats.source/subject-transforms

:nats.kv/placement map keys:

• :nats.placement/cluster
• :nats.placement/tags

:nats.kv/republish map keys:

• :nats.republish/destination
• :nats.republish/headers-only?
• :nats.republish/source

delete clj

(delete conn k)

(delete conn k expected-rev)

(delete conn bucket-name k expected-rev)

Delete the value at key k. When providing the optional expected-rev, only delete the value if the current revision is still expected-rev.

Returns the new revision number for the key.

(delete conn :bucket/key)

;; Delete specific revision
(delete conn :bucket/key 32)

(delete conn "bucket" "key" 32)

;; Explicitly name bucket and key without specifying revision
(delete conn "bucket" "key" nil)

delete-bucket clj

(delete-bucket conn bucket-name)

Delete a key/value bucket

get clj

(get conn k)

(get conn k rev)

(get conn bucket-name k rev)

Get the entry for key k. Returns the version specified by rev, or the current one.

(get conn :bucket/key)
(get conn :bucket/key 42)
(get conn "bucket" "key" 42)

get-bucket-status clj

(get-bucket-status conn bucket-name)

get-bucket-statuses clj

(get-bucket-statuses conn)

get-history clj

(get-history conn k)

(get-history conn bucket-name k)

Returns all revisions of the key k.

(get-history conn :bucket/key)
(get-history conn "bucket" "key")

get-keys clj

(get-keys conn bucket-name)

Return a set of all the keys in the bucket as strings

get-value clj

(get-value conn k)

(get-value conn k rev)

(get-value conn bucket-name k rev)

Get the value for key k. Returns the version specified by rev, or the current one.

(get-value conn :bucket/key)
(get-value conn :bucket/key 42)
(get-value conn "bucket" "key" 42)

message->key-value-entry clj

(message->key-value-entry opt bucket k msg)

message-info->key-value-entry clj

(message-info->key-value-entry opt bucket k msg)

native->key-value-entry clj

(native->key-value-entry entry)

operations clj

Available key value operations:

• :nats.kv-operation/delete
• :nats.kv-operation/purge
• :nats.kv-operation/put

purge clj

(purge conn k)

(purge conn k expected-rev)

(purge conn bucket-name k expected-rev)

Purge all history for a single key, optionally specify the expected current revision.

(purge conn :bucket/key)
(purge conn :bucket/key 23)
(purge conn "bucket" "key" 23)

purge-deleted clj

(purge-deleted conn bucket-name & [{:keys [delete-marker-threshold]}])

Purges history for deleted keys in bucket-name

put clj

(put conn k v)

(put conn bucket-name k v)

Put a key in the bucket. v can be either a byte array or any serializable Clojure value.

Supports two arities:

(put conn :bucket/key v)
(put conn "bucket" "key" v)

update-bucket clj

(update-bucket conn config)

Update a key/value bucket. See create-bucket for config details.

watch clj

(watch conn bucket-name watcher)

(watch conn bucket-name watcher watch-opts)

(watch conn bucket-name subjects watcher watch-opts)

(watch conn
       bucket-name
       subjects
       from-rev
       {:keys [watch end-of-data consumer-name-prefix]}
       watch-opts)

watch-options clj