aboutsummaryrefslogtreecommitdiff
path: root/weed/remote_storage/track_sync_offset.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/remote_storage/track_sync_offset.go')
-rw-r--r--weed/remote_storage/track_sync_offset.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/remote_storage/track_sync_offset.go b/weed/remote_storage/track_sync_offset.go
index 2dfb6d784..439491d12 100644
--- a/weed/remote_storage/track_sync_offset.go
+++ b/weed/remote_storage/track_sync_offset.go
@@ -13,7 +13,7 @@ const (
SyncKeyPrefix = "remote.sync."
)
-func GetSyncOffset(grpcDialOption grpc.DialOption, filer string, dir string) (lastOffsetTsNs int64, readErr error) {
+func GetSyncOffset(grpcDialOption grpc.DialOption, filer pb.ServerAddress, dir string) (lastOffsetTsNs int64, readErr error) {
dirHash := uint32(util.HashStringToLong(dir))
@@ -42,7 +42,7 @@ func GetSyncOffset(grpcDialOption grpc.DialOption, filer string, dir string) (la
}
-func SetSyncOffset(grpcDialOption grpc.DialOption, filer string, dir string, offsetTsNs int64) error {
+func SetSyncOffset(grpcDialOption grpc.DialOption, filer pb.ServerAddress, dir string, offsetTsNs int64) error {
dirHash := uint32(util.HashStringToLong(dir))