Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 33 for podstore (0.2 sec)

  1. pkg/controller/disruption/disruption_test.go

    	}
    	add(t, dc.pdbStore, pdb)
    
    	pod1, _ := newPod(t, "p1")
    	pod1.DeletionTimestamp = &metav1.Time{Time: dc.clock.Now()}
    	pod2, _ := newPod(t, "p2")
    	pod3, _ := newPod(t, "p3")
    
    	add(t, dc.podStore, pod1)
    	add(t, dc.podStore, pod2)
    	add(t, dc.podStore, pod3)
    
    	dc.sync(ctx, pdbName)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 50K bytes
    - Viewed (0)
  2. pkg/controller/daemon/daemon_controller_test.go

    		if err != nil {
    			t.Fatal(err)
    		}
    		addNodes(manager.nodeStore, 0, 5, nil)
    		addNodes(manager.nodeStore, 5, 5, simpleNodeLabel)
    		addPods(manager.podStore, "node-0", simpleDaemonSetLabel2, ds, 2)
    		addPods(manager.podStore, "node-1", simpleDaemonSetLabel, ds, 3)
    		addPods(manager.podStore, "node-1", simpleDaemonSetLabel2, ds, 1)
    		addPods(manager.podStore, "node-4", simpleDaemonSetLabel, ds, 1)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
  3. pkg/controller/endpointslice/endpointslice_controller_test.go

    	ns := metav1.NamespaceDefault
    
    	pod1 := newPod(1, ns, true, 0, false)
    	esController.podStore.Add(pod1)
    
    	// ensure this pod will not match the selector
    	pod2 := newPod(2, ns, true, 0, false)
    	pod2.Labels["foo"] = "boo"
    	esController.podStore.Add(pod2)
    
    	standardSyncService(t, esController, ns, "testing-1")
    	expectActions(t, client.Actions(), 1, "create", "endpointslices")
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  4. pkg/registry/core/serviceaccount/storage/storage_test.go

    		StorageConfig:           etcdStorage,
    		Decorator:               generic.UndecoratedStorage,
    		DeleteCollectionWorkers: 1,
    		ResourcePrefix:          "serviceaccounts",
    	}
    	// set issuer, podStore and secretStore to allow the token endpoint to be initialised
    	rest, err := NewREST(restOptions, fakeTokenGenerator{"fake"}, nil, 0, panicGetter{}, panicGetter{}, nil, false)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  5. pkg/controller/job/job_controller.go

    	finalizerExpectations *uidTrackingExpectations
    
    	// A store of jobs
    	jobLister batchv1listers.JobLister
    
    	// A store of pods, populated by the podController
    	podStore corelisters.PodLister
    
    	// Jobs that need to be updated
    	queue workqueue.TypedRateLimitingInterface[string]
    
    	// Orphan deleted pods that still have a Job tracking finalizer to be removed
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  6. pkg/controller/job/job_controller_test.go

    	pod, err = clientset.CoreV1().Pods(pod.GetNamespace()).Create(ctx, pod, metav1.CreateOptions{})
    	if err != nil {
    		t.Fatalf("Creating pod: %v", err)
    	}
    
    	// Await for the Pod to appear in the podStore to ensure that the pod exists when cleaning up the Job.
    	// In a production environment, there wouldn't be these guarantees, but the Pod would be cleaned up
    	// by the orphan pod worker, when the Pod finishes.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  7. pkg/kubelet/config/config.go

    func (c *PodConfig) Sync() {
    	c.pods.sync()
    }
    
    // podStorage manages the current pod state at any point in time and ensures updates
    // to the channel are delivered in order.  Note that this object is an in-memory source of
    // "truth" and on creation contains zero entries.  Once all previously read sources are
    // available, then this object should be considered authoritative.
    type podStorage struct {
    	podLock sync.RWMutex
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/-CacheControlCommon.kt

        .onlyIfCached()
        .maxStale(Int.MAX_VALUE.seconds)
        .build()
    
    internal fun CacheControl.Builder.commonBuild(): CacheControl {
      return CacheControl(
        noCache = noCache,
        noStore = noStore,
        maxAgeSeconds = maxAgeSeconds,
        sMaxAgeSeconds = -1,
        isPrivate = false,
        isPublic = false,
        mustRevalidate = false,
        maxStaleSeconds = maxStaleSeconds,
        minFreshSeconds = minFreshSeconds,
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  9. pkg/registry/core/service/storage/storage_test.go

    		default:
    			t.Fatalf("Unknown IPFamily: %v", fam)
    		}
    	}
    
    	portAlloc := makePortAllocator(*(machineryutilnet.ParsePortRangeOrDie("30000-32767")))
    
    	// Not all tests will specify pods and endpoints.
    	podStorage, err := podstore.NewStorage(generic.RESTOptions{
    		StorageConfig:           etcdStorage,
    		Decorator:               generic.UndecoratedStorage,
    		DeleteCollectionWorkers: 3,
    		ResourcePrefix:          "pods",
    	}, nil, nil, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 440.2K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/CacheControlTest.kt

      fun emptyBuilderIsEmpty() {
        val cacheControl = CacheControl.Builder().build()
        assertThat(cacheControl.toString()).isEqualTo("")
        assertThat(cacheControl.noCache).isFalse()
        assertThat(cacheControl.noStore).isFalse()
        assertThat(cacheControl.maxAgeSeconds).isEqualTo(-1)
        assertThat(cacheControl.sMaxAgeSeconds).isEqualTo(-1)
        assertThat(cacheControl.isPrivate).isFalse()
        assertThat(cacheControl.isPublic).isFalse()
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 2.7K bytes
    - Viewed (0)
Back to top