Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 85 for podstore (0.18 sec)

  1. pkg/kubelet/cm/topologymanager/scope_pod_test.go

    				{
    					"resource-3": nil,
    				},
    			},
    		},
    	}
    
    	for _, tc := range tcases {
    		podScope := &podScope{
    			scope{
    				hintProviders: tc.hp,
    				policy:        &mockPolicy{},
    				name:          podTopologyScope,
    			},
    		}
    
    		podScope.calculateAffinity(&v1.Pod{})
    		actual := podScope.policy.(*mockPolicy).ph
    		if !reflect.DeepEqual(tc.expected, actual) {
    			t.Errorf("Test Case: %s", tc.name)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 12 11:25:55 UTC 2020
    - 6.1K bytes
    - Viewed (0)
  2. src/cmd/compile/internal/ssa/rewritedec.go

    		}
    		imag := v_1.Args[1]
    		real := v_1.Args[0]
    		mem := v_2
    		if !(t.Size() == 8) {
    			break
    		}
    		v.reset(OpStore)
    		v.Aux = typeToAux(typ.Float32)
    		v0 := b.NewValue0(v.Pos, OpOffPtr, typ.Float32Ptr)
    		v0.AuxInt = int64ToAuxInt(4)
    		v0.AddArg(dst)
    		v1 := b.NewValue0(v.Pos, OpStore, types.TypeMem)
    		v1.Aux = typeToAux(typ.Float32)
    		v1.AddArg3(dst, real, mem)
    		v.AddArg3(v0, imag, v1)
    		return true
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 12 00:48:31 UTC 2023
    - 24.9K bytes
    - Viewed (0)
  3. 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)
  4. pkg/kubelet/cm/topologymanager/scope_pod.go

    	"k8s.io/kubernetes/pkg/kubelet/lifecycle"
    	"k8s.io/kubernetes/pkg/kubelet/metrics"
    )
    
    type podScope struct {
    	scope
    }
    
    // Ensure podScope implements Scope interface
    var _ Scope = &podScope{}
    
    // NewPodScope returns a pod scope.
    func NewPodScope(policy Policy) Scope {
    	return &podScope{
    		scope{
    			name:             podTopologyScope,
    			podTopologyHints: podTopologyHints{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 14:44:24 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  5. 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)
  6. pkg/kubelet/util/pod_startup_latency_tracker_test.go

    				podState.firstStartedPulling.Add(time.Second*10), podState.firstStartedPulling)
    		}
    		if !podState.lastFinishedPulling.Equal(frozenTime.Add(time.Second * 20)) { // should be updated when the pod's last image finished pulling
    			t.Errorf("expected pod lastFinishedPulling: %s but got lastFinishedPulling: %s",
    				podState.lastFinishedPulling.Add(time.Second*20), podState.lastFinishedPulling)
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 15 06:09:49 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  7. src/cmd/compile/internal/ssa/_gen/RISCV64.rules

    (Zero [16] {t} ptr mem) && t.Alignment()%8 == 0 =>
    	(MOVDstore [8] ptr (MOVDconst [0])
    		(MOVDstore ptr (MOVDconst [0]) mem))
    (Zero [24] {t} ptr mem) && t.Alignment()%8 == 0 =>
    	(MOVDstore [16] ptr (MOVDconst [0])
    		(MOVDstore [8] ptr (MOVDconst [0])
    			(MOVDstore ptr (MOVDconst [0]) mem)))
    (Zero [32] {t} ptr mem) && t.Alignment()%8 == 0 =>
    	(MOVDstore [24] ptr (MOVDconst [0])
    		(MOVDstore [16] ptr (MOVDconst [0])
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 14:57:07 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/CacheControlJvmTest.kt

    import org.junit.jupiter.api.Test
    
    class CacheControlJvmTest {
      @Test
      @Throws(Exception::class)
      fun completeBuilder() {
        val cacheControl =
          CacheControl.Builder()
            .noCache()
            .noStore()
            .maxAge(1, TimeUnit.SECONDS)
            .maxStale(2, TimeUnit.SECONDS)
            .minFresh(3, TimeUnit.SECONDS)
            .onlyIfCached()
            .noTransform()
            .immutable()
            .build()
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  9. 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)
  10. pkg/controller/ttl/ttl_controller_test.go

    		},
    	}
    
    	for i, testCase := range testCases {
    		fakeClient := &fake.Clientset{}
    		nodeStore := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{})
    		nodeStore.Add(testCase.node)
    		ttlController := &Controller{
    			kubeClient:        fakeClient,
    			nodeStore:         listers.NewNodeLister(nodeStore),
    			desiredTTLSeconds: testCase.desiredTTL,
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top