From 5fcd9c5564f562a254398dd98abc629be1c6cdfa Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Sun, 20 Jun 2021 10:42:35 -0700 Subject: [PATCH] Add test for sequence only Signed-off-by: Derek Collison --- server/jetstream_cluster_test.go | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/server/jetstream_cluster_test.go b/server/jetstream_cluster_test.go index cddd4127..e930992f 100644 --- a/server/jetstream_cluster_test.go +++ b/server/jetstream_cluster_test.go @@ -7488,6 +7488,19 @@ func TestJetStreamClusterExtendedStreamPurge(t *testing.T) { purge(&JSApiStreamPurgeRequest{Keep: 10}, 10) expectLeft(">", 10) + // RESET AGAIN + js.DeleteStream("KV") + // Do manually for now. + nc.Request(fmt.Sprintf(JSApiStreamCreateT, cfg.Name), req, time.Second) + if _, err := js.StreamInfo("KV"); err != nil { + t.Fatalf("Unexpected error: %v", err) + } + // Put in 100. + for i := 0; i < 100; i++ { + js.Publish("kv.foo", []byte("OK")) + } + purge(&JSApiStreamPurgeRequest{Sequence: 90}, 11) // Up to 90 so we keep that, hence the 11. + expectLeft(">", 11) }) }