- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 42 for getCond (0.15 sec)
-
pilot/pkg/xds/ads.go
// can still help provide some client-side Envoy context when load balancing based on location. proxy.Locality = &core.Locality{ Region: proxy.XdsNode.Locality.GetRegion(), Zone: proxy.XdsNode.Locality.GetZone(), SubZone: proxy.XdsNode.Locality.GetSubZone(), } } // add topology labels to proxy labels proxy.Labels = labelutil.AugmentLabels( proxy.Labels, proxy.Metadata.ClusterID,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
platforms/extensibility/plugin-development/src/integTest/groovy/org/gradle/plugin/devel/tasks/AbstractPluginValidationIntegrationSpec.groovy
@DisableCachingByDefault(because = "test task") public class MyTask extends DefaultTask { // Should be ignored because it's not a getter public void getVoid() { } // Should be ignored because it's not a getter public int getWithParameter(int count) { return count; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 09:03:53 UTC 2024 - 40.7K bytes - Viewed (0) -
src/net/http/transport_test.go
if chunked { w.(Flusher).Flush() } w.Write(rgz) // arbitrary gzip response })).ts c := ts.Client() trace := &httptrace.ClientTrace{ GetConn: func(hostPort string) { t.Logf("GetConn(%q)", hostPort) }, GotConn: func(ci httptrace.GotConnInfo) { t.Logf("GotConn(%+v)", ci) }, PutIdleConn: func(err error) { t.Logf("PutIdleConn(%v)", err) },
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
/** * The number of milliseconds that tests are permitted for execution without being reported, when * profileTests is set. */ private static final long profileThreshold = Long.getLong("jsr166.profileThreshold", 100); @Override protected void runTest() throws Throwable { if (profileTests) runTestProfiled(); else super.runTest(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
node.ObjectMeta.Labels[v1.LabelInstanceTypeStable] = instanceType } // If the cloud has zone information, label the node with the zone information zones, ok := kl.cloud.Zones() if ok { zone, err := zones.GetZone(ctx) if err != nil { return nil, fmt.Errorf("failed to get zone from cloud provider: %v", err) } if zone.FailureDomain != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
for _, fwk := range scheduler.Profiles { actualPodNamesInWaitingPods := sets.NewString() fwk.IterateOverWaitingPods(func(pod framework.WaitingPod) { actualPodNamesInWaitingPods.Insert(pod.GetPod().Name) }) // Validate the name of pods in waitingPods matches expectations. if actualPodNamesInWaitingPods.Len() != len(tc.expectPodNamesInWaitingPods) ||
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
guava/src/com/google/common/net/InetAddresses.java
addressAsLong = getEmbeddedIPv4ClientAddress(ip6).hashCode(); } else { // Just extract the high 64 bits (assuming the rest is user-modifiable). addressAsLong = ByteBuffer.wrap(ip6.getAddress(), 0, 8).getLong(); } // Many strategies for hashing are possible. This might suffice for now. int coercedHash = Hashing.murmur3_32_fixed().hashLong(addressAsLong).asInt();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 24 16:44:05 UTC 2024 - 47.1K bytes - Viewed (0) -
android/guava/src/com/google/common/net/InetAddresses.java
addressAsLong = getEmbeddedIPv4ClientAddress(ip6).hashCode(); } else { // Just extract the high 64 bits (assuming the rest is user-modifiable). addressAsLong = ByteBuffer.wrap(ip6.getAddress(), 0, 8).getLong(); } // Many strategies for hashing are possible. This might suffice for now. int coercedHash = Hashing.murmur3_32_fixed().hashLong(addressAsLong).asInt();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 24 16:44:05 UTC 2024 - 47.1K bytes - Viewed (0) -
pkg/config/validation/validation.go
continue } // nolint: staticcheck if i.Port.TargetPort > 0 { errs = AppendValidation(errs, fmt.Errorf("targetPort has no impact on Sidecars")) } bind := i.GetBind() errs = AppendValidation(errs, validateSidecarIngressPortAndBind(i.Port, bind)) if portMap.Contains(i.Port.Number) { errs = AppendValidation(errs, fmt.Errorf("sidecar: ports on IP bound listeners must be unique"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
pkg/workloadapi/workload.pb.go
return file_workloadapi_workload_proto_rawDescGZIP(), []int{4} } func (x *Locality) GetRegion() string { if x != nil { return x.Region } return "" } func (x *Locality) GetZone() string { if x != nil { return x.Zone } return "" } func (x *Locality) GetSubzone() string { if x != nil { return x.Subzone } return "" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 65.9K bytes - Viewed (0)