INNER CODE UNIT · Go

runLoop

kumahq/kuma · app/cni/pkg/install/main.go:255

func runLoop(ic *InstallerConfig) error {
	defer cleanup(ic)
	osSignals := make(chan os.Signal, 1)
	signal.Notify(osSignals, syscall.SIGHUP, syscall.SIGINT, syscall.SIGTERM, syscall.SIGQUIT)

	if !ic.ShouldSleep {
		return nil
	}

	checkInstallTicker := time.NewTicker(time.Duration(ic.CfgCheckInterval) * time.Second)
	refreshSATokenTicker := time.NewTicker(time.Duration(ic.RefreshSATokenInterval) * time.Second)
	defer checkInstallTicker.Stop()
	defer refreshSATokenTicker.Stop()

	for {
		select {
		case <-osSignals:
			return nil

View source record →