Skip to content

Commit 0252402

Browse files
vduduhrekby
authored andcommitted
Update path.go
- Add scheme.EntryTopic - Remove pathToRemove (if not empty)
1 parent 00d2bf4 commit 0252402

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

sugar/path.go

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -120,8 +120,21 @@ func RemoveRecursive(ctx context.Context, db ydb.Connection, pathToRemove string
120120
return xerrors.WithStackTrace(err)
121121
}
122122

123+
case scheme.EntryTopic:
124+
err = db.Topic().Drop(ctx, pt)
125+
if err != nil {
126+
return xerrors.WithStackTrace(err)
127+
}
128+
123129
default:
124130
}
131+
132+
if len(p) != 0 {
133+
err = db.Scheme().RemoveDirectory(ctx, p)
134+
if err != nil {
135+
return err
136+
}
137+
}
125138
}
126139
return nil
127140
}

0 commit comments

Comments
 (0)