Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for _Equal (0.12 sec)

  1. pilot/pkg/networking/core/cluster_test.go

    		} else if locality.Region == "region1" && locality.SubZone == "subzone2" {
    			g.Expect(localityLbEndpoint.LoadBalancingWeight.GetValue()).To(Equal(uint32(17)))
    			g.Expect(localityLbEndpoint.LbEndpoints[0].LoadBalancingWeight.GetValue()).To(Equal(uint32(20)))
    		} else if locality.Region == "region2" {
    			g.Expect(localityLbEndpoint.LoadBalancingWeight.GetValue()).To(Equal(uint32(50)))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_test.go

    		ID:        pod.UID,
    		Name:      pod.Name,
    		Namespace: pod.Namespace,
    	}
    	apiStatus := kubelet.generateAPIPodStatus(pod, status, false)
    	require.Equal(t, v1.PodFailed, apiStatus.Phase)
    	require.Equal(t, "Evicted", apiStatus.Reason)
    	require.Equal(t, "because", apiStatus.Message)
    }
    
    func TestSyncTerminatingPodKillPod(t *testing.T) {
    	testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/cluster_builder_test.go

    			// assert httpProtocolOptions
    			assert.Equal(t, opts.mutable.httpProtocolOptions.CommonHttpProtocolOptions.IdleTimeout,
    				tt.expectedHTTPPOpt.CommonHttpProtocolOptions.IdleTimeout)
    			assert.Equal(t, opts.mutable.httpProtocolOptions.CommonHttpProtocolOptions.MaxRequestsPerConnection,
    				tt.expectedHTTPPOpt.CommonHttpProtocolOptions.MaxRequestsPerConnection)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 110.4K bytes
    - Viewed (0)
  4. cmd/object-handlers_test.go

    		if err != nil {
    			t.Fatalf("Test %d: %s: Failed reading response body: <ERROR> %v", i+1, instanceType, err)
    		}
    
    		if rec.Code == http.StatusOK || rec.Code == http.StatusPartialContent {
    			if !bytes.Equal(testCase.expectedContent, actualContent) {
    				t.Errorf("Test %d: %s: Object content differs from expected value %s, got %s", i+1, instanceType, testCase.expectedContent, string(actualContent))
    			}
    			continue
    		}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 161.9K bytes
    - Viewed (0)
  5. cluster/gce/util.sh

      # Each MIG must have at least one node, so the min number of nodes
      # must be greater or equal to the number of migs.
      if [[ ${AUTOSCALER_MIN_NODES} -lt 0 ]]; then
        echo "AUTOSCALER_MIN_NODES must be greater or equal 0"
        exit 2
      fi
    
      # Each MIG must have at least one node, so the min number of nodes
      # must be greater or equal to the number of migs.
      if [[ ${AUTOSCALER_MAX_NODES} -lt ${NUM_MIGS} ]]; then
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 21:47:17 UTC 2024
    - 161.6K bytes
    - Viewed (0)
  6. tensorflow/compiler/mlir/tensorflow/transforms/shape_inference.cc

        // Update the result type of this op with the resource's type. We only use
        // the resource subtype of the first user since shapes from all the users
        // should be equal or compatible.
        return UpdateTypeAndInsertIncompatibleUseCasts(subtype, op->getResult(0));
      }
      return false;
    }
    
    // Helper structure to capture shapes & types for Dataset input.
    struct DatasetInput {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Sat Jun 08 07:28:49 UTC 2024
    - 134.1K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    	}
    
    	// get the object
    	checkobj, err := registry.Get(testContext, podA.Name, &metav1.GetOptions{})
    	if err != nil {
    		t.Errorf("Unexpected error: %v", err)
    	}
    
    	// verify objects are equal
    	if e, a := objA, checkobj; !reflect.DeepEqual(e, a) {
    		t.Errorf("Expected %#v, got %#v", e, a)
    	}
    
    	// now try to create the second pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet.go

    	for _, c := range pod.Spec.Containers {
    		if cs, ok := podutil.GetContainerStatus(podStatus.ContainerStatuses, c.Name); ok {
    			if cs.Resources == nil {
    				continue
    			}
    			if !cmp.Equal(c.Resources.Limits, cs.Resources.Limits) || !cmp.Equal(cs.AllocatedResources, cs.Resources.Requests) {
    				return true
    			}
    		}
    	}
    	return false
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet_pods.go

    	hostname, hostDomainName, err := kl.GeneratePodHostNameAndDomain(pod)
    	if err != nil {
    		return nil, nil, err
    	}
    	// nodename will be equal to hostname if SetHostnameAsFQDN is nil or false. If SetHostnameFQDN
    	// is true and hostDomainName is defined, nodename will be the FQDN (hostname.hostDomainName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  10. cmd/bucket-replication.go

    			rd.Replicate = true
    			return
    		}
    		// For existing object reset - this condition is needed
    		rd.Replicate = tgtStatus == ""
    		return
    	}
    	if resetID == "" || resetBeforeDate.Equal(timeSentinel) { // no reset in progress
    		return
    	}
    
    	// if already replicated, return true if a new reset was requested.
    	splits := strings.SplitN(rs, ";", 2)
    	if len(splits) != 2 {
    		return
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 114.4K bytes
    - Viewed (0)
Back to top