- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for itemOrErr (0.83 sec)
-
cmd/iam-object-store.go
ch := make(chan itemOrErr[string]) go func() { defer xioutil.SafeClose(ch) // Allocate new results channel to receive ObjectInfo. objInfoCh := make(chan itemOrErr[ObjectInfo]) if err := objAPI.Walk(ctx, minioMetaBucket, pathPrefix, objInfoCh, WalkOptions{}); err != nil { select { case ch <- itemOrErr[string]{Err: err}: case <-ctx.Done():
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 19.5K bytes - Viewed (0) -
cmd/batch-handlers.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0) -
cmd/batch-rotate.go
wk, err := workers.New(workerSize) if err != nil { // invalid worker size. return err } retryAttempts := ri.RetryAttempts ctx, cancel := context.WithCancel(ctx) results := make(chan itemOrErr[ObjectInfo], 100) if err := api.Walk(ctx, r.Bucket, r.Prefix, results, WalkOptions{ Marker: lastObject, Filter: selectObj, }); err != nil { cancel()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/object-api-interface.go
// Walk lists all objects including versions, delete markers. Walk(ctx context.Context, bucket, prefix string, results chan<- itemOrErr[ObjectInfo], opts WalkOptions) error // Object operations. // GetObjectNInfo returns a GetObjectReader that satisfies the // ReadCloser interface. The Close method runs any cleanup
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 20:27:52 UTC 2024 - 17K bytes - Viewed (0) -
cmd/batch-expire.go
} wk, err := workers.New(workerSize) if err != nil { // invalid worker size. return err } ctx, cancel := context.WithCancel(ctx) defer cancel() results := make(chan itemOrErr[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
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 13:50:53 UTC 2024 - 21.1K bytes - Viewed (0) -
cmd/erasure-server-pool.go
sentErr := false sendErr := func(err error) { if !sentErr { select { case results <- itemOrErr[ObjectInfo]{Err: err}: sentErr = true case <-parentCtx.Done(): } } } send := func(oi ObjectInfo) bool { select { case results <- itemOrErr[ObjectInfo]{Item: oi}: return true case <-ctx.Done(): sendErr(context.Cause(ctx)) return false
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
cmd/utils.go
select { case <-ctx.Done(): return ctx.Err() case <-time.After(d): } return nil } // helper type to return either item or error. type itemOrErr[V any] struct { Item V Err error } func filterStorageClass(ctx context.Context, s string) string { // Veeam 14.0 and later clients are not compatible with custom storage classes.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 22:00:34 UTC 2024 - 31.9K bytes - Viewed (0) -
cmd/bucket-replication.go
s.markStatus(resyncStatus, opts, objectAPI) globalSiteResyncMetrics.incBucket(opts, resyncStatus) s.workerCh <- struct{}{} }() // Allocate new results channel to receive ObjectInfo. objInfoCh := make(chan itemOrErr[ObjectInfo]) cfg, err := getReplicationConfig(ctx, opts.bucket) if err != nil { replLogIf(ctx, fmt.Errorf("replication resync of %s for arn %s failed with %w", opts.bucket, opts.arn, err)) return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0)