Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 80 for read_file (0.12 sec)

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

    		{
    			name: "k8s-gateway-http-route-path-prefix",
    		},
    	}
    	for _, tt := range tests {
    		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})
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  2. src/cmd/asm/internal/asm/endtoend_test.go

    	if !ok || failed {
    		t.Errorf("asm: %s assembly failed", goarch)
    		return
    	}
    	output := strings.Split(testOut.String(), "\n")
    
    	// Reconstruct expected output by independently "parsing" the input.
    	data, err := os.ReadFile(input)
    	if err != nil {
    		t.Error(err)
    		return
    	}
    	lineno := 0
    	seq := 0
    	hexByLine := map[string]string{}
    	lines := strings.SplitAfter(string(data), "\n")
    Diff:
    	for _, line := range lines {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Dec 07 18:42:59 UTC 2023
    - 11.6K bytes
    - Viewed (0)
  3. cmd/handler-api.go

    const (
    	cgroupV1MemLimitFile = "/sys/fs/cgroup/memory/memory.limit_in_bytes"
    	cgroupV2MemLimitFile = "/sys/fs/cgroup/memory.max"
    )
    
    func cgroupMemLimit() (limit uint64) {
    	buf, err := os.ReadFile(cgroupV2MemLimitFile)
    	if err != nil {
    		buf, err = os.ReadFile(cgroupV1MemLimitFile)
    	}
    	if err != nil {
    		return 0
    	}
    	limit, err = strconv.ParseUint(strings.TrimSpace(string(buf)), 10, 64)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  4. docs/debugging/healing-bin/main.go

    					}
    					ht[file.Name] = htr
    				}
    			}
    			b, err := json.MarshalIndent(ht, "", "  ")
    			if err != nil {
    				return err
    			}
    			fmt.Println(string(b))
    			return nil
    		}
    		b, err := os.ReadFile(file)
    		if err != nil {
    			return err
    		}
    		buf := bytes.NewBuffer(nil)
    		if _, err = msgp.CopyToJSON(buf, bytes.NewReader(b)); err != nil {
    			return err
    		}
    		var htr map[string]interface{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.2K bytes
    - Viewed (0)
  5. istioctl/pkg/kubeinject/kubeinject.go

    				return nil, nil, err
    			}
    		}
    	}
    
    	injector := &ExternalInjector{}
    	if injectConfigFile != "" {
    		injectionConfig, err := os.ReadFile(injectConfigFile) // nolint: vetshadow
    		if err != nil {
    			return nil, nil, err
    		}
    		injectConfig, err := readInjectConfigFile(injectionConfig)
    		if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
  6. istioctl/pkg/waypoint/waypoint_test.go

    				t.Fatal(err)
    			}
    
    			for _, gw := range tt.gateways {
    				_, _ = client.GatewayAPI().GatewayV1().Gateways(gw.Namespace).Create(context.Background(), gw, metav1.CreateOptions{})
    			}
    			defaultFile, err := os.ReadFile(fmt.Sprintf("testdata/waypoint/%s", tt.expectedOutFile))
    			if err != nil {
    				t.Fatal(err)
    			}
    			expectedOut := string(defaultFile)
    			if len(expectedOut) == 0 {
    				t.Fatal("expected output is empty")
    			}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Apr 04 15:53:09 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. cmd/xl-storage_test.go

    		}
    	}
    
    	{
    		buf := make([]byte, 5)
    		// Test for negative offset.
    		if _, err = xlStorage.ReadFile(context.Background(), volume, "myobject", -1, buf, v); err == nil {
    			t.Fatalf("expected: error, got: <nil>")
    		}
    	}
    
    	for l := 0; l < 2; l++ {
    		// Following block validates all ReadFile test cases.
    		for i, testCase := range testCases {
    			var n int64
    			// Common read buffer.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  8. internal/s3select/simdj/reader_amd64_test.go

    	Fatal(args ...interface{})
    }
    
    func loadCompressed(t tester, file string) (js []byte) {
    	dec, err := zstd.NewReader(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer dec.Close()
    	js, err = os.ReadFile(filepath.Join("testdata", file+".json.zst"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	js, err = dec.DecodeAll(js, nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	return js
    }
    
    var testCases = []struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  9. cni/pkg/iptables/iptables_linux.go

    	return forEachLoopbackRoute(cfg, "remove", netlink.RouteDel)
    }
    
    const ipv6DisabledLo = "/proc/sys/net/ipv6/conf/lo/disable_ipv6"
    
    func ReadSysctl(key string) (string, error) {
    	data, err := os.ReadFile(key)
    	if err != nil {
    		return "", err
    	}
    	return strings.TrimSpace(string(data)), nil
    }
    
    func forEachLoopbackRoute(cfg *Config, operation string, f func(*netlink.Route) error) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Sep 06 09:44:28 UTC 2024
    - 4K bytes
    - Viewed (0)
  10. istioctl/pkg/proxyconfig/proxyconfig.go

    	debug, err := extractConfigDump(kubeClient, podName, podNamespace, includeEds)
    	if err != nil {
    		return nil, err
    	}
    	return setupConfigdumpEnvoyConfigWriter(debug, out)
    }
    
    func readFile(filename string) ([]byte, error) {
    	file := os.Stdin
    	if filename != "-" {
    		var err error
    		file, err = os.Open(filename)
    		if err != nil {
    			return nil, err
    		}
    	}
    	defer func() {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
Back to top