- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Walk (0.14 sec)
-
cmd/metacache-walk.go
if s.walkMu != nil { s.walkMu.Unlock() } if err != nil { // Folder could have gone away in-between if err != errVolumeNotFound && err != errFileNotFound { internalLogOnceIf(ctx, err, "metacache-walk-scan-dir") } if opts.ReportNotFound && err == errFileNotFound && current == opts.BaseDir { err = errFileNotFound } else { err = nil } diskHealthCheckOK(ctx, err) return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
src/cmd/cgo/ast.go
f.walk(n.Body, ctxTypeSwitch, visit) case *ast.CommClause: f.walk(n.Comm, ctxStmt, visit) f.walk(n.Body, ctxStmt, visit) case *ast.SelectStmt: f.walk(n.Body, ctxStmt, visit) case *ast.ForStmt: f.walk(n.Init, ctxStmt, visit) f.walk(&n.Cond, ctxExpr, visit) f.walk(n.Post, ctxStmt, visit) f.walk(n.Body, ctxStmt, visit) case *ast.RangeStmt: f.walk(&n.Key, ctxExpr, visit)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Jun 07 16:54:27 GMT 2023 - 14.3K bytes - Viewed (0) -
cmd/batch-rotate.go
if err != nil { // invalid worker size. return err } retryAttempts := ri.RetryAttempts ctx, cancel := context.WithCancel(ctx) results := make(chan ObjectInfo, 100) if err := api.Walk(ctx, r.Bucket, r.Prefix, results, WalkOptions{ Marker: lastObject, Filter: selectObj, }); err != nil { cancel() // Do not need to retry if we can't list objects on source. return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/object-api-interface.go
ListObjectVersions(ctx context.Context, bucket, prefix, marker, versionMarker, delimiter string, maxKeys int) (result ListObjectVersionsInfo, err error) // Walk lists all objects including versions, delete markers. Walk(ctx context.Context, bucket, prefix string, results chan<- ObjectInfo, opts WalkOptions) error // Object operations. // GetObjectNInfo returns a GetObjectReader that satisfies the
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K bytes - Viewed (0) -
cmd/batch-expire.go
if err != nil { // invalid worker size. return err } ctx, cancel := context.WithCancel(ctx) defer cancel() results := make(chan ObjectInfo, workerSize) if err := api.Walk(ctx, r.Bucket, r.Prefix, results, WalkOptions{ Marker: lastObject, LatestOnly: false, // we need to visit all versions of the object to implement purge: retainVersions VersionsSort: WalkVersionsSortDesc,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
operator/cmd/mesh/manifest-generate_test.go
} outFile.Close() default: return fmt.Errorf("unknown type: %v in %v", header.Typeflag, header.Name) } } return nil } func copyDir(src string, dest string) error { return filepath.Walk(src, func(path string, info fs.FileInfo, err error) error { if err != nil { return err } outpath := filepath.Join(dest, strings.TrimPrefix(path, src)) if info.IsDir() {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 43.5K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
if err != nil { log.Infof("file: %s is not closed: %v", path, err) } warningsByFilename[path] = warning } processDirectory := func(directory string, processFile func(string)) error { err := filepath.Walk(directory, func(path string, info os.FileInfo, err error) error { if err != nil { return err } if info.IsDir() { return nil } if isFileFormatValid(path) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
} }) return local.ReaderSource{Name: f, Reader: r}, nil } func gatherFilesInDirectory(cmd *cobra.Command, dir string) ([]local.ReaderSource, error) { var readers []local.ReaderSource err := filepath.Walk(dir, func(path string, info os.FileInfo, err error) error { if err != nil { return err } // If we encounter a directory, recurse only if the --recursive option
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0) -
cmd/peer-rest-client.go
"github.com/minio/minio/internal/grid" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/rest" xnet "github.com/minio/pkg/v2/net" ) // client to talk to peer Nodes. type peerRESTClient struct { host *xnet.Host restClient *rest.Client gridHost string // Function that returns the grid connection for this peer when initialized.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/peer-s3-client.go
return makeBucketLocal(ctx, bucket, opts) } func (l localPeerS3Client) DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error { return deleteBucketLocal(ctx, bucket, opts) } // client to talk to peer Nodes. type remotePeerS3Client struct { node Node pools []int // Function that returns the grid connection for this peer when initialized. // Will return nil if the grid connection is not initialized yet.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0)