- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for interrupt (0.16 sec)
-
cni/test/install_cni.go
// the CNI binary installed. if err := installer.Run(ctx); err != nil { if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) { // Error was caused by interrupt/termination signal t.Logf("installer complete: %v", err) } else { t.Errorf("installer failed: %v", err) } } if cleanErr := installer.Cleanup(); cleanErr != nil {
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) -
cni/pkg/cmd/root.go
if err = installer.Run(ctx); err != nil { if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) { log.Infof("installer complete: %v", err) // Error was caused by interrupt/termination signal err = nil } else { log.Errorf("installer failed: %v", err) } } if cleanErr := installer.Cleanup(); cleanErr != nil { if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/cmd/install-cni/main.go
"istio.io/istio/pkg/log" ) func main() { // Create context that cancels on termination signal ctx, cancel := context.WithCancel(context.Background()) sigChan := make(chan os.Signal, 1) signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM) go func(sigChan chan os.Signal, cancel context.CancelFunc) { sig := <-sigChan log.Infof("Exit signal received: %s", sig) cancel() }(sigChan, cancel) rootCmd := cmd.GetCommand()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.2K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
return fmt.Errorf("failure running port forward process: %v", err) } func ClosePortForwarderOnInterrupt(fw kube.PortForwarder) { go func() { signals := make(chan os.Signal, 1) signal.Notify(signals, os.Interrupt) defer signal.Stop(signals) <-signals fw.Close() }() } func openBrowser(url string, writer io.Writer, browser bool) { var err error fmt.Fprintf(writer, "%s\n", url)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_intercept_rule_mgr.go
Ben Leggett <******@****.***> 1707525115 -0500
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 940 bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
}, "log_level": "debug", "cni_event_address": "%s", "ambient_enabled": %t, "kubernetes": { "k8s_api_root": "APIRoot", "kubeconfig": "testK8sConfig", "intercept_type": "%s", "node_name": "testNodeName", "exclude_namespaces": ["testExcludeNS"], "cni_bin_dir": "/testDirectory" } }` type mockInterceptRuleMgr struct { lastRedirect []*Redirect
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
iptablesBuilder.AppendRule( iptableslog.UndefinedCommand, ChainInpodOutput, iptablesconstants.NAT, "-d", hostProbeSNAT.String(), "-p", "tcp", "-m", "tcp", "-j", "ACCEPT", ) // prevent intercept traffic from app ==> app by pod ip iptablesBuilder.AppendVersionedRule("127.0.0.1/32", "::1/128", iptableslog.UndefinedCommand, ChainInpodPrerouting, iptablesconstants.MANGLE,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/server-main.go
} logger.EnableJSON() return output, nil } // serverMain handler called for 'minio server' command. func serverMain(ctx *cli.Context) { var warnings []string signal.Notify(globalOSSignalCh, os.Interrupt, syscall.SIGTERM, syscall.SIGQUIT) go handleSignals() setDefaultProfilerRates() // Initialize globalConsoleSys system bootstrapTrace("newConsoleLogger", func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (1) -
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())) if err != nil {
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) -
cmd/endpoint.go
// This is needed as the remote hosts are sometime // not available immediately. select { case <-globalOSSignalCh: return fmt.Errorf("The endpoint resolution got interrupted") default: for i, resolved := range resolvedList { if resolved { // Continue if host is already resolved. continue } if endpoints[i].Host == "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0)