diff options
| author | chrislu <chris.lu@gmail.com> | 2022-05-06 23:38:22 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-05-06 23:38:22 -0700 |
| commit | 8bc16f11496e0c184f8ffdd3c16df8a074b65a2b (patch) | |
| tree | 3676f3ff707751bf339022744b372c16ab4d9c3e | |
| parent | bbd3c586f6e76c303c95b6537001abe8b7c5ea82 (diff) | |
| download | seaweedfs-8bc16f11496e0c184f8ffdd3c16df8a074b65a2b.tar.xz seaweedfs-8bc16f11496e0c184f8ffdd3c16df8a074b65a2b.zip | |
rename
| -rw-r--r-- | weed/pb/filer_pb_tail.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/pb/filer_pb_tail.go b/weed/pb/filer_pb_tail.go index 16c7bc8f4..b373588c9 100644 --- a/weed/pb/filer_pb_tail.go +++ b/weed/pb/filer_pb_tail.go @@ -16,7 +16,7 @@ func FollowMetadata(filerAddress ServerAddress, grpcDialOption grpc.DialOption, pathPrefix string, additionalPathPrefixes []string, lastTsNs int64, selfSignature int32, processEventFn ProcessMetadataFunc, fatalOnError bool) error { - err := WithFilerClient(true, filerAddress, grpcDialOption, makeFunc(clientName, clientId, + err := WithFilerClient(true, filerAddress, grpcDialOption, makeSubscribeMetadataFunc(clientName, clientId, pathPrefix, additionalPathPrefixes, &lastTsNs, selfSignature, processEventFn, fatalOnError)) if err != nil { return fmt.Errorf("subscribing filer meta change: %v", err) @@ -28,7 +28,7 @@ func WithFilerClientFollowMetadata(filerClient filer_pb.FilerClient, clientName string, clientId int32, pathPrefix string, lastTsNs *int64, selfSignature int32, processEventFn ProcessMetadataFunc, fatalOnError bool) error { - err := filerClient.WithFilerClient(true, makeFunc(clientName, clientId, + err := filerClient.WithFilerClient(true, makeSubscribeMetadataFunc(clientName, clientId, pathPrefix, nil, lastTsNs, selfSignature, processEventFn, fatalOnError)) if err != nil { return fmt.Errorf("subscribing filer meta change: %v", err) @@ -37,7 +37,7 @@ func WithFilerClientFollowMetadata(filerClient filer_pb.FilerClient, return nil } -func makeFunc(clientName string, clientId int32, pathPrefix string, additionalPathPrefixes []string, lastTsNs *int64, selfSignature int32, +func makeSubscribeMetadataFunc(clientName string, clientId int32, pathPrefix string, additionalPathPrefixes []string, lastTsNs *int64, selfSignature int32, processEventFn ProcessMetadataFunc, fatalOnError bool) func(client filer_pb.SeaweedFilerClient) error { return func(client filer_pb.SeaweedFilerClient) error { ctx, cancel := context.WithCancel(context.Background()) |