Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. pkg/controller/daemon/update_test.go

    	markPodsReady(podControl.podStore)
    
    	clearExpectations(t, manager, ds, podControl)
    	expectSyncDaemonSets(t, manager, ds, podControl, 0, maxUnavailable, 0)
    	clearExpectations(t, manager, ds, podControl)
    	expectSyncDaemonSets(t, manager, ds, podControl, maxUnavailable, 0, 0)
    	markPodsReady(podControl.podStore)
    
    	clearExpectations(t, manager, ds, podControl)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 10 21:10:35 UTC 2024
    - 28.9K bytes
    - Viewed (0)
  2. pkg/registry/core/rest/storage_core.go

    		storage[resource+"/log"] = podStorage.Log
    		storage[resource+"/exec"] = podStorage.Exec
    		storage[resource+"/portforward"] = podStorage.PortForward
    		storage[resource+"/proxy"] = podStorage.Proxy
    		storage[resource+"/binding"] = podStorage.Binding
    		if podStorage.Eviction != nil {
    			storage[resource+"/eviction"] = podStorage.Eviction
    		}
    		storage[resource+"/ephemeralcontainers"] = podStorage.EphemeralContainers
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 19.1K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. okhttp/src/main/kotlin/okhttp3/CacheControl.kt

      )
      fun noCache(): Boolean = noCache
    
      @JvmName("-deprecated_noStore")
      @Deprecated(
        message = "moved to val",
        replaceWith = ReplaceWith(expression = "noStore"),
        level = DeprecationLevel.ERROR,
      )
      fun noStore(): Boolean = noStore
    
      @JvmName("-deprecated_maxAgeSeconds")
      @Deprecated(
        message = "moved to val",
        replaceWith = ReplaceWith(expression = "maxAgeSeconds"),
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 10K bytes
    - Viewed (0)
  8. pkg/registry/core/pod/storage/storage.go

    	registrypod "k8s.io/kubernetes/pkg/registry/core/pod"
    	podrest "k8s.io/kubernetes/pkg/registry/core/pod/rest"
    	"sigs.k8s.io/structured-merge-diff/v4/fieldpath"
    )
    
    // PodStorage includes storage for pods and all sub resources
    type PodStorage struct {
    	Pod                 *REST
    	Binding             *BindingREST
    	LegacyBinding       *LegacyBindingREST
    	Eviction            *EvictionREST
    	Status              *StatusREST
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 20 14:29:25 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  9. pkg/scheduler/internal/cache/cache.go

    	mu sync.RWMutex
    	// a set of assumed pod keys.
    	// The key could further be used to get an entry in podStates.
    	assumedPods sets.Set[string]
    	// a map from pod key to podState.
    	podStates map[string]*podState
    	nodes     map[string]*nodeInfoListItem
    	// headNode points to the most recently updated NodeInfo in "nodes". It is the
    	// head of the linked list.
    	headNode *nodeInfoListItem
    	nodeTree *nodeTree
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 09:56:48 UTC 2023
    - 24.9K bytes
    - Viewed (0)
  10. src/cmd/compile/internal/ssa/memcombine.go

    		mark.clear()
    		for _, v := range b.Values {
    			if v.Op == OpStore {
    				mark.add(v.MemoryArg().ID)
    			}
    		}
    
    		// pick an order for visiting stores such that
    		// later stores come earlier in the ordering.
    		order = order[:0]
    		for _, v := range b.Values {
    			if v.Op != OpStore {
    				continue
    			}
    			if mark.contains(v.ID) {
    				continue // not last in a chain of stores
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 21 19:45:41 UTC 2024
    - 18.4K bytes
    - Viewed (0)
Back to top