kv tests

jakubwro · Feb 3, 2024 · 6fbb390 · 6fbb390
1 parent 15ffcf2
commit 6fbb390
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/src/jetstream/JetStream.jl b/src/jetstream/JetStream.jl
@@ -27,6 +27,7 @@ export ConsumerConfiguration
 export consumer_create, consumer_update, consumer_delete
 export consumer_next, consumer_ack
 
+export keyvalue_stream_info, keyvalue_buckets
 export keyvalue_stream_create, keyvalue_stream_purge, keyvalue_stream_delete
 export keyvalue_get, keyvalue_put, keyvalue_delete, keyvalue_watch
 export JetDict, watch, with_optimistic_concurrency

diff --git a/test/jetstream.jl b/test/jetstream.jl
@@ -201,6 +201,8 @@ uint8_vec(s::String) = convert.(UInt8, collect(s))
 @testset "Key value - 100 keys" begin
     connection = NATS.connect()
     kv = JetStream.JetDict{String}(connection, "test_kv")
+    @test keyvalue_stream_info(connection, "test_kv") isa JetStream.StreamInfo
+    @test "test_kv" in keyvalue_buckets(connection)
     @time @sync for i in 1:100
         @async kv["key_$i"] = "value_$i"
     end