- Sort Score
- Result 10 results
- Languages All
Results 101 - 109 of 109 for It (4.75 sec)
-
cni/pkg/plugin/plugin_test.go
testDoAddRun(t, cniConf, excludedNS, pod, ns) wasCalled := serverClose() // If the pod is being added to a namespace that is explicitly excluded by plugin config denylist // it should never be added, even if the namespace has the annotation assert.Equal(t, wasCalled, false) } func TestCmdAdd(t *testing.T) { pod, ns := buildFakePodAndNSForClient()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 17.5K bytes - Viewed (0) -
tests/integration/pilot/gateway_test.go
// Wipe out the status gwc, _ := client.Get(context.Background(), "istio", metav1.GetOptions{}) gwc.Status.Conditions = nil client.Update(context.Background(), gwc, metav1.UpdateOptions{}) // It should be added back retry.UntilSuccessOrFail(t, check) } // Verify that the envoy readiness probes are reachable at // https://GatewaySvcIP:15021/healthz/ready . This is being explicitly done
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.7K bytes - Viewed (0) -
security/pkg/k8s/chiron/utils_test.go
} port2, err := getServerPort(server2.httpServer) if err != nil { t.Fatalf("error to get the server 2 port: %v", err) } // Server 1 should be reachable, since it is not closed. if !isTCPReachable(host, port1) { t.Fatal("server 1 is unreachable") } // After closing server 2, server 2 should not be reachable server2.httpServer.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 03:58:11 UTC 2024 - 13K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
waitForMockCalls() assertPodNotAnnotated(t, client, pod) fs.On("AddPodToMesh", ctx, mock.Anything, util.GetPodIPsIfPresent(pod), "", ).Return(nil) // Now bring it back // Patch the pod back to a running status phaseRunPatch := []byte(`{"status":{"phase":"Running"}}`) _, err = client.Kube().CoreV1().Pods(pod.Namespace).Patch(ctx, pod.Name,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
istioctl ztunnel-config workload <ztunnel-name[.namespace]> --address 0.0.0.0 -o json # Retrieve Ztunnel config dump separately and inspect from file. kubectl exec -it $ZTUNNEL -n istio-system -- curl localhost:15000/config_dump > ztunnel-config.json istioctl ztunnel-config workloads --file ztunnel-config.json # Retrieve workload summary for a specific namespace
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 22K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters_test.go
{Network: "network2", Address: "20.0.0.2"}, {Network: "network2", Address: "20.0.0.3"}, }, // network3 has no endpoints. // network4 has a single endpoint, but not gateway so it will always // be considered directly reachable. {Cluster: "cluster4"}: { {Network: "network4", Address: "40.0.0.1"}, }, }} // apply common properties for sk, shard := range shards.Shards {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 26.8K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_test.go
if _, ok := expected[k]; !ok { unexpected[k] = struct{}{} } } for _, i := range got { k := instanceKey(i) // just remove the items rather than looping over expected, if anythings left we missed it delete(expected, k) if _, ok := unexpected[k]; ok { t.Errorf("expected %s to be filtered out", k) } } if len(expected) > 0 { t.Errorf("did not include %v", expected) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server_test.go
http.Redirect(w, r, "/redirect-loop", http.StatusMovedPermanently) case "remote-redirect": http.Redirect(w, r, "http://example.com/foo", http.StatusMovedPermanently) case "", "hello/sunnyvale": w.Write([]byte("welcome, it works")) case "status": code, _ := strconv.Atoi(segments[1]) w.Header().Set("Location", "/") w.WriteHeader(code) default: return } } func TestNewServer(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/test/framework/components/istio/kube.go
} return operatorCfg.Spec, nil } // installControlPlaneCluster installs the istiod control plane to the given cluster. // The cluster is considered a "primary" cluster if it is also a "config cluster", in which case components // like ingress will be installed. func (i *istioImpl) installControlPlaneCluster(c cluster.Cluster) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 31.1K bytes - Viewed (0)