Search Options

Results per page
Sort
Preferred Languages
Advance

Results 751 - 760 of 1,387 for funcs (0.02 sec)

  1. istioctl/pkg/internaldebug/internal-debug.go

    	"istio.io/istio/istioctl/pkg/clioptions"
    	"istio.io/istio/istioctl/pkg/multixds"
    	"istio.io/istio/istioctl/pkg/util"
    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    	"istio.io/istio/pkg/kube"
    )
    
    func HandlerForRetrieveDebugList(kubeClient kube.CLIClient,
    	centralOpts clioptions.CentralControlPlaneOptions,
    	writer io.Writer,
    	istioNamespace string,
    ) (map[string]*discovery.DiscoveryResponse, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jul 12 11:30:24 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  2. cmd/batch-job-common-types_test.go

    				LowerBound: 1 << 20,
    			},
    			want: true,
    		},
    	}
    
    	for i, test := range tests {
    		t.Run(fmt.Sprintf("test-%d", i+1), func(t *testing.T) {
    			if got := test.sizeFilter.InRange(test.objSize); got != test.want {
    				t.Fatalf("Expected %v but got %v", test.want, got)
    			}
    		})
    	}
    }
    
    func TestBatchJobSizeValidate(t *testing.T) {
    	errInvalidBatchJobSizeFilter := BatchJobYamlErr{
    		msg: "invalid batch-job size filter",
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 08 23:22:28 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  3. internal/lock/lock_nix.go

    // This implementation doesn't support all the open
    // flags and shouldn't be considered as replacement
    // for os.OpenFile().
    func LockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
    	return lockedOpenFile(path, flag, perm, 0)
    }
    
    // Open - Call os.OpenFile
    func Open(path string, flag int, perm os.FileMode) (*os.File, error) {
    	return os.OpenFile(path, flag, perm)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  4. internal/disk/stat_linux_32bit.go

    }
    
    // getFSType returns the filesystem type of the underlying mounted filesystem
    func getFSType(ftype int32) string {
    	fsTypeHex := strconv.FormatInt(int64(ftype), 16)
    	fsTypeString, ok := fsType2StringMap[fsTypeHex]
    	if !ok {
    		return "UNKNOWN"
    	}
    	return fsTypeString
    }
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, _ bool) (info Info, err error) {
    	s := syscall.Statfs_t{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  5. src/cmd/addr2line/main.go

    	"cmd/internal/objfile"
    	"cmd/internal/telemetry/counter"
    )
    
    func printUsage(w *os.File) {
    	fmt.Fprintf(w, "usage: addr2line binary\n")
    	fmt.Fprintf(w, "reads addresses from standard input and writes two lines for each:\n")
    	fmt.Fprintf(w, "\tfunction name\n")
    	fmt.Fprintf(w, "\tfile:line\n")
    }
    
    func usage() {
    	printUsage(os.Stderr)
    	os.Exit(2)
    }
    
    func main() {
    	log.SetFlags(0)
    	log.SetPrefix("addr2line: ")
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  6. cni/pkg/plugin/cnieventclient.go

    type CNIEventClient struct {
    	client *http.Client
    	url    string
    }
    
    func buildClient(address, path string) CNIEventClient {
    	c := &http.Client{
    		Transport: &http.Transport{
    			DialContext: func(_ context.Context, _, _ string) (net.Conn, error) {
    				return net.Dial("unix", address)
    			},
    		},
    		Timeout: 5 * time.Second,
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  7. istioctl/pkg/install/k8sversion/version.go

    func CheckKubernetesVersion(versionInfo *version.Info) (bool, error) {
    	v, err := extractKubernetesVersion(versionInfo)
    	if err != nil {
    		return false, err
    	}
    	return MinK8SVersion <= v, nil
    }
    
    // extractKubernetesVersion returns the Kubernetes minor version. For example, `v1.19.1` will return `19`
    func extractKubernetesVersion(versionInfo *version.Info) (int, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 30 21:50:50 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. tests/update_test.go

    	sort.Slice(result.Pets, func(i, j int) bool {
    		return result.Pets[i].ID < result.Pets[j].ID
    	})
    	sort.Slice(result.Team, func(i, j int) bool {
    		return result.Team[i].ID < result.Team[j].ID
    	})
    	sort.Slice(result.Friends, func(i, j int) bool {
    		return result.Friends[i].ID < result.Friends[j].ID
    	})
    	sort.Slice(result2.Pets, func(i, j int) bool {
    		return result2.Pets[i].ID < result2.Pets[j].ID
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Dec 04 03:50:58 UTC 2023
    - 30.3K bytes
    - Viewed (0)
  9. istioctl/pkg/validate/validate.go

    		}
    		err = reader.Close()
    		if err != nil {
    			log.Infof("file: %s is not closed: %v", path, err)
    		}
    		warningsByFilename[path] = warning
    	}
    	processDirectory := func(directory string, processFile func(string)) error {
    		err := filepath.Walk(directory, func(path string, info os.FileInfo, err error) error {
    			if err != nil {
    				return err
    			}
    
    			if info.IsDir() {
    				return nil
    			}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 22:27:47 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  10. istioctl/pkg/workload/workload_test.go

    	for _, dir := range files {
    		if !dir.IsDir() {
    			continue
    		}
    		testdir := path.Join("testdata/vmconfig", dir.Name())
    		t.Cleanup(func() {
    			for k := range generated {
    				os.Remove(path.Join(testdir, k))
    			}
    		})
    		t.Run(dir.Name(), func(t *testing.T) {
    			createClientFunc := func(client kube.CLIClient) {
    				client.Kube().CoreV1().ServiceAccounts("bar").Create(context.Background(), &v1.ServiceAccount{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 14.6K bytes
    - Viewed (0)
Back to top