Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 45 for fruiter (0.14 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/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)
  3. 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)
  4. 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)
  5. 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)
  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/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)
  9. 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)
  10. 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)
Back to top