Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SetupSignalHandler (0.23 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/signal.go

    var shutdownHandler chan os.Signal
    
    // SetupSignalHandler registered for SIGTERM and SIGINT. A stop channel is returned
    // which is closed on one of these signals. If a second signal is caught, the program
    // is terminated with exit code 1.
    // Only one of SetupSignalContext and SetupSignalHandler should be called, and only can
    // be called once.
    func SetupSignalHandler() <-chan struct{} {
    	return SetupSignalContext().Done()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 06 14:30:27 UTC 2020
    - 2K bytes
    - Viewed (0)
  2. operator/cmd/operator/server.go

    	metrics.Version.
    		With(metrics.OperatorVersionLabel.Value(version.Info.String())).
    		Record(1.0)
    
    	log.Info("Starting the Cmd.")
    
    	// Start the Cmd
    	if err := mgr.Start(signals.SetupSignalHandler()); err != nil {
    		log.Fatalf("Manager exited non-zero: %v", err)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Aug 30 21:09:08 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  3. cmd/kube-scheduler/app/server.go

    		fmt.Fprintf(os.Stderr, "%v\n", err)
    		os.Exit(1)
    	}
    	cliflag.PrintFlags(cmd.Flags())
    
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	go func() {
    		stopCh := server.SetupSignalHandler()
    		<-stopCh
    		cancel()
    	}()
    
    	cc, sched, err := Setup(ctx, opts, registryOptions...)
    	if err != nil {
    		return err
    	}
    	// add feature enablement metrics
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 14.3K bytes
    - Viewed (0)
Back to top