- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for writes (0.66 sec)
-
operator/cmd/mesh/manifest-generate.go
for _, obj := range objects { yml, err := obj.YAML() if err != nil { return nil, err } output = append(output, string(yml)) } return output, nil } // RenderToDir writes manifests to a local filesystem directory tree. func RenderToDir(manifests name.ManifestMap, outputDir string, dryRun bool, l clog.Logger) error { l.LogAndPrintf("Component dependencies tree: \n%s", helmreconciler.InstallTreeString())
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K 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/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) -
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) -
istioctl/pkg/writer/ztunnel/configdump/configdump.go
"encoding/json" "fmt" "io" "text/tabwriter" "sigs.k8s.io/yaml" ) // ConfigWriter is a writer for processing responses from the Ztunnel Admin config_dump endpoint type ConfigWriter struct { Stdout io.Writer ztunnelDump *ZtunnelDump FullDump []byte } // Prime loads the config dump into the writer ready for printing func (c *ConfigWriter) Prime(b []byte) error { cd := ZtunnelDump{}
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
mappedResp[id] = string(resource.Value) + "\n" } else { _, _ = s.Writer.Write(resource.Value) _, _ = s.Writer.Write([]byte("\n")) } } } if len(mappedResp) > 0 { mresp, err := json.MarshalIndent(mappedResp, "", " ") if err != nil { return err } _, _ = s.Writer.Write(mresp) _, _ = s.Writer.Write([]byte("\n")) } return nil
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/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/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) -
cni/pkg/nodeagent/ztunnelserver_test.go
if err != nil { panic(err) } c.Write(data) } func sendHello(c *net.UnixConn) { ack := &zdsapi.ZdsHello{ Version: zdsapi.Version_V1, } data, err := proto.Marshal(ack) if err != nil { panic(err) } err = c.SetWriteDeadline(time.Now().Add(time.Second)) if err != nil { panic(err) } c.Write(data) } type fakePodCache struct {
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)