Fix watch to include only recent events on rev<=0

Signed-off-by: Byron Ruth <[email protected]>
k3s-io · Aug 20, 2023 · 003b4c9 · 003b4c9
1 parent edd0875
commit 003b4c9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/drivers/nats/backend_test.go b/pkg/drivers/nats/backend_test.go
@@ -376,5 +376,5 @@ func TestBackend_Watch(t *testing.T) {
 		events = append(events, es...)
 	}
 
-	expEqual(t, 5, len(events))
+	expEqual(t, 1, len(events))
 }
diff --git a/pkg/drivers/nats/kv.go b/pkg/drivers/nats/kv.go
@@ -281,7 +281,7 @@ func (e *KeyValue) watchStream(ctx context.Context, filter, keyPrefix string, st
 	}
 
 	if startRev <= 0 {
-		cfg.DeliverPolicy = jetstream.DeliverNewPolicy
+		cfg.DeliverPolicy = jetstream.DeliverLastPerSubjectPolicy
 	} else {
 		cfg.DeliverPolicy = jetstream.DeliverByStartSequencePolicy
 		cfg.OptStartSeq = startRev