- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 311 for newLru (0.19 sec)
-
pilot/pkg/model/typed_xds_cache.go
evictedOnClear bool } var _ typedXdsCache[uint64] = &lruCache[uint64]{} func newLru[K comparable](evictCallback simplelru.EvictCallback[K, cacheValue]) simplelru.LRUCache[K, cacheValue] { sz := features.XDSCacheMaxSize if sz <= 0 { sz = 20000 } l, err := simplelru.NewLRU(sz, evictCallback) if err != nil { panic(fmt.Errorf("invalid lru configuration: %v", err)) } return l }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 11K bytes - Viewed (0) -
cmd/jwt.go
errMalformedAuth = errors.New("Malformed authentication input") ) type cacheKey struct { accessKey, secretKey, audience string } var cacheLRU = expirable.NewLRU[cacheKey, string](1000, nil, 15*time.Second) func authenticateNode(accessKey, secretKey, audience string) (string, error) { claims := xjwt.NewStandardClaims() claims.SetExpiry(UTCNow().Add(defaultInterNodeJWTExpiry))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/controller/deployment/sync.go
Template: newRSTemplate, }, } allRSs := append(oldRSs, &newRS) newReplicasCount, err := deploymentutil.NewRSNewReplicas(d, allRSs, &newRS) if err != nil { return nil, err } *(newRS.Spec.Replicas) = newReplicasCount // Set new replica set's annotation deploymentutil.SetNewReplicaSetAnnotations(ctx, d, &newRS, newRevision, false, maxRevHistoryLengthInChars)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 24.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresourcedefinition/strategy.go
if !apiequality.Semantic.DeepEqual(oldCRD.Spec, newCRD.Spec) { newCRD.Generation = oldCRD.Generation + 1 } for _, v := range newCRD.Spec.Versions { if v.Storage { if !apiextensions.IsStoredVersion(newCRD, v.Name) { newCRD.Status.StoredVersions = append(newCRD.Status.StoredVersions, v.Name) } break } } dropDisabledFields(newCRD, oldCRD) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 10.3K bytes - Viewed (0) -
src/cmd/fix/main.go
// output of the printer run on a mangled AST generated by a fixer. newSrc, err = gofmtFile(newFile) if err != nil { return err } if *doDiff { os.Stdout.Write(diff.Diff(filename, src, "fixed/"+filename, newSrc)) return nil } if useStdin { os.Stdout.Write(newSrc) return nil } return os.WriteFile(f.Name(), newSrc, 0) } func gofmt(n any) string {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 5.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/DuplicateHostHelper.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/kube/inject/app_probe.go
func convertAppProber(probe *corev1.Probe, newURL string, statusPort int) *corev1.Probe { if probe == nil { return nil } if probe.HTTPGet != nil { return convertAppProberHTTPGet(probe, newURL, statusPort) } else if probe.TCPSocket != nil { return convertAppProberTCPSocket(probe, newURL, statusPort) } else if probe.GRPC != nil { return convertAppProberGRPC(probe, newURL, statusPort) } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Aug 04 15:06:24 UTC 2023 - 8.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/common/values.go
return types.NullValue } return types.NewErr("invalid data, got null for schema with nullable=false") } if schema.IsXIntOrString() { switch v := unstructured.(type) { case string: return types.String(v) case int: return types.Int(v) case int32: return types.Int(v) case int64: return types.Int(v) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:30:17 UTC 2023 - 20.5K bytes - Viewed (0) -
pkg/controller/deployment/rolling.go
// Sync deployment status return dc.syncRolloutStatus(ctx, allRSs, newRS, d) } func (dc *DeploymentController) reconcileNewReplicaSet(ctx context.Context, allRSs []*apps.ReplicaSet, newRS *apps.ReplicaSet, deployment *apps.Deployment) (bool, error) { if *(newRS.Spec.Replicas) == *(deployment.Spec.Replicas) { // Scaling not required. return false, nil } if *(newRS.Spec.Replicas) > *(deployment.Spec.Replicas) { // Scale down.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 07:09:11 UTC 2023 - 9.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/PathMappingHelper.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 7.6K bytes - Viewed (0)