- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 47 for index (0.05 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
} if chanSize > maxChanSize { chanSize = maxChanSize } return chanSize } // isIndexValidLocked checks if a given index is still valid. // This assumes that the lock is held. func (w *watchCache) isIndexValidLocked(index int) bool { return index >= w.startIndex } // getAllEventsSinceLocked returns a watchCacheInterval that can be used to
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
cmd/object-api-utils.go
} } partSkip = offset - skipLength // Load index and skip more if feasible. if partSkip > 0 && len(oi.Parts) > firstPartIdx && len(oi.Parts[firstPartIdx].Index) > 0 { _, isEncrypted := crypto.IsEncrypted(oi.UserDefined) if isEncrypted { dec, err := decrypt(oi.Parts[firstPartIdx].Index) if err == nil { // Load Index var idx s2.Index _, err := idx.Load(s2.RestoreIndexHeaders(dec))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 36.3K bytes - Viewed (0) -
cmd/bucket-listobjects-handlers.go
return subToken, false } func proxyRequestByNodeIndex(ctx context.Context, w http.ResponseWriter, r *http.Request, index int) (success bool) { if len(globalProxyEndpoints) == 0 { return false } if index < 0 || index >= len(globalProxyEndpoints) { return false } ep := globalProxyEndpoints[index] if ep.IsLocal { return false } return proxyRequest(ctx, w, r, ep) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/apis/resource/validation/validation_resourceclaim_test.go
field.Required(field.NewPath("status", "allocation", "resourceHandles").Index(0).Child("structuredData", "results").Index(1), "exactly one structured model field must be set"), }, oldClaim: validClaim, update: func(claim *resource.ResourceClaim) *resource.ResourceClaim { claim.Status.DriverName = "valid" claim.Status.Allocation = &resource.AllocationResult{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 09:18:10 UTC 2024 - 28.7K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
type EndpointIndexUpdater struct { Index *EndpointIndex // Optional; if set, we will trigger ConfigUpdates in response to EDS updates as appropriate ConfigUpdateFunc func(req *PushRequest) } var _ XDSUpdater = &EndpointIndexUpdater{} func NewEndpointIndexUpdater(ei *EndpointIndex) *EndpointIndexUpdater { return &EndpointIndexUpdater{Index: ei} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
scan.go
} for initialized || rows.Next() { BEGIN: initialized = false if update { if int(db.RowsAffected) >= reflectValue.Len() { return } elem = reflectValue.Index(int(db.RowsAffected)) if onConflictDonothing { for _, field := range fields { if _, ok := field.ValueOf(db.Statement.Context, elem); !ok { db.RowsAffected++ goto BEGIN }
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 10:57:36 UTC 2024 - 10K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
// // e.g /path/to/archive.zip/backup-2021/myimage.png => /path/to/archive.zip, backup/myimage.png func splitZipExtensionPath(input string) (zipPath, object string, err error) { idx := strings.Index(input, archivePattern) if idx < 0 { // Should never happen return "", "", errors.New("unable to parse zip path") } return input[:idx+len(archivePattern)-1], input[idx+len(archivePattern):], nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.8K bytes - Viewed (0) -
src/cmd/compile/internal/liveness/plive.go
index-- } // Update liveness information. pos, e := lv.valueEffects(v) if e&varkill != 0 { liveout.Unset(pos) } if e&uevar != 0 { liveout.Set(pos) } } if b == lv.f.Entry { if index != 0 { base.Fatalf("bad index for entry point: %v", index) } // Check to make sure only input variables are live. for i, n := range lv.vars {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 15:22:22 UTC 2024 - 45.2K bytes - Viewed (0) -
cmd/metacache-entries.go
func (e metaCacheEntry) isInDir(dir, separator string) bool { if len(dir) == 0 { // Root idx := strings.Index(e.name, separator) return idx == -1 || idx == len(e.name)-len(separator) } ext := strings.TrimPrefix(e.name, dir) if len(ext) != len(e.name) { idx := strings.Index(ext, separator) // If separator is not found or is last entry, ok. return idx == -1 || idx == len(ext)-len(separator) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 04:34:26 UTC 2024 - 24K bytes - Viewed (0) -
cmd/api-response.go
for index, commonPrefix := range multipartsInfo.CommonPrefixes { listMultipartUploadsResponse.CommonPrefixes[index] = CommonPrefix{ Prefix: s3EncodeName(commonPrefix, encodingType), } } listMultipartUploadsResponse.Uploads = make([]Upload, len(multipartsInfo.Uploads)) for index, upload := range multipartsInfo.Uploads { newUpload := Upload{}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 33.5K bytes - Viewed (0)