replace CreateBucket with CreateBucketIfNotExists

Signed-off-by: Benjamin Wang <benjamin.ahrtr@gmail.com>
This commit is contained in:
Benjamin Wang 2024-01-15 16:18:27 +00:00
parent 4bc55e5208
commit 690916f018

View File

@ -112,8 +112,7 @@ func (t *batchTx) Unlock() {
}
func (t *batchTx) UnsafeCreateBucket(bucket Bucket) {
_, err := t.tx.CreateBucket(bucket.Name())
if err != nil && err != bolt.ErrBucketExists {
if _, err := t.tx.CreateBucketIfNotExists(bucket.Name()); err != nil {
t.backend.lg.Fatal(
"failed to create a bucket",
zap.Stringer("bucket-name", bucket),