- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 42 for clone (0.81 sec)
-
istioctl/pkg/proxyconfig/proxyconfig.go
file := os.Stdin if filename != "-" { var err error file, err = os.Open(filename) if err != nil { return nil, err } } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() return io.ReadAll(file) } func setupFileConfigdumpWriter(filename string, out io.Writer) (*configdump.ConfigWriter, 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) -
cni/pkg/pluginlistener/listener_test.go
f := filepath.Join(t.TempDir(), "test") l, err := NewListener(f) if err != nil { t.Fatalf("unexpected error %v", err) } defer l.Close() conn, err := connect(f) if err != nil { t.Fatalf("failed to connect %v", err) } conn.Close() } func connect(socket string) (*grpc.ClientConn, error) { var opts []grpc.DialOption
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 21:58:32 GMT 2024 - 1.4K bytes - Viewed (0) -
istioctl/pkg/validate/validate_test.go
defer closeValidYAMLFile.Close() validFilenameJSON, closeValidJSONFile := createTestFile(t, validJSON) defer closeValidJSONFile.Close() invalidFilenameYAML, closeInvalidYAMLFile := createTestFile(t, invalidYAML) defer closeInvalidYAMLFile.Close() warningFilename, closeWarningFile := createTestFile(t, warningsYAML) defer closeWarningFile.Close()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 25 08:08:36 GMT 2023 - 21.5K bytes - Viewed (0) -
cni/pkg/nodeagent/netns.go
} type NetnsCloser interface { io.Closer Netns } type NetnsWithFd struct { netns io.Closer fd uintptr inode uint64 } func (n *NetnsWithFd) Close() error { if n.netns == nil { return nil } ret := n.netns.Close() // set fd to invalid value, so if something uses it by mistake it will err uintZero := uintptr(0) n.fd = ^uintZero return ret } func (n *NetnsWithFd) Fd() uintptr {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.2K bytes - Viewed (0) -
cni/pkg/nodeagent/healthServer_test.go
installReady, watchReady := initRouter(router) assert.Equal(t, installReady.Load(), false) assert.Equal(t, watchReady.Load(), false) server := httptest.NewServer(router) defer server.Close() makeReq(t, server.URL, constants.LivenessEndpoint, http.StatusOK) makeReq(t, server.URL, constants.ReadinessEndpoint, http.StatusServiceUnavailable) installReady.Store(true) watchReady.Store(true)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2K bytes - Viewed (0) -
istioctl/pkg/authz/authz.go
} func getConfigDumpFromFile(filename string) (*configdump.Wrapper, error) { file, err := os.Open(filename) if err != nil { return nil, err } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() data, err := io.ReadAll(file) if err != nil { return nil, err } envoyConfig := &configdump.Wrapper{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 5K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics.go
} if err = fw.Start(); err != nil { return fmt.Errorf("failure running port forward process: %v", err) } // Close the forwarder either when we exit or when an this processes is interrupted. defer fw.Close() dashboard.ClosePortForwarderOnInterrupt(fw) log.Debugf("port-forward to prometheus pod ready") promAPI, err := prometheusAPI(fmt.Sprintf("http://%s", fw.Address()))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 8.4K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
} func gatherFile(f string) (local.ReaderSource, error) { r, err := os.Open(f) if err != nil { return local.ReaderSource{}, err } runtime.SetFinalizer(r, func(x *os.File) { err = x.Close() if err != nil { log.Infof("file : %s is not closed: %v", f, err) } }) return local.ReaderSource{Name: f, Reader: r}, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0) -
cni/pkg/plugin/plugin_dryrun_test.go
} func (*mockNetNs) Set() error { return nil } func (ns *mockNetNs) Path() string { return ns.path } func (*mockNetNs) Fd() uintptr { return 0 } func (*mockNetNs) Close() error { return nil } type netNsFunc func(nspath string) (ns.NetNS, error) func generateMockGetNsFunc(netNs string) netNsFunc { return func(nspath string) (ns.NetNS, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 8.4K bytes - Viewed (0) -
cni/pkg/install/install.go
watcher, err := util.CreateFileWatcher(targets...) if err != nil { return err } defer func() { setNotReady(in.isReady) watcher.Close() }() // Before we process whether any file events have been triggered, we must check that the file is correct // at this moment, and if not, yield. This is to catch other CNIs which might have mutated the file between
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)