- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 103 for Len (0.12 sec)
-
istioctl/pkg/writer/ztunnel/configdump/services.go
return r } return cmp.Compare(a.Hostname, b.Hostname) }) fmt.Fprintln(w, "NAMESPACE\tSERVICE NAME\tSERVICE VIP\tWAYPOINT") for _, svc := range svcs { var ip string if len(svc.Addresses) > 0 { _, ip, _ = strings.Cut(svc.Addresses[0], "/") } waypoint := serviceWaypointName(svc, zDump.Services) fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", svc.Namespace, svc.Name, ip, waypoint) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
`, RunE: func(c *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClientWithRevision(opts.Revision) if err != nil { return err } if len(args) == 0 { return util.CommandParseError{ Err: fmt.Errorf("debug type is required"), } } var xdsRequest discovery.DiscoveryRequest var namespace, serviceAccount string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0) -
istioctl/pkg/tag/generate_test.go
// expect both namespace.sidecar-injector.istio.io and object.sidecar-injector.istio.io webhooks if len(wh.Webhooks) != tc.numWebhooks { t.Errorf("expected %d webhook(s) in MutatingWebhookConfiguration, found %d", tc.numWebhooks, len(wh.Webhooks)) } tag, exists := wh.ObjectMeta.Labels[IstioTagLabel] if !exists {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 12.1K bytes - Viewed (0) -
istioctl/pkg/tag/tag_test.go
webhooksAfter, _ := client.AdmissionregistrationV1().MutatingWebhookConfigurations().List(context.Background(), metav1.ListOptions{}) if len(webhooksAfter.Items) != len(tc.webhooksAfter.Items) { t.Fatalf("expected %d after running, got %d", len(tc.webhooksAfter.Items), len(webhooksAfter.Items)) } }) } } func TestSetTagErrors(t *testing.T) { tcs := []struct { name string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Nov 17 22:41:06 GMT 2023 - 8.7K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
endpointStatus: eds, extensionconfigStatus: ecds, }) if len(fullStatus) == 0 { return nil, nil, fmt.Errorf("no proxies found (checked %d istiods)", len(drs)) } sort.Slice(fullStatus, func(i, j int) bool { return fullStatus[i].proxyID < fullStatus[j].proxyID }) } } if len(mappedResp) > 0 { mresp, err := json.MarshalIndent(mappedResp, "", " ") if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
istioctl/pkg/util/formatting/formatter.go
default: return "", fmt.Errorf("invalid format, expected one of %v but got %q", MsgOutputFormatKeys, format) } } func printLog(ms diag.Messages, colorize bool) string { logOutput := make([]string, 0, len(ms)) for _, m := range ms { logOutput = append(logOutput, render(m, colorize)) } return strings.Join(logOutput, "\n") } func printJSON(ms diag.Messages) (string, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 11 02:41:45 GMT 2023 - 3.1K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
defer c.mu.Unlock() delete(c.connectionSet, conn) if c.latestConn == conn { c.latestConn = nil } ztunnelConnected.RecordInt(int64(len(c.connectionSet))) } // this is used in tests // nolint: unused func (c *connMgr) len() int { c.mu.Lock() defer c.mu.Unlock() return len(c.connectionSet) } type ztunnelServer struct { listener *net.UnixListener // connections to pod delivered map
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_test.go
}} podUIDNetns, err := n.FindNetnsForPods(map[types.UID]*corev1.Pod{ 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")
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
} defaultFile, err := os.ReadFile(fmt.Sprintf("testdata/waypoint/%s", tt.expectedOutFile)) if err != nil { t.Fatal(err) } expectedOut := string(defaultFile) 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)
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) -
istioctl/pkg/writer/compare/comparator.go
func NewXdsComparator(w io.Writer, istiodResponses map[string]*discovery.DiscoveryResponse, envoyResponse []byte) (*Comparator, error) { c := &Comparator{} for _, resp := range istiodResponses { if len(resp.Resources) > 0 { c.istiod = &configdump.Wrapper{ ConfigDump: &admin.ConfigDump{ Configs: resp.Resources, }, } break } } if c.istiod == nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 3.7K bytes - Viewed (1)