Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for workqueue (0.14 sec)

  1. pkg/controller/garbagecollector/garbagecollector_test.go

    			informersStarted: alwaysStarted,
    			graphChanges:     workqueue.NewTypedRateLimitingQueue(workqueue.DefaultTypedControllerRateLimiter[*event]()),
    			uidToNode: &concurrentUIDToNode{
    				uidToNodeLock: sync.RWMutex{},
    				uidToNode:     make(map[types.UID]*node),
    			},
    			attemptToDelete:  workqueue.NewTypedRateLimitingQueue(workqueue.DefaultTypedControllerRateLimiter[*node]()),
    			absentOwnerCache: NewReferenceCache(2),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  2. okhttp-android/src/main/baseline-prof.txt

    HSPLkotlinx/coroutines/scheduling/WorkQueue;-><clinit>()V
    HSPLkotlinx/coroutines/scheduling/WorkQueue;-><init>()V
    HSPLkotlinx/coroutines/scheduling/WorkQueue;->pollBuffer()Lkotlinx/coroutines/scheduling/Task;
    HSPLkotlinx/coroutines/scheduling/WorkQueue;->tryStealLastScheduled(Lkotlinx/coroutines/scheduling/WorkQueue;Z)J
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Mar 21 11:22:00 UTC 2022
    - 127.9K bytes
    - Viewed (1)
  3. pkg/kubelet/kubelet_test.go

    	pods[2].Status.StartTime = &startTime
    	pods[2].Spec.ActiveDeadlineSeconds = &exceededActiveDeadlineSeconds
    
    	kubelet.podManager.SetPods(pods)
    	kubelet.workQueue.Enqueue(pods[2].UID, 0)
    	kubelet.workQueue.Enqueue(pods[3].UID, 30*time.Second)
    	kubelet.workQueue.Enqueue(pods[4].UID, 2*time.Minute)
    
    	clock.Step(1 * time.Minute)
    
    	expected := []*v1.Pod{pods[2], pods[3], pods[0]}
    	podsToSync := kubelet.getPodsToSync()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet.go

    	}
    	klet.containerLogManager = containerLogManager
    
    	klet.reasonCache = NewReasonCache()
    	klet.workQueue = queue.NewBasicWorkQueue(klet.clock)
    	klet.podWorkers = newPodWorkers(
    		klet,
    		kubeDeps.Recorder,
    		klet.workQueue,
    		klet.resyncInterval,
    		backOffPeriod,
    		klet.podCache,
    	)
    
    	runtime, err := kuberuntime.NewKubeGenericRuntimeManager(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (1)
  5. pkg/controller/job/job_controller_test.go

    	fakePodControl.Err = nil
    	manager.processNextWorkItem(context.TODO())
    	verifyEmptyQueue(ctx, t, manager)
    }
    
    var _ workqueue.TypedRateLimitingInterface[string] = &fakeRateLimitingQueue{}
    
    type fakeRateLimitingQueue struct {
    	workqueue.TypedInterface[string]
    	requeues int
    	item     string
    	duration time.Duration
    }
    
    func (f *fakeRateLimitingQueue) AddRateLimited(item string) {}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.5.md

    * The implicit registration of Prometheus metrics for workqueue has been removed, and a plug-able interface was added. If you were using workqueue in your own binaries and want these metrics, add the following to your imports in the main package: "k8s.io/pkg/util/workqueue/prometheus". ([#33792](https://github.com/kubernetes/kubernetes/pull/33792), [@caesarxuchao](https://github.com/caesarxuchao))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 136.4K bytes
    - Viewed (0)
  7. pkg/controller/daemon/daemon_controller_test.go

    	"k8s.io/client-go/kubernetes/fake"
    	core "k8s.io/client-go/testing"
    	"k8s.io/client-go/tools/cache"
    	"k8s.io/client-go/tools/record"
    	"k8s.io/client-go/util/flowcontrol"
    	"k8s.io/client-go/util/workqueue"
    	"k8s.io/klog/v2"
    	"k8s.io/klog/v2/ktesting"
    	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
    	api "k8s.io/kubernetes/pkg/apis/core"
    	"k8s.io/kubernetes/pkg/apis/scheduling"
    	"k8s.io/kubernetes/pkg/controller"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.4.md

    * Name the job created by scheduledjob (sj) deterministically with sj's name and a hash of job's scheduled time. ([#30420](https://github.com/kubernetes/kubernetes/pull/30420), [@janetkuo](https://github.com/janetkuo))
    * add metrics for workqueues ([#30296](https://github.com/kubernetes/kubernetes/pull/30296), [@deads2k](https://github.com/deads2k))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 133.5K bytes
    - Viewed (0)
Back to top