- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for EXPECTED (0.27 sec)
-
istioctl/pkg/describe/describe_test.go
} } func TestGetRevisionFromPodAnnotation(t *testing.T) { cases := []struct { anno klabels.Set expected string }{ { anno: klabels.Set{ apiannotation.SidecarStatus.Name: "", }, expected: "", }, { anno: klabels.Set{}, expected: "", }, { anno: klabels.Set{ apiannotation.SidecarStatus.Name: ` { "initContainers": [
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Mar 28 09:54:01 GMT 2024 - 30.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
if kept.Uid != string(pod.UID) { panic("expected keep received") } sendAck(ztunClient) // read snapshot sent m, fds := readRequest(t, ztunClient) assert.Equal(t, len(fds), 0) sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent if sent == nil { panic("expected snapshot sent") } sendAck(ztunClient) ztunClient.Close()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus_test.go
) type execTestCase struct { args []string revision string noIstiod bool // Typically use one of the three expectedOutput string // Expected constant output expectedString string // String output is expected to contain wantException bool } func TestProxyStatus(t *testing.T) { cases := []execTestCase{ { // case 0, with no Isitod instance args: []string{},
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 5.5K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_test.go
pod.UID: pod, }) if err != nil { panic(err) } defer podUIDNetns.Close() if len(podUIDNetns) == 0 { t.Fatal("expected to find pod netns") } expectedUID := "863b91d4-4b68-4efa-917f-4b560e3e86aa" if podUIDNetns[expectedUID] == (WorkloadInfo{}) { t.Fatal("expected to find pod netns under pod uid") } } // copied and modified from spire func TestGetContainerIDFromCGroups(t *testing.T) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.6K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint_test.go
if len(expectedOut) == 0 { t.Fatal("expected output is empty") } var out bytes.Buffer rootCmd := Cmd(ctx) rootCmd.SetArgs(tt.args) rootCmd.SetOut(&out) rootCmd.SetErr(&out) fErr := rootCmd.Execute() if fErr != nil { t.Fatal(fErr) } output := out.String() if output != expectedOut { t.Fatalf("expected %s, got %s", expectedOut, output) } })
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 04 15:53:09 GMT 2024 - 4.4K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
types.MergePatchType, labelsPatch, metav1.PatchOptions{}) assert.NoError(t, err) waitForMockCalls() assertPodAnnotated(t, client, pod) // Assert expected calls actually made fs.AssertExpectations(t) } func TestExistingPodAddedWhenDualStack(t *testing.T) { setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background())
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
} // Create a kube client client := kube.NewFakeClient(objects...) mockRedir := &mockInterceptRuleMgr{} err = doAddRun(args, conf, client.Kube(), mockRedir) if err == nil { t.Fatal("expected to fail, but did not!") } return mockRedir } func testDoAddRun(t *testing.T, stdinData, nsName string, objects ...runtime.Object) *mockInterceptRuleMgr {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
} return nil } func pruneHostIPset(expected sets.Set[netip.Addr], hostsideProbeSet *ipset.IPSet) error { actualIPSetContents, err := hostsideProbeSet.ListEntriesByIP() if err != nil { log.Warnf("unable to list IPSet: %v", err) return err } actual := sets.New[netip.Addr](actualIPSetContents...) stales := actual.DifferenceInPlace(expected) for staleIP := range stales {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
operator/cmd/mesh/profile-dump.go
case jsonOutput, yamlOutput, flagsOutput: default: return fmt.Errorf("unknown output format: %s", outputFormat) } return nil } // yamlToFormat converts the generated yaml config to the expected format func yamlToFormat(yaml, outputFormat string) (string, error) { var output string switch outputFormat { case jsonOutput: j, err := yamlToPrettyJSON(yaml) if err != nil { return "", err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 7.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
err := netServer.AddPodToMesh(ctx, &corev1.Pod{ObjectMeta: podMeta}, podIPs, "faksens") assert.Equal(t, ztunnelServer.addedPods.Load(), 1) if !errors.Is(err, ErrPartialAdd) { t.Fatal("expected partial error") } } func TestDoesntReturnsPartialErrorOnIptablesFail(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0)