Skip to content

Commit

Permalink
Do not export purge option
Browse files Browse the repository at this point in the history
  • Loading branch information
steveh committed Apr 4, 2022
1 parent 59ef68b commit a7fe02b
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 4 deletions.
6 changes: 3 additions & 3 deletions kv.go
Expand Up @@ -202,8 +202,8 @@ func LastRevision(revision uint64) DeleteOpt {
})
}

// Purge removes all previous revisions.
func Purge() DeleteOpt {
// purge removes all previous revisions.
func purge() DeleteOpt {
return deleteOptFn(func(opts *deleteOpts) error {
opts.purge = true
return nil
Expand Down Expand Up @@ -662,7 +662,7 @@ func (kv *kvs) Delete(key string, opts ...DeleteOpt) error {

// Purge will remove the key and all revisions.
func (kv *kvs) Purge(key string, opts ...DeleteOpt) error {
return kv.Delete(key, append(opts, Purge())...)
return kv.Delete(key, append(opts, purge())...)
}

const kvDefaultPurgeDeletesMarkerThreshold = 30 * time.Minute
Expand Down
4 changes: 3 additions & 1 deletion test/kv_test.go
Expand Up @@ -378,7 +378,9 @@ func TestKeyValueDeleteVsPurge(t *testing.T) {
if len(entries) != 4 {
t.Fatalf("Expected 4 entries for age after delete, got %d", len(entries))
}
err = kv.Purge("name")
err = kv.Purge("name", nats.LastRevision(4))
expectErr(t, err)
err = kv.Purge("name", nats.LastRevision(5))
expectOk(t, err)
// Check marker
e, err := kv.Get("name")
Expand Down

0 comments on commit a7fe02b

Please sign in to comment.