Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for primul (0.15 sec)

  1. istioctl/pkg/writer/envoy/configdump/configdump_test.go

    		},
    		{
    			name:    "errors if config dump is not primed",
    			wantErr: true,
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			gotOut := &bytes.Buffer{}
    			cw := &ConfigWriter{Stdout: gotOut}
    			cd, _ := os.ReadFile("testdata/configdump.json")
    			if tt.callPrime {
    				cw.Prime(cd)
    			}
    			err := cw.PrintBootstrapDump("json")
    			if tt.wantOutputFile != "" {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jan 03 23:08:06 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/envoy/configdump/configdump.go

    var includeConfigType bool
    
    func SetPrintConfigTypeInSummary(p bool) {
    	includeConfigType = p
    }
    
    // Prime loads the config dump into the writer ready for printing
    func (c *ConfigWriter) Prime(b []byte) error {
    	w := &configdump.Wrapper{}
    	err := w.UnmarshalJSON(b)
    	if err != nil {
    		return fmt.Errorf("error unmarshalling config dump response from Envoy: %v", err)
    	}
    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)
  3. istioctl/pkg/writer/ztunnel/configdump/configdump_test.go

    	}{
    		{
    			name:             "returns expected secret summary onto Stdout",
    			callPrime:        true,
    			wantOutputSecret: "testdata/secretsummary.txt",
    		},
    		{
    			name:    "errors if config dump is not primed",
    			wantErr: true,
    		},
    		{
    			name:               "returns expected workload summary onto Stdout",
    			callPrime:          true,
    			wantOutputWorkload: "testdata/workloadsummary.txt",
    		},
    		{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Feb 02 18:21:48 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/ztunnel/configdump/certificates.go

    )
    
    // PrintSecretDump prints just the secret config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintSecretDump(outputFormat string) error {
    	if c.ztunnelDump == nil {
    		return fmt.Errorf("config writer has not been primed")
    	}
    	secretDump := c.ztunnelDump.Certificates
    	out, err := json.MarshalIndent(secretDump, "", "    ")
    	if err != nil {
    		return fmt.Errorf("failed to marshal secrets dump: %v", err)
    	}
    	if outputFormat == "yaml" {
    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)
  5. istioctl/pkg/writer/ztunnel/configdump/configdump.go

    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{}
    	// TODO(fisherxu): migrate this to jsonpb when issue fixed in golang
    	// Issue to track -> https://github.com/golang/protobuf/issues/632
    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/envoy/configdump/route_test.go

    		t.Run(tt.name, func(t *testing.T) {
    			gotOut := &bytes.Buffer{}
    			cw := &ConfigWriter{Stdout: gotOut}
    			cd, _ := os.ReadFile(fmt.Sprintf("testdata/routes/%s/configdump.json", tt.name))
    			if err := cw.Prime(cd); err != nil {
    				t.Errorf("failed to parse config dump: %s", err)
    			}
    			err := cw.PrintRouteSummary(RouteFilter{Verbose: true})
    			assert.NoError(t, err)
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 2.8K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/envoy/configdump/listener.go

    	return w, listeners, nil
    }
    
    func (c *ConfigWriter) retrieveSortedListenerSlice() ([]*listener.Listener, error) {
    	if c.configDump == nil {
    		return nil, fmt.Errorf("config writer has not been primed")
    	}
    	listenerDump, err := c.configDump.GetListenerConfigDump()
    	if err != nil {
    		return nil, fmt.Errorf("listener dump: %v", err)
    	}
    	listeners := make([]*listener.Listener, 0)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  8. istioctl/pkg/proxyconfig/proxyconfig.go

    	}
    	return setupConfigdumpEnvoyConfigWriter(data, out)
    }
    
    func setupConfigdumpEnvoyConfigWriter(debug []byte, out io.Writer) (*configdump.ConfigWriter, error) {
    	cw := &configdump.ConfigWriter{Stdout: out}
    	err := cw.Prime(debug)
    	if err != nil {
    		return nil, err
    	}
    	return cw, nil
    }
    
    func setupEnvoyClusterStatsConfig(kubeClient kube.CLIClient, podName, podNamespace string, outputFormat string) (string, error) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 16 03:28:36 GMT 2024
    - 48K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/envoy/configdump/endpoint.go

    		}
    	}
    	return "unknown"
    }
    
    func (c *ConfigWriter) PrintEndpoints(filter EndpointFilter, outputFormat string) error {
    	if c.configDump == nil {
    		return fmt.Errorf("config writer has not been primed")
    	}
    	dump, err := c.retrieveSortedEndpointsSlice(filter)
    	if err != nil {
    		return err
    	}
    	marshaller := make(proto.MessageSlice, 0, len(dump))
    	for _, eds := range dump {
    		marshaller = append(marshaller, eds)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  10. istioctl/pkg/ztunnelconfig/ztunnelconfig.go

    	}
    	return debug, err
    }
    
    func setupConfigdumpZtunnelConfigWriter(debug []byte, out io.Writer) (*ztunnelDump.ConfigWriter, error) {
    	cw := &ztunnelDump.ConfigWriter{Stdout: out, FullDump: debug}
    	err := cw.Prime(debug)
    	if err != nil {
    		return nil, err
    	}
    	return cw, nil
    }
    
    func setupFileZtunnelConfigdumpWriter(filename string, out io.Writer) (*ztunnelDump.ConfigWriter, error) {
    	data, err := readFile(filename)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 01 13:11:40 GMT 2024
    - 22.2K bytes
    - Viewed (0)
Back to top