Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 162 for newLru (0.3 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top