Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for Read (0.24 sec)

  1. cni/test/install_cni.go

    func checkResult(result, expected string) error {
    	resultFile, err := os.ReadFile(result)
    	if err != nil {
    		return fmt.Errorf("couldn't read result: %v", err)
    	}
    	expectedFile, err := os.ReadFile(expected)
    	if err != nil {
    		return fmt.Errorf("couldn't read expected: %v", err)
    	}
    	if !bytes.Equal(resultFile, expectedFile) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 12.5K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/ztunnelserver.go

    			// Safety: Resp is buffered, so this will not block
    			update.Resp <- updateResponse{
    				err:  err,
    				resp: resp,
    			}
    
    		case <-time.After(ztunnelKeepAliveCheckInterval):
    			// do a short read, just to see if the connection to ztunnel is
    			// still alive. As ztunnel shouldn't send anything unless we send
    			// something first, we expect to get an os.ErrDeadlineExceeded error
    			// here if the connection is still alive.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  3. istioctl/pkg/validate/validate.go

    		var err error
    		if path == "-" {
    			reader = io.NopCloser(os.Stdin)
    		} else {
    			reader, err = os.Open(path)
    			if err != nil {
    				errs = multierror.Append(errs, fmt.Errorf("cannot read file %q: %v", path, err))
    				return
    			}
    		}
    		warning, err := v.validateFile(path, istioNamespace, defaultNamespace, reader, writer)
    		if err != nil {
    			errs = multierror.Append(errs, err)
    		}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Jan 22 17:58:52 GMT 2024
    - 15K bytes
    - Viewed (0)
  4. istioctl/pkg/kubeinject/kubeinject.go

    	}
    	meshConfigMap, err := client.Kube().CoreV1().ConfigMaps(ctx.IstioNamespace()).Get(context.TODO(), meshConfigMapName, metav1.GetOptions{})
    	if err != nil {
    		return nil, fmt.Errorf("could not read valid configmap %q from namespace %q: %v - "+
    			"Use --meshConfigFile or re-run "+command+" with `-i <istioSystemNamespace> and ensure valid MeshConfig exists",
    			meshConfigMapName, ctx.IstioNamespace(), err)
    	}
    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)
  5. istioctl/pkg/describe/describe_test.go

    }
    
    // Tests Pilot /debug
    func TestDescribe(t *testing.T) {
    	productPageConfigPath := "testdata/describe/http_config.json"
    	config, err := os.ReadFile(productPageConfigPath)
    	if err != nil {
    		t.Fatalf("failed to read %s: %v", productPageConfigPath, err)
    	}
    	cases := []execAndK8sConfigTestCase{
    		{ // case 0
    			args:           []string{},
    			expectedString: "Describe resource and related Istio configuration",
    		},
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Mar 28 09:54:01 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  6. cni/pkg/install/install.go

    	if len(in.cniConfigFilepath) > 0 && file.Exists(in.cniConfigFilepath) {
    		if in.cfg.ChainedCNIPlugin {
    			installLog.Infof("Removing Istio CNI config from CNI config file: %s", in.cniConfigFilepath)
    
    			// Read JSON from CNI config file
    			cniConfigMap, err := util.ReadCNIConfigMap(in.cniConfigFilepath)
    			if err != nil {
    				return err
    			}
    			// Find Istio CNI and remove from plugin list
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  7. istioctl/cmd/root.go

    	"istio.io/istio/pkg/cmd"
    	"istio.io/istio/pkg/collateral"
    	"istio.io/istio/pkg/config/constants"
    	"istio.io/istio/pkg/log"
    	"istio.io/istio/tools/bug-report/pkg/bugreport"
    )
    
    const (
    	// Location to read istioctl defaults from
    	defaultIstioctlConfig = "$HOME/.istioctl/config.yaml"
    )
    
    const (
    	FlagCharts = "charts"
    )
    
    // ConfigAndEnvProcessing uses spf13/viper for overriding CLI parameters
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 11 20:51:30 GMT 2024
    - 10K bytes
    - Viewed (0)
  8. operator/cmd/mesh/manifest-generate_test.go

    		if err != nil {
    			panic(fmt.Errorf("failed to make temp dir: %v", err))
    		}
    		f, err := os.Open("testdata/manifest-generate/data-snapshot.tar.gz")
    		if err != nil {
    			panic(fmt.Errorf("failed to read data snapshot: %v", err))
    		}
    		if err := extract(f, d); err != nil {
    			panic(fmt.Errorf("failed to extract data snapshot: %v", err))
    		}
    		return chartSourceType(filepath.Join(d, "manifests"))
    	}()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 18 18:16:49 GMT 2024
    - 43.5K bytes
    - Viewed (0)
  9. istioctl/pkg/multicluster/remote_secret.go

    		}
    	default:
    		return nil, nil, fmt.Errorf("unsupported type: %v", opt.Type)
    	}
    	tokenSecret, err := getServiceAccountSecret(client, opt)
    	if err != nil {
    		return nil, nil, fmt.Errorf("could not get access token to read resources from local kube-apiserver: %v", err)
    	}
    
    	var server string
    	var warn Warning
    	if opt.ServerOverride != "" {
    		server = opt.ServerOverride
    	} else {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Oct 11 01:43:17 GMT 2023
    - 24K bytes
    - Viewed (0)
Back to top