Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newControllerWithClock (0.14 sec)

  1. pkg/controller/job/job_controller.go

    func NewController(ctx context.Context, podInformer coreinformers.PodInformer, jobInformer batchinformers.JobInformer, kubeClient clientset.Interface) (*Controller, error) {
    	return newControllerWithClock(ctx, podInformer, jobInformer, kubeClient, &clock.RealClock{})
    }
    
    func newControllerWithClock(ctx context.Context, podInformer coreinformers.PodInformer, jobInformer batchinformers.JobInformer, kubeClient clientset.Interface, clock clock.WithTicker) (*Controller, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller_test.go

    	t.Helper()
    	sharedInformers := informers.NewSharedInformerFactory(kubeClient, resyncPeriod())
    	jm, err := newControllerWithClock(ctx, sharedInformers.Core().V1().Pods(), sharedInformers.Batch().V1().Jobs(), kubeClient, clock)
    	if err != nil {
    		t.Fatalf("Error creating Job controller: %v", err)
    	}
    	jm.podControl = &controller.FakePodControl{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
Back to top