Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ListenForSignal (0.12 sec)

  1. pkg/scheduler/internal/cache/debugger/debugger.go

    			PodQueue:   podQueue,
    		},
    		Dumper: CacheDumper{
    			cache:    cache,
    			podQueue: podQueue,
    		},
    	}
    }
    
    // ListenForSignal starts a goroutine that will trigger the CacheDebugger's
    // behavior when the process receives SIGINT (Windows) or SIGUSER2 (non-Windows).
    func (d *CacheDebugger) ListenForSignal(ctx context.Context) {
    	logger := klog.FromContext(ctx)
    	stopCh := ctx.Done()
    	ch := make(chan os.Signal, 1)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  2. pkg/scheduler/scheduler.go

    	}
    
    	schedulerCache := internalcache.New(ctx, durationToExpireAssumedPod)
    
    	// Setup cache debugger.
    	debugger := cachedebugger.New(nodeLister, podLister, schedulerCache, podQueue)
    	debugger.ListenForSignal(ctx)
    
    	sched := &Scheduler{
    		Cache:                    schedulerCache,
    		client:                   client,
    		nodeInfoSnapshot:         snapshot,
    		percentageOfNodesToScore: options.percentageOfNodesToScore,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
Back to top