- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 162 for newLru (0.3 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) -
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/controller/status/naming_controller_test.go
name: "first resource", in: newCRD("alfa.bravo.com").NewOrDie(), existing: []*apiextensionsv1.CustomResourceDefinition{}, expectedNames: apiextensionsv1.CustomResourceDefinitionNames{ Plural: "alfa", }, expectedNameConflictCondition: acceptedCondition, expectedEstablishedCondition: installingCondition, }, { name: "different groups",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 03 16:49:27 UTC 2019 - 15.7K 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) -
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) -
pkg/kubelet/lifecycle/handlers_test.go
} if fakeHTTPDoer.url != expectedURL { t.Errorf("url = %v; want %v", fakeHTTPDoer.url, tt.Expected.NewURL) } } t.Run("consistent", func(t *testing.T) { verify(t, tt.Expected.NewHeader, tt.Expected.NewURL) }) }) } } func TestRunHandlerNil(t *testing.T) { ctx := context.Background()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/controller/deployment/progress_test.go
fake := fake.Clientset{} dc := &DeploymentController{ client: &fake, } if test.newRS != nil { test.allRSs = append(test.allRSs, test.newRS) } _, ctx := ktesting.NewTestContext(t) err := dc.syncRolloutStatus(ctx, test.allRSs, test.newRS, test.d) if err != nil { t.Error(err) } newCond := util.GetDeploymentCondition(test.d.Status, test.conditionType)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
newCRD := newObj.(*apiextensionsv1.CustomResourceDefinition) // only queue deleted things that haven't been finalized by us if newCRD.DeletionTimestamp.IsZero() || !apiextensionshelpers.CRDHasFinalizer(newCRD, apiextensionsv1.CustomResourceCleanupFinalizer) { return } // always requeue resyncs just in case if oldCRD.ResourceVersion == newCRD.ResourceVersion { c.enqueue(newCRD)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
pkg/controller/deployment/rolling_test.go
oldSelector := map[string]string{"foo": "old"} newRS := rs("foo-new", test.newReplicas, newSelector, noTimestamp) newRS.Status.AvailableReplicas = int32(test.readyPodsFromNewRS) oldRS := rs("foo-old", test.oldReplicas, oldSelector, noTimestamp) oldRS.Status.AvailableReplicas = int32(test.readyPodsFromOldRS) oldRSs := []*apps.ReplicaSet{oldRS} allRSs := []*apps.ReplicaSet{oldRS, newRS} maxSurge := intstr.FromInt32(0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 09:10:50 UTC 2023 - 11K bytes - Viewed (0)