- Sort Score
- Result 10 results
- Languages All
Results 751 - 760 of 1,387 for funcs (0.02 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)