- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 39 for ruleset (0.15 sec)
-
cmd/erasure-server-pool-rebalance.go
err := z.saveRebalanceStats(GlobalContext, poolIdx, rebalSaveStats) stopFn(err) rebalanceLogIf(GlobalContext, err) if quit { return } timer.Reset(randSleepFor()) } }() rebalanceLogEvent(ctx, "Pool %d rebalancing is started", poolIdx+1) for { select { case <-ctx.Done(): doneCh <- ctx.Err() return default: }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
internal/bucket/lifecycle/rule.go
return errXMLNotWellFormed } return nil } // CloneNonTransition - returns a clone of the object containing non transition rules func (r Rule) CloneNonTransition() Rule { return Rule{ XMLName: r.XMLName, ID: r.ID, Status: r.Status, Filter: r.Filter,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/data-scanner_test.go
workers := globalExpiryState.workers.Load() for t := range (*workers)[0] { if t, ok := t.(newerNoncurrentTask); ok { expired = append(expired, t.versions...) } } }() lc := lifecycle.Lifecycle{ Rules: []lifecycle.Rule{ { ID: "max-versions", Status: "Enabled", NoncurrentVersionExpiration: lifecycle.NoncurrentVersionExpiration{ NewerNoncurrentVersions: 1, }, }, }, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
cmd/bucket-targets.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/update.go
} else { return nil, nil, fmt.Errorf("unsupported protocol scheme: %s", u.Scheme) } defer xhttp.DrainBody(reader) b := bytebufferpool.Get() bc := bytebufferpool.Get() defer func() { b.Reset() bc.Reset() bytebufferpool.Put(b) bytebufferpool.Put(bc) }() w, err := zstd.NewWriter(bc) if err != nil { return nil, nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/erasure-object.go
if r == nil { onlineDisks[i] = OfflineDisk } } // Track total bytes read from disk and written to the client. totalBytesRead += partLength // partOffset will be valid only for the first part, hence reset it to 0 for // the remaining parts. partOffset = 0 } // End of read all parts loop. // Return success. return nil } // GetObjectInfo - reads object metadata and replies back ObjectInfo.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/erasure-server-pool.go
return nil, err } // This is a special call attempted first to check for SOS-API calls. gr, err = veeamSOSAPIGetObject(ctx, bucket, object, rs, opts) if err == nil { return gr, nil } // reset any error to 'nil' and any reader to be 'nil' gr = nil err = nil object = encodeDirObject(object) if z.SinglePool() { return z.serverPools[0].GetObjectNInfo(ctx, bucket, object, rs, h, opts) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/object-handlers.go
} if s3Error := authorizeRequest(ctx, r, policy.GetObjectAction); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } if !proxy.Proxy { // apply lifecycle rules only for local requests // Automatically remove the object/version if an expiry lifecycle rule can be applied if lc, err := globalLifecycleSys.Get(bucket); err == nil { rcfg, err := globalBucketObjectLockSys.Get(bucket)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/iam.go
sys.updateGroupMembershipsForLDAP(ctx) } if sys.OpenIDConfig.ProviderEnabled() { sys.purgeExpiredCredentialsForExternalSSO(ctx) } } timer.Reset(waitInterval()) case <-ctx.Done(): return } } } func (sys *IAMSys) validateAndAddRolePolicyMappings(ctx context.Context, m map[arn.ARN]string) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
internal/bucket/lifecycle/lifecycle_test.go
rules[5], }, }, opts: ObjectOpts{ IsLatest: true, UserTags: "key1=val1", Name: "obj-1", Size: 1*humanize.MiByte - 1, }, hasRules: true, }, { // PUT version with size based filters lc: Lifecycle{ Rules: []Rule{ rules[1], rules[2], rules[3], rules[4], rules[5], }, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 53.2K bytes - Viewed (0)