- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for getThing (0.37 sec)
-
platforms/core-configuration/model-core/src/test/groovy/org/gradle/internal/instantiation/generator/AsmBackedClassGeneratorTest.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 74.6K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/test/groovy/org/gradle/api/internal/provider/MapPropertySpec.groovy
"getOrNull" | _ "getOrElse" | _ } def "runs side effect when getting #description"() { def valueSideEffect = Mock(ValueSupplier.SideEffect) when: property.put("some key", Providers.of("some value").withSideEffect(valueSideEffect)) def valueProvider = property.getting(key) then: 0 * _ // no side effects until values are unpacked
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 17 11:41:55 UTC 2024 - 58.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/service/DefaultServiceRegistryTest.groovy
then: 1 * service3.close() } def "cannot add provider after getting a service via class"() { when: registry.get(Integer) registry.addProvider(new TestProvider()) then: thrown IllegalStateException } def "cannot add provider after getting a service via type"() { when: registry.get(Integer as Type)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:53:25 UTC 2024 - 59.8K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2_test.go
} job.UID = "1234" job.Namespace = cj.Namespace if tc.stillActive { ref, err := getRef(job) if err != nil { t.Fatalf("%s: unexpected error getting the job object reference: %v", name, err) } if tc.jobPresentInCJActiveStatus { cj.Status.Active = []v1.ObjectReference{*ref} } realCJ.Status.Active = []v1.ObjectReference{*ref}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 70.8K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
w.WriteHeader(http.StatusOK) w.Header().Add("Content-Type", "text/html") w.Write([]byte(content)) } resp, err := http.Get(fw.testHTTPServer.URL + "/logs/") if err != nil { t.Fatalf("Got error GETing: %v", err) } defer resp.Body.Close() body, err := httputil.DumpResponse(resp, true) if err != nil { // copying the response body did not work t.Errorf("Cannot copy resp: %#v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters_test.go
kubeProxyVersion: true, }, { desc: "error getting version info", node: &v1.Node{}, versionInfoError: fmt.Errorf("foo"), expectNode: &v1.Node{}, expectError: fmt.Errorf("error getting version info: foo"), kubeProxyVersion: true, }, { desc: "error getting runtime version results in Unknown runtime", node: &v1.Node{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 21:47:24 UTC 2024 - 76.1K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
expectActions(t, client.Actions(), 1, "create", "endpointslices") sliceList, err := client.DiscoveryV1().EndpointSlices(ns).List(context.TODO(), metav1.ListOptions{}) assert.Nil(t, err, "Expected no error fetching endpoint slices") assert.Len(t, sliceList.Items, 1, "Expected 1 endpoint slices") slice := sliceList.Items[0] assert.Regexp(t, "^"+serviceName, slice.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
// So the old PV is safe to be recycled. claimName := claimrefToClaimKey(volume.Spec.ClaimRef) _, claimCached, err := ctrl.claims.GetByKey(claimName) if err != nil { logger.V(3).Info("Error getting the claim from cache", "PVC", klog.KRef(volume.Spec.ClaimRef.Namespace, volume.Spec.ClaimRef.Name)) return } if used && !claimCached { msg := fmt.Sprintf("Volume is used by pods: %s", strings.Join(pods, ","))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
cmd/test-utils_test.go
queryValues := url.Values{} queryValues.Set("uploadId", uploadID) queryValues.Set("partNumber", partNumber) return makeTestTargetURL(endPoint, bucketName, objectName, queryValues) } // return URL for fetching object from the bucket. func getGetObjectURL(endPoint, bucketName, objectName string) string { return makeTestTargetURL(endPoint, bucketName, objectName, url.Values{}) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers.go
p1Usage, p1Err := podDiskUsage(p1Stats, p1, fsStatsToMeasure) p2Usage, p2Err := podDiskUsage(p2Stats, p2, fsStatsToMeasure) if p1Err != nil || p2Err != nil { // prioritize evicting the pod which had an error getting stats return cmpBool(p1Err != nil, p2Err != nil) } p1Disk := p1Usage[diskResource] p2Disk := p2Usage[diskResource]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 53.6K bytes - Viewed (0)