Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 51 for Writer (0.3 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. istioctl/pkg/validate/validate.go

    				if fname == "-" {
    					_, _ = fmt.Fprint(writer, warningToString(w))
    					break
    				}
    				_, _ = fmt.Fprintf(writer, "%q has warnings: %v\n", fname, warningToString(w))
    			}
    		}
    		return errs
    	}
    	for _, fname := range filenames {
    		if fname == "-" {
    			if w := warningsByFilename[fname]; w != nil {
    				_, _ = fmt.Fprint(writer, warningToString(w))
    			} else {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Jan 22 17:58:52 GMT 2024
    - 15K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/compare/comparator.go

    )
    
    // Comparator diffs between a config dump from Istiod and one from Envoy
    type Comparator struct {
    	envoy, istiod *configdump.Wrapper
    	w             io.Writer
    	context       int
    	location      string
    }
    
    // NewComparator is a comparator constructor
    func NewComparator(w io.Writer, istiodResponses map[string][]byte, envoyResponse []byte) (*Comparator, error) {
    	c := &Comparator{}
    	for _, resp := range istiodResponses {
    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)
  7. istioctl/pkg/checkinject/checkinject.go

    	return cmd
    }
    
    func printCheckInjectorResults(writer io.Writer, was []webhookAnalysis) error {
    	if len(was) == 0 {
    		fmt.Fprintf(writer, "ERROR: no Istio injection hooks present.\n")
    		return nil
    	}
    	w := table.NewStyleWriter(writer)
    	w.SetAddRowFunc(func(obj interface{}) table.Row {
    		wa := obj.(webhookAnalysis)
    		row := table.Row{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/configdump/configdump.go

    	"sigs.k8s.io/yaml"
    
    	"istio.io/istio/istioctl/pkg/util/configdump"
    	sdscompare "istio.io/istio/istioctl/pkg/writer/compare/sds"
    	"istio.io/istio/pkg/util/protomarshal"
    )
    
    // ConfigWriter is a writer for processing responses from the Envoy Admin config_dump endpoint
    type ConfigWriter struct {
    	Stdout     io.Writer
    	configDump *configdump.Wrapper
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 29 20:46:41 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/ztunnel/configdump/certificates.go

    func (c *ConfigWriter) PrintSecretSummary() error {
    	if c.ztunnelDump == nil {
    		return fmt.Errorf("config writer has not been primed")
    	}
    	secretDump := c.ztunnelDump.Certificates
    	w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 5, ' ', 0)
    	fmt.Fprintln(w, "CERTIFICATE NAME\tTYPE\tSTATUS\tVALID CERT\tSERIAL NUMBER\tNOT AFTER\tNOT BEFORE")
    
    	for _, secret := range secretDump {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 25 16:38:16 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  10. 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)
Back to top