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 Nov 15, 2021
1 parent 622af90 commit 11afe5f
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 @@ -171,8 +171,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 @@ -545,7 +545,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())...)
}

// PurgeDeletes will remove all current delete markers.
Expand Down
4 changes: 3 additions & 1 deletion test/kv_test.go
Expand Up @@ -309,7 +309,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 11afe5f

Please sign in to comment.