aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-04-29 13:26:02 -0700
committerChris Lu <chris.lu@gmail.com>2020-04-29 13:26:02 -0700
commited3cf811f576e2dd9fd1c1fb0df967d7fb9e6f1c (patch)
treec74581440a5f375bedc0d03a99dc51a536f971ed
parent7c10602b49dca54591337597f48da6e228a7068d (diff)
downloadseaweedfs-ed3cf811f576e2dd9fd1c1fb0df967d7fb9e6f1c.tar.xz
seaweedfs-ed3cf811f576e2dd9fd1c1fb0df967d7fb9e6f1c.zip
refactoring
-rw-r--r--weed/filesys/meta_cache/meta_cache.go2
-rw-r--r--weed/filesys/wfs.go2
-rw-r--r--weed/messaging/broker/broker_append.go6
-rw-r--r--weed/messaging/client/subscriber.go2
-rw-r--r--weed/replication/sink/filersink/fetch_write.go2
-rw-r--r--weed/replication/source/filer_source.go10
-rw-r--r--weed/s3api/s3api_handlers.go2
-rw-r--r--weed/server/webdav_server.go2
-rw-r--r--weed/shell/command_fs_lock_unlock.go1
-rw-r--r--weed/shell/command_fs_meta_save.go2
-rw-r--r--weed/shell/commands.go2
11 files changed, 27 insertions, 6 deletions
diff --git a/weed/filesys/meta_cache/meta_cache.go b/weed/filesys/meta_cache/meta_cache.go
index f3416ca18..2b899103e 100644
--- a/weed/filesys/meta_cache/meta_cache.go
+++ b/weed/filesys/meta_cache/meta_cache.go
@@ -34,4 +34,4 @@ func openMetaStore(dbFolder string) filer2.FilerStore {
return store
-} \ No newline at end of file
+}
diff --git a/weed/filesys/wfs.go b/weed/filesys/wfs.go
index 33403aaf8..67dd2a62c 100644
--- a/weed/filesys/wfs.go
+++ b/weed/filesys/wfs.go
@@ -117,6 +117,8 @@ func (wfs *WFS) Root() (fs.Node, error) {
return wfs.root, nil
}
+var _ = filer_pb.FilerClient(&WFS{})
+
func (wfs *WFS) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) error) error {
err := pb.WithCachedGrpcClient(func(grpcConnection *grpc.ClientConn) error {
diff --git a/weed/messaging/broker/broker_append.go b/weed/messaging/broker/broker_append.go
index 7194dfcfc..26f24f4d3 100644
--- a/weed/messaging/broker/broker_append.go
+++ b/weed/messaging/broker/broker_append.go
@@ -98,6 +98,8 @@ func (broker *MessageBroker) assignAndUpload(topicConfig *messaging_pb.TopicConf
return assignResult, uploadResult, nil
}
+var _ = filer_pb.FilerClient(&MessageBroker{})
+
func (broker *MessageBroker) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) error) (err error) {
for _, filer := range broker.option.Filers {
@@ -111,3 +113,7 @@ func (broker *MessageBroker) WithFilerClient(fn func(filer_pb.SeaweedFilerClient
return
}
+
+func (broker *MessageBroker) AdjustedUrl(hostAndPort string) string {
+ return hostAndPort
+}
diff --git a/weed/messaging/client/subscriber.go b/weed/messaging/client/subscriber.go
index ddf1f82e6..2ebad4ce6 100644
--- a/weed/messaging/client/subscriber.go
+++ b/weed/messaging/client/subscriber.go
@@ -85,7 +85,7 @@ func (s *Subscriber) doSubscribe(partition int, processFn func(m *messaging_pb.M
// Subscribe starts goroutines to process the messages
func (s *Subscriber) Subscribe(processFn func(m *messaging_pb.Message)) {
- for i:=0;i<len(s.subscriberClients);i++{
+ for i := 0; i < len(s.subscriberClients); i++ {
go s.doSubscribe(i, processFn)
}
}
diff --git a/weed/replication/sink/filersink/fetch_write.go b/weed/replication/sink/filersink/fetch_write.go
index 3c7a36fa0..d6474a7f1 100644
--- a/weed/replication/sink/filersink/fetch_write.go
+++ b/weed/replication/sink/filersink/fetch_write.go
@@ -113,6 +113,8 @@ func (fs *FilerSink) fetchAndWrite(sourceChunk *filer_pb.FileChunk, dir string)
return
}
+var _ = filer_pb.FilerClient(&FilerSink{})
+
func (fs *FilerSink) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) error) error {
return pb.WithCachedGrpcClient(func(grpcConnection *grpc.ClientConn) error {
diff --git a/weed/replication/source/filer_source.go b/weed/replication/source/filer_source.go
index 90bcffdf0..69c23fe82 100644
--- a/weed/replication/source/filer_source.go
+++ b/weed/replication/source/filer_source.go
@@ -47,7 +47,7 @@ func (fs *FilerSource) LookupFileId(part string) (fileUrl string, err error) {
vid := volumeId(part)
- err = fs.withFilerClient(func(client filer_pb.SeaweedFilerClient) error {
+ err = fs.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error {
glog.V(4).Infof("read lookup volume id locations: %v", vid)
resp, err := client.LookupVolume(context.Background(), &filer_pb.LookupVolumeRequest{
@@ -91,7 +91,9 @@ func (fs *FilerSource) ReadPart(part string) (filename string, header http.Heade
return filename, header, readCloser, err
}
-func (fs *FilerSource) withFilerClient(fn func(filer_pb.SeaweedFilerClient) error) error {
+var _ = filer_pb.FilerClient(&FilerSource{})
+
+func (fs *FilerSource) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) error) error {
return pb.WithCachedGrpcClient(func(grpcConnection *grpc.ClientConn) error {
client := filer_pb.NewSeaweedFilerClient(grpcConnection)
@@ -100,6 +102,10 @@ func (fs *FilerSource) withFilerClient(fn func(filer_pb.SeaweedFilerClient) erro
}
+func (fs *FilerSource) AdjustedUrl(hostAndPort string) string {
+ return hostAndPort
+}
+
func volumeId(fileId string) string {
lastCommaIndex := strings.LastIndex(fileId, ",")
if lastCommaIndex > 0 {
diff --git a/weed/s3api/s3api_handlers.go b/weed/s3api/s3api_handlers.go
index b6f3d4334..45a7cbc2e 100644
--- a/weed/s3api/s3api_handlers.go
+++ b/weed/s3api/s3api_handlers.go
@@ -38,6 +38,8 @@ func encodeResponse(response interface{}) []byte {
return bytesBuffer.Bytes()
}
+var _ = filer_pb.FilerClient(&S3ApiServer{})
+
func (s3a *S3ApiServer) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) error) error {
return pb.WithCachedGrpcClient(func(grpcConnection *grpc.ClientConn) error {
diff --git a/weed/server/webdav_server.go b/weed/server/webdav_server.go
index 11b89677f..f195b09f7 100644
--- a/weed/server/webdav_server.go
+++ b/weed/server/webdav_server.go
@@ -110,6 +110,8 @@ func NewWebDavFileSystem(option *WebDavOption) (webdav.FileSystem, error) {
}, nil
}
+var _ = filer_pb.FilerClient(&WebDavFileSystem{})
+
func (fs *WebDavFileSystem) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) error) error {
return pb.WithCachedGrpcClient(func(grpcConnection *grpc.ClientConn) error {
diff --git a/weed/shell/command_fs_lock_unlock.go b/weed/shell/command_fs_lock_unlock.go
index a173d6c85..8a6e8f71b 100644
--- a/weed/shell/command_fs_lock_unlock.go
+++ b/weed/shell/command_fs_lock_unlock.go
@@ -52,4 +52,3 @@ func (c *commandUnlock) Do(args []string, commandEnv *CommandEnv, writer io.Writ
return nil
}
-
diff --git a/weed/shell/command_fs_meta_save.go b/weed/shell/command_fs_meta_save.go
index a5efb69ba..ed19e3d01 100644
--- a/weed/shell/command_fs_meta_save.go
+++ b/weed/shell/command_fs_meta_save.go
@@ -140,4 +140,4 @@ func doTraverseBfsAndSaving(filerClient filer_pb.FilerClient, writer io.Writer,
fmt.Fprintf(writer, "total %d directories, %d files\n", dirCount, fileCount)
}
return err
-} \ No newline at end of file
+}
diff --git a/weed/shell/commands.go b/weed/shell/commands.go
index a43196b62..b7ca5d268 100644
--- a/weed/shell/commands.go
+++ b/weed/shell/commands.go
@@ -92,6 +92,8 @@ func (ce *CommandEnv) checkDirectory(path string) error {
}
+var _ = filer_pb.FilerClient(&CommandEnv{})
+
func (ce *CommandEnv) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) error) error {
filerGrpcAddress := fmt.Sprintf("%s:%d", ce.option.FilerHost, ce.option.FilerPort+10000)