aboutsummaryrefslogtreecommitdiff
path: root/weed/filer2/filer.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-02-27 00:07:13 -0800
committerChris Lu <chris.lu@gmail.com>2020-02-27 00:07:13 -0800
commit555413d9fc4837302ef1c5b2b921b406c9de6777 (patch)
treedfd0f67586df0320fd9a77288651475d2ccdcc6c /weed/filer2/filer.go
parent430b5a49e2abd9e3751e8c5840a690541ddc66ca (diff)
downloadseaweedfs-555413d9fc4837302ef1c5b2b921b406c9de6777.tar.xz
seaweedfs-555413d9fc4837302ef1c5b2b921b406c9de6777.zip
weed queue starts
Diffstat (limited to 'weed/filer2/filer.go')
-rw-r--r--weed/filer2/filer.go3
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/filer2/filer.go b/weed/filer2/filer.go
index 181a250f2..e70e013ae 100644
--- a/weed/filer2/filer.go
+++ b/weed/filer2/filer.go
@@ -31,10 +31,11 @@ type Filer struct {
fileIdDeletionQueue *util.UnboundedQueue
GrpcDialOption grpc.DialOption
DirBucketsPath string
+ DirQueuesPath string
buckets *FilerBuckets
}
-func NewFiler(masters []string, grpcDialOption grpc.DialOption, bucketFolder string) *Filer {
+func NewFiler(masters []string, grpcDialOption grpc.DialOption) *Filer {
f := &Filer{
directoryCache: ccache.New(ccache.Configure().MaxSize(1000).ItemsToPrune(100)),
MasterClient: wdclient.NewMasterClient(grpcDialOption, "filer", masters),