use %w fmt.Errorf

weed/filer/abstract_sql/abstract_sql_store.go

@@ -328,7 +328,7 @@ func (store *AbstractSqlStore) ListDirectoryPrefixedEntries(ctx context.Context,
 
 		resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 		if resEachEntryFuncErr != nil {
-			err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+			err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 			break
 		}
 
@@ -338,7 +338,7 @@ func (store *AbstractSqlStore) ListDirectoryPrefixedEntries(ctx context.Context,
 
 	}
 
-	return lastFileName, nil
+	return lastFileName, err
 }
 
 func (store *AbstractSqlStore) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error) {

weed/filer/arangodb/arangodb_store.go

@@ -337,7 +337,7 @@ sort d.name asc
 
 		resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 		if resEachEntryFuncErr != nil {
-			err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+			err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 			break
 		}
 

weed/filer/etcd/etcd_store.go

@@ -215,7 +215,7 @@ func (store *EtcdStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPat
 
 		resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 		if resEachEntryFuncErr != nil {
-			err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+			err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 			break
 		}
 

weed/filer/filerstore_wrapper.go

@@ -310,7 +310,7 @@ func (fsw *FilerStoreWrapper) prefixFilterEntries(ctx context.Context, dirPath u
 				res, resErr := eachEntryFunc(entry)
 
 				if resErr != nil {
-					err = fmt.Errorf("Failed in process eachEntryFnc: %v", resErr)
+					err = fmt.Errorf("failed to process eachEntryFunc: %w", resErr)
 					return
 				}
 

weed/filer/hbase/hbase_store.go

@@ -210,7 +210,7 @@ func (store *HbaseStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPa
 
 		resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 		if resEachEntryFuncErr != nil {
-			err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+			err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 			break
 		}
 
@@ -219,7 +219,7 @@ func (store *HbaseStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPa
 		}
 	}
 
-	return lastFileName, nil
+	return lastFileName, err
 }
 
 func (store *HbaseStore) BeginTransaction(ctx context.Context) (context.Context, error) {

weed/filer/leveldb/leveldb_store.go

@@ -212,7 +212,7 @@ func (store *LevelDBStore) ListDirectoryPrefixedEntries(ctx context.Context, dir
 
 		resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 		if resEachEntryFuncErr != nil {
-			err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+			err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 			break
 		}
 

weed/filer/leveldb2/leveldb2_store.go

@@ -219,7 +219,7 @@ func (store *LevelDB2Store) ListDirectoryPrefixedEntries(ctx context.Context, di
 
 		resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 		if resEachEntryFuncErr != nil {
-			err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+			err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 			break
 		}
 

weed/filer/leveldb3/leveldb3_store.go

@@ -348,7 +348,7 @@ func (store *LevelDB3Store) ListDirectoryPrefixedEntries(ctx context.Context, di
 
 		resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 		if resEachEntryFuncErr != nil {
-			err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+			err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 			break
 		}
 

weed/filer/mongodb/mongodb_store.go

@@ -321,7 +321,7 @@ func (store *MongodbStore) ListDirectoryPrefixedEntries(ctx context.Context, dir
 
 		resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 		if resEachEntryFuncErr != nil {
-			err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+			err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 			break
 		}
 

weed/filer/redis/universal_redis_store.go

@@ -194,7 +194,7 @@ func (store *UniversalRedisStore) ListDirectoryEntries(ctx context.Context, dirP
 
 			resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 			if resEachEntryFuncErr != nil {
-				err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+				err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 				break
 			}
 

weed/filer/redis2/universal_redis_store.go

@@ -209,7 +209,7 @@ func (store *UniversalRedis2Store) ListDirectoryEntries(ctx context.Context, dir
 
 			resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 			if resEachEntryFuncErr != nil {
-				err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+				err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 				break
 			}
 

weed/filer/redis3/universal_redis_store.go

@@ -167,7 +167,7 @@ func (store *UniversalRedis3Store) ListDirectoryEntries(ctx context.Context, dir
 
 			resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 			if resEachEntryFuncErr != nil {
-				err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+				err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 			}
 
 			if !resEachEntryFunc {

weed/filer/redis_lua/universal_redis_store.go

@@ -176,7 +176,7 @@ func (store *UniversalRedisLuaStore) ListDirectoryEntries(ctx context.Context, d
 
 			resEachEntryFunc, resEachEntryFuncErr := eachEntryFunc(entry)
 			if resEachEntryFuncErr != nil {
-				err = fmt.Errorf("Failed in process eachEntryFnc: %v", resEachEntryFuncErr)
+				err = fmt.Errorf("failed to process eachEntryFunc: %w", resEachEntryFuncErr)
 				break
 			}