Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for Writer (0.14 sec)

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

    }
    
    func colorSuffix(colorize bool) string {
    	if !colorize {
    		return ""
    	}
    	return "\033[0m"
    }
    
    func IstioctlColorDefault(writer io.Writer) bool {
    	if strings.EqualFold(termEnvVar.Get(), "dumb") {
    		return false
    	}
    
    	file, ok := writer.(*os.File)
    	if ok {
    		if !isatty.IsTerminal(file.Fd()) {
    			return false
    		}
    	}
    
    	return true
    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)
  6. istioctl/pkg/admin/istiodconfig_test.go

    			}
    		})
    	}
    }
    
    func resourceHandler(writer http.ResponseWriter, request *http.Request) {
    	const getResponse = `{"name":"resource","description":"Core resource model scope","output_level":"info","stack_trace_level":"none","log_callers":false}`
    
    	switch request.Method {
    	case http.MethodGet:
    		_, _ = writer.Write([]byte(getResponse))
    	}
    }
    
    func adsHandler(writer http.ResponseWriter, request *http.Request) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 6.2K bytes
    - Viewed (0)
  7. 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)
  8. istioctl/pkg/writer/pilot/status.go

    	if len(mappedResp) > 0 {
    		mresp, err := json.MarshalIndent(mappedResp, "", "  ")
    		if err != nil {
    			return nil, nil, err
    		}
    		_, _ = s.Writer.Write(mresp)
    		_, _ = s.Writer.Write([]byte("\n"))
    	}
    
    	return w, fullStatus, nil
    }
    
    func xdsStatusPrintln(w io.Writer, status *xdsWriterStatus) error {
    	_, err := fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\t%v\t%v\t%v\n",
    		status.proxyID, status.clusterID,
    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)
  9. istioctl/pkg/proxystatus/proxystatus.go

    	"istio.io/istio/istioctl/pkg/clioptions"
    	"istio.io/istio/istioctl/pkg/completion"
    	"istio.io/istio/istioctl/pkg/multixds"
    	"istio.io/istio/istioctl/pkg/util/ambient"
    	"istio.io/istio/istioctl/pkg/writer/compare"
    	"istio.io/istio/istioctl/pkg/writer/pilot"
    	pilotxds "istio.io/istio/pilot/pkg/xds"
    	"istio.io/istio/pkg/log"
    )
    
    var configDumpFile string
    
    func readConfigFile(filename string) ([]byte, error) {
    	file := os.Stdin
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  10. istioctl/pkg/util/common.go

    	Err error
    }
    
    func (c CommandParseError) Error() string {
    	return c.Err.Error()
    }
    
    // Confirm waits for a user to confirm with the supplied message.
    func Confirm(msg string, writer io.Writer) bool {
    	for {
    		_, _ = fmt.Fprintf(writer, "%s ", msg)
    		var response string
    		_, err := fmt.Scanln(&response)
    		if err != nil {
    			return false
    		}
    		switch strings.ToUpper(response) {
    		case "Y", "YES":
    			return true
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 1.6K bytes
    - Viewed (0)
Back to top