|
@ -55,7 +55,7 @@ func (f *Filer) DeleteEntryMetaAndData(ctx context.Context, p util.FullPath, isR |
|
|
|
|
|
|
|
|
if isDeleteCollection { |
|
|
if isDeleteCollection { |
|
|
collectionName := entry.Name() |
|
|
collectionName := entry.Name() |
|
|
f.doDeleteCollection(collectionName) |
|
|
|
|
|
|
|
|
f.DoDeleteCollection(collectionName) |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
return nil |
|
|
return nil |
|
@ -133,7 +133,7 @@ func (f *Filer) doDeleteEntryMetaAndData(ctx context.Context, entry *Entry, shou |
|
|
return nil |
|
|
return nil |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
func (f *Filer) doDeleteCollection(collectionName string) (err error) { |
|
|
|
|
|
|
|
|
func (f *Filer) DoDeleteCollection(collectionName string) (err error) { |
|
|
|
|
|
|
|
|
return f.MasterClient.WithClient(false, func(client master_pb.SeaweedClient) error { |
|
|
return f.MasterClient.WithClient(false, func(client master_pb.SeaweedClient) error { |
|
|
_, err := client.CollectionDelete(context.Background(), &master_pb.CollectionDeleteRequest{ |
|
|
_, err := client.CollectionDelete(context.Background(), &master_pb.CollectionDeleteRequest{ |
|
|