Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for newObject (0.58 sec)

  1. cmd/server-main.go

    				initDataScanner(GlobalContext, newObject)
    			}
    		})
    
    		// Initialize background replication
    		bootstrapTrace("initBackgroundReplication", func() {
    			initBackgroundReplication(GlobalContext, newObject)
    		})
    
    		// Initialize background ILM worker poool
    		bootstrapTrace("initBackgroundExpiry", func() {
    			initBackgroundExpiry(GlobalContext, newObject)
    		})
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 04 15:12:57 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/managedfieldsupdater_test.go

    	}
    
    	updater := internal.NewManagedFieldsUpdater(NoopManager{})
    
    	newObject, _, err := updater.Apply(obj, obj.DeepCopyObject(), managed, "some_manager", false)
    	if err != nil {
    		t.Fatalf("failed to apply configuration %v", err)
    	}
    
    	if newObject == obj {
    		t.Fatalf("returned newObject must not be the same instance as the passed in liveObj")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 13.2K bytes
    - Viewed (0)
  3. pkg/kubelet/util/manager/watch_based_manager.go

    	}
    
    	store := &objectCache{
    		listObject:    listObject,
    		watchObject:   watchObject,
    		newObject:     newObject,
    		isImmutable:   isImmutable,
    		groupResource: groupResource,
    		clock:         clock,
    		maxIdleTime:   maxIdleTime,
    		items:         make(map[objectKey]*objectCacheItem),
    	}
    
    	go wait.Until(store.startRecycleIdleWatch, time.Minute, stopCh)
    	go store.shutdownWhenStopped(stopCh)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  4. platforms/core-configuration/declarative-dsl-core/src/main/kotlin/org/gradle/internal/declarativedsl/mappingToJvm/DeclarativeReflectionToObjectConverter.kt

        private
        fun objectByIdentity(key: ObjectAccessKey, newObject: () -> Any?): Any? {
            // This code does not use `computeIfAbsent` because `newObject` can make reentrant calls, leading to CME.
            // Also, it does not check for the value being null, because null values are potentially allowed
            if (key !in reflectionIdentityObjects) {
                val newInstance = newObject()
                reflectionIdentityObjects[key] = newInstance
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 21 14:27:23 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  5. test/live.go

    func f27go(b bool) {
    	x := 0
    	if b {
    		go call27(func() { x++ }) // ERROR "live at call to newobject: &x$" "live at call to newobject: &x .autotmp_[0-9]+$" "live at call to newproc: &x$" // allocate two closures, the func literal, and the wrapper for go
    	}
    	go call27(func() { x++ }) // ERROR "live at call to newobject: &x$" "live at call to newobject: .autotmp_[0-9]+$" // allocate two closures, the func literal, and the wrapper for go
    	printnl()
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Dec 05 20:34:30 UTC 2023
    - 18K bytes
    - Viewed (0)
  6. test/live_regabi.go

    func f27go(b bool) {
    	x := 0
    	if b {
    		go call27(func() { x++ }) // ERROR "live at call to newobject: &x$" "live at call to newobject: &x .autotmp_[0-9]+$" "live at call to newproc: &x$" // allocate two closures, the func literal, and the wrapper for go
    	}
    	go call27(func() { x++ }) // ERROR "live at call to newobject: &x$" "live at call to newobject: .autotmp_[0-9]+$" // allocate two closures, the func literal, and the wrapper for go
    	printnl()
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Dec 05 20:34:30 UTC 2023
    - 18.4K bytes
    - Viewed (0)
  7. common-protos/k8s.io/api/admissionregistration/v1beta1/generated.proto

      // object has matching labels. objectSelector is evaluated against both
      // the oldObject and newObject that would be sent to the webhook, and
      // is considered to match if either object matches the selector. A null
      // object (oldObject in the case of create, or newObject in the case of
      // delete) or an object that cannot have labels (like a
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/admissionregistration/v1/generated.proto

      // object has matching labels. objectSelector is evaluated against both
      // the oldObject and newObject that would be sent to the webhook, and
      // is considered to match if either object matches the selector. A null
      // object (oldObject in the case of create, or newObject in the case of
      // delete) or an object that cannot have labels (like a
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/admissionregistration/v1beta1/types_swagger_doc_generated.go

        "ObjectSelector decides whether to run the validation based on if the object has matching labels. objectSelector is evaluated against both the oldObject and newObject that would be sent to the cel validation, and is considered to match if either object matches the selector. A null object (oldObject in the case of create, or newObject in the case of delete) or an object that cannot have labels (like a DeploymentRollback or a PodProxyOptions object) is not considered to match. Use the object selector...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 20:14:19 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  10. pkg/registry/flowcontrol/ensurer/strategy.go

    	}
    
    	klog.V(5).InfoS(fmt.Sprintf("The %s already exists, checking whether it is up to date", bootstrap.GetObjectKind().GroupVersionKind().Kind), "type", configurationType, "name", name)
    	newObject, update, err := strategy.ReviseIfNeeded(ops, current, bootstrap)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 14K bytes
    - Viewed (0)
Back to top