Function TestKeyValueGetRevision

jetstream/test/kv_test.go:2309–2354

(t *testing.T)

}

func TestKeyValueGetRevision(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",
		History: 5,
	})
	if err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}

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

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

	entry, err := kv.GetRevision(ctx, "key", 1)
	if err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}

	if string(entry.Value()) != "value1" {
		t.Fatalf("Expected value1, got %s", string(entry.Value()))
	}

	if entry.Revision() != 1 {
		t.Fatalf("Expected revision 1, got %d", entry.Revision())
	}

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

	_, err = kv.GetRevision(ctx, "key", 3)
	if !errors.Is(err, jetstream.ErrKeyNotFound) {
		t.Fatalf("Expected ErrKeyNotFound, got %v", err)
	}
}

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