weed/filer/arangodb/arangodb_store_bucket.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

package arangodb

import (
	"context"
	"github.com/chrislusf/seaweedfs/weed/filer"
	"time"

	"github.com/chrislusf/seaweedfs/weed/glog"
)

var _ filer.BucketAware = (*ArangodbStore)(nil)

func (store *ArangodbStore) OnBucketCreation(bucket string) {
	//nothing needs to be done
}
func (store *ArangodbStore) OnBucketDeletion(bucket string) {
	timeout, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	cur, err := store.database.Query(timeout, `
for d in files
filter d.bucket == @bucket
remove d in files`, map[string]interface{}{"bucket": bucket})
	if err != nil {
		glog.V(0).Infof("bucket delete %s : %v", bucket, err)
	}
	defer cur.Close()
}
func (store *ArangodbStore) CanDropWholeBucket() bool {
	return true
}