Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 1,035 for updateIPs (0.85 sec)

  1. pkg/scheduler/internal/cache/interface.go

    	// UpdateNode updates overall information about node.
    	// It returns a clone of updated NodeInfo object.
    	UpdateNode(logger klog.Logger, oldNode, newNode *v1.Node) *framework.NodeInfo
    
    	// RemoveNode removes overall information about node.
    	RemoveNode(logger klog.Logger, node *v1.Node) error
    
    	// UpdateSnapshot updates the passed infoSnapshot to the current contents of Cache.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  2. releasenotes/notes/46267.yaml

    apiVersion: release-notes/v2
    kind: feature
    area: traffic-management
    issue:
      - 46267
    
    releaseNotes:
    - |
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 01 18:39:13 UTC 2023
    - 237 bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AtomicDoubleArray.java

       * @return the updated value
       */
      @CanIgnoreReturnValue
      public double addAndGet(int i, double delta) {
        return accumulateAndGet(i, delta, Double::sum);
      }
    
      /**
       * Atomically updates the element at index {@code i} with the results of applying the given
       * function to the current and given values.
       *
       * @param i the index to update
       * @param x the update value
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.2K bytes
    - Viewed (0)
  4. pkg/registry/apps/statefulset/strategy_test.go

    		if len(errs) != 0 {
    			t.Errorf("should ignore updates to PersistentVolumeClaimRetentionPolicyType")
    		}
    	})
    
    	validPs.Spec.Selector = &metav1.LabelSelector{MatchLabels: map[string]string{"a": "bar"}}
    	Strategy.PrepareForUpdate(ctx, validPs, ps)
    	errs = Strategy.ValidateUpdate(ctx, validPs, ps)
    	if len(errs) == 0 {
    		t.Errorf("expected a validation error since updates are disallowed on statefulsets.")
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/hash/HashingInputStream.java

       * byte read.
       */
      @Override
      @CanIgnoreReturnValue
      public int read() throws IOException {
        int b = in.read();
        if (b != -1) {
          hasher.putByte((byte) b);
        }
        return b;
      }
    
      /**
       * Reads the specified bytes of data from the underlying input stream and updates the hasher with
       * the bytes read.
       */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 20 18:43:59 UTC 2021
    - 3K bytes
    - Viewed (0)
  6. tensorflow/compiler/mlir/tensorflow/transforms/decompose_resource_ops.td

    def DecomposeResourceScatterAdd : Pat<
      (TF_ResourceScatterAddOp:$src_op $resource, $indices, $updates),
      (TF_AssignVariableOp
        $resource,
        (TF_TensorScatterAddOp
          (CreateTFReadVariableOp $src_op, $updates, $resource),
          (TF_ExpandDimsOp $indices,
           (TF_ConstOp (GetScalarOfType<-1> $indices))),
          $updates
        ),
        (CreateConstBoolAttrFalse)
      )>;
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed May 22 19:47:48 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  7. pilot/pkg/autoregistration/controller.go

    // of workloads, such as auto-registration, health status updates, etc.
    //
    // If connecting proxy represents a workload that is using auto-registration, it will
    // create a WorkloadEntry resource automatically and be ready to receive health status
    // updates.
    //
    // If connecting proxy represents a workload that is not using auto-registration,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 00:00:36 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/configuration/validating_webhook_manager_test.go

    		finalNumberOfWebhookAccessors int
    	}{
    		{
    			name: "no creations and no updates",
    			args: args{
    				nil,
    				nil,
    			},
    			numberOfCreations:             0,
    			numberOfRefreshes:             0,
    			finalNumberOfWebhookAccessors: 0,
    		},
    		{
    			name: "create configurations and no updates",
    			args: args{
    				[]*v1.ValidatingWebhookConfiguration{
    					{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 15:20:14 UTC 2023
    - 9K bytes
    - Viewed (0)
  9. pkg/controller/endpointslice/endpointslice_controller_test.go

    		batchPeriod      time.Duration
    		podsCount        int
    		updates          []podUpdate
    		finalDelay       time.Duration
    		wantRequestCount int
    	}{
    		{
    			name:        "three updates with no batching",
    			batchPeriod: 0 * time.Second,
    			podsCount:   10,
    			updates: []podUpdate{
    				{
    					// endpoints.Run needs ~100 ms to start processing updates.
    					delay:   200 * time.Millisecond,
    					podName: "pod0",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/audit/metrics.go

    	legacyregistry.MustRegister(levelCounter)
    	legacyregistry.MustRegister(ApiserverAuditDroppedCounter)
    }
    
    // ObserveEvent updates the relevant prometheus metrics for the generated audit event.
    func ObserveEvent(ctx context.Context) {
    	eventCounter.WithContext(ctx).Inc()
    }
    
    // ObservePolicyLevel updates the relevant prometheus metrics with the audit level for a request.
    func ObservePolicyLevel(ctx context.Context, level auditinternal.Level) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 13 00:46:24 UTC 2021
    - 3.6K bytes
    - Viewed (0)
Back to top