- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 44 for Writer (0.15 sec)
-
istioctl/pkg/admin/istiodconfig.go
"istio.io/istio/pkg/log" ) type flagState interface { run(out io.Writer) error } var ( _ flagState = (*resetState)(nil) _ flagState = (*logLevelState)(nil) _ flagState = (*stackTraceLevelState)(nil) _ flagState = (*getAllLogLevelsState)(nil) ) type resetState struct { client *ControlzClient } func (rs *resetState) run(_ io.Writer) error { const ( defaultOutputLevel = "info"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
istioctl/pkg/authz/listener.go
log.Errorf("failed to parse policy name: %s", name) return "", "" } return fmt.Sprintf("%s.%s", parts[2], parts[1]), parts[3] } // Print prints the AuthorizationPolicy in the listener. func Print(writer io.Writer, listeners []*listener.Listener) { parsedListeners := parse(listeners) if parsedListeners == nil { return } actionToPolicy := map[rbacpb.RBAC_Action]map[string]struct{}{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Sep 11 15:29:30 GMT 2023 - 6K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
} // listTags lists existing revision. func listTags(ctx context.Context, kubeClient kubernetes.Interface, writer io.Writer) error { tagWebhooks, err := GetRevisionWebhooks(ctx, kubeClient) if err != nil { return fmt.Errorf("failed to retrieve revision tags: %v", err) } if len(tagWebhooks) == 0 { fmt.Fprintf(writer, "No Istio revision tag MutatingWebhookConfigurations to list\n") return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
"istio.io/istio/istioctl/pkg/completion" "istio.io/istio/istioctl/pkg/kubeinject" istioctlutil "istio.io/istio/istioctl/pkg/util" sdscompare "istio.io/istio/istioctl/pkg/writer/compare/sds" "istio.io/istio/istioctl/pkg/writer/envoy/clusters" "istio.io/istio/istioctl/pkg/writer/envoy/configdump" "istio.io/istio/operator/pkg/util" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pkg/config/host" "istio.io/istio/pkg/kube"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
if err == nil { err = errClose } } }() } var writer io.Writer if outFilename == "" { writer = c.OutOrStdout() } else { var out *os.File if out, err = os.Create(outFilename); err != nil { return err } writer = out defer func() { if errClose := out.Close(); errClose != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
List(context.Background(), metav1.ListOptions{}) if err != nil { return err } if len(gws.Items) == 0 { fmt.Fprintln(writer, "No waypoints found.") return nil } w := new(tabwriter.Writer).Init(writer, 0, 8, 5, ' ', 0) slices.SortFunc(gws.Items, func(i, j gateway.Gateway) int { if r := cmp.Compare(i.Namespace, j.Namespace); r != 0 { return r }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
} type Printer interface { Printf(format string, a ...any) Println(string) } func NewPrinterForWriter(w io.Writer) Printer { return &writerPrinter{writer: w} } type writerPrinter struct { writer io.Writer } func (w *writerPrinter) Printf(format string, a ...any) { _, _ = fmt.Fprintf(w.writer, format, a...) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 5.1K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
cfgNames += ", " } } fmt.Fprintf(writer, " %s\n", cfgNames) } func printPeerAuthentication(writer io.Writer, pa authn.MergedPeerAuthentication) { fmt.Fprintf(writer, "Effective PeerAuthentication:\n") fmt.Fprintf(writer, " Workload mTLS mode: %s\n", pa.Mode.String()) if len(pa.PerPort) != 0 { fmt.Fprintf(writer, " Port Level mTLS mode:\n") for port, mode := range pa.PerPort {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list.go
return filtered[i].Name < filtered[j].Name }) return filtered, nil } func printNS(writer io.Writer, namespaces []corev1.Namespace, hooks []admitv1.MutatingWebhookConfiguration, allPods map[resource.Namespace][]corev1.Pod, ) error { outputCount := 0 w := new(tabwriter.Writer).Init(writer, 0, 8, 1, ' ', 0) for _, namespace := range namespaces { revision := getInjectedRevision(&namespace, hooks)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 04 03:08:06 GMT 2024 - 10.4K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/services.go
"cmp" "encoding/json" "fmt" "strings" "sigs.k8s.io/yaml" "istio.io/istio/pkg/maps" "istio.io/istio/pkg/slices" ) // ServiceFilter is used to pass filter information into service based config writer print functions type ServiceFilter struct { Namespace string } // Verify returns true if the passed workload matches the filter fields func (wf *ServiceFilter) Verify(svc *ZtunnelService) bool {
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)