Function TestKeyValueStatusBytes

jetstream/test/kv_test.go:2356–2383

(t *testing.T)

}

func TestKeyValueStatusBytes(t *testing.T) {
	s := RunBasicJetStreamServer()
	defer shutdownJSServerAndRemoveStorage(t, s)

	nc, js := jsClient(t, s)
	defer nc.Close()
	ctx := context.Background()

	kv, err := js.CreateKeyValue(ctx, jetstream.KeyValueConfig{
		Bucket: "TEST",
	})
	if err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}

	if _, err := kv.Put(ctx, "key", []byte("value")); err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}

	status, err := kv.Status(ctx)
	if err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}

	if status.Bytes() == 0 {
		t.Fatal("Expected Bytes() to return non-zero value")
	}
}

func TestKeyValueConfig(t *testing.T) {
	s := RunBasicJetStreamServer()