- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for TestNode (1.2 sec)
-
subprojects/composite-builds/src/test/groovy/org/gradle/composite/internal/DefaultIncludedBuildTaskGraphParallelTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 20.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
"istio.io/istio/pkg/kube" "istio.io/istio/pkg/monitoring/monitortest" "istio.io/istio/pkg/test/util/assert" ) func TestExistingPodAddedWhenNsLabeled(t *testing.T) { setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background()) defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", }, Spec: corev1.PodSpec{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/kubelet/network/dns/dns_test.go
strings.Repeat("A", 127), strings.Repeat("A", 127), } recorder := record.NewFakeRecorder(20) nodeRef := &v1.ObjectReference{ Kind: "Node", Name: string("testNode"), UID: types.UID("testNode"), Namespace: "", } testClusterDNSDomain := "TEST" configurer := NewConfigurer(recorder, nodeRef, nil, nil, testClusterDNSDomain, "") pod := &v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 25.6K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/idempotency_test.go
name: "patch node when timeout", lookupName: "testnode", node: v1.Node{ ObjectMeta: metav1.ObjectMeta{ Name: "testnode", Labels: map[string]string{v1.LabelHostname: ""}, }, }, success: false, fakeError: apierrors.NewTimeoutError("fake timeout", -1), }, { name: "patch node when conflict", lookupName: "testnode", node: v1.Node{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumezone/volume_zone_test.go
}{ { name: "label zone failure domain matched", Pod: createPodWithVolume("pod_1", "PVC_1"), Node: testNode, }, { name: "unbound volume empty storage class", Pod: createPodWithVolume("pod_1", "PVC_EmptySC"), Node: testNode, wantPreFilterStatus: framework.NewStatus(framework.UnschedulableAndUnresolvable, "PersistentVolumeClaim had no pv name and storageClass name"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 14 05:17:04 UTC 2023 - 20K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/test/groovy/org/gradle/model/internal/registry/RuleBindingsTest.groovy
} void addNode(TestNode node, ModelProjection... projections) { addUntypedNode(node) addProjections(node, projections) } private void addUntypedNode(TestNode node) { bindings.nodeCreated(node) } private void addProjections(TestNode node, ModelProjection... projections) { projections.each { node.addProjection it }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 26.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/filter_test.go
"spec": map[string]interface{}{ "testSize": 10, }, }, } podObject := corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "foo", }, Spec: corev1.PodSpec{ NodeName: "testnode", }, } nsObject := &corev1.Namespace{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Labels: map[string]string{ "env": "test", "foo": "demo", },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 40.4K bytes - Viewed (0) -
src/net/http/clientserver_test.go
"net/url" "os" "reflect" "runtime" "slices" "strings" "sync" "sync/atomic" "testing" "time" ) type testMode string const ( http1Mode = testMode("h1") // HTTP/1.1 https1Mode = testMode("https1") // HTTPS/1.1 http2Mode = testMode("h2") // HTTP/2 ) type testNotParallelOpt struct{} var ( testNotParallel = testNotParallelOpt{} )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 46.6K bytes - Viewed (0) -
src/net/http/responsecontroller_test.go
"fmt" "io" . "net/http" "os" "sync" "testing" "time" ) func TestResponseControllerFlush(t *testing.T) { run(t, testResponseControllerFlush) } func testResponseControllerFlush(t *testing.T, mode testMode) { continuec := make(chan struct{}) cst := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) { ctl := NewResponseController(w) w.Write([]byte("one")) if err := ctl.Flush(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 06 19:20:31 UTC 2024 - 10.2K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
allClusterGVKs = helmreconciler.ClusterResources ) func init() { if kubeBuilderInstalled() { // TestMode is required to not wait in the go client for resources that will never be created in the test server. helmreconciler.TestMode = true // Add install and controller to the list of commands to run tests against. testedManifestCmds = append(testedManifestCmds, cmdApply, cmdController) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 20 22:39:28 UTC 2024 - 11.7K bytes - Viewed (0)