Key Value streams

Low level APIs for manipulating KV buckets. See JetDict for interface conforming to Base.AbstractDict.

Management

keyvalue_stream_create(connection, bucket, encoding)
keyvalue_stream_create(
    connection,
    bucket,
    encoding,
    history
)

Create a stream for KV bucket.

keyvalue_stream_purge(connection, bucket)

Purge a KV stream.

keyvalue_stream_delete(connection, bucket)

Delete a KV stream by bucket name.

keyvalue_get(connection, bucket, key)

Get a value from KV stream.

keyvalue_put(connection, bucket, key, value)
keyvalue_put(connection, bucket, key, value, revision)

Put a value to KV stream.

keyvalue_delete(connection, bucket, key)

Delete a value from KV stream.

keyvalue_watch(f, connection, bucket)
keyvalue_watch(f, connection, bucket, key)

Watch for changes in KV stream.