- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ClaimInfoStateList (0.2 sec)
-
pkg/kubelet/cm/dra/state/state_checkpoint.go
func (sc *stateCheckpoint) Store(claimInfoStateList ClaimInfoStateList) error { sc.Lock() defer sc.Unlock() return sc.store(claimInfoStateList) } // saves state to a checkpoint, caller is responsible for locking func (sc *stateCheckpoint) store(claimInfoStateList ClaimInfoStateList) error { checkpoint := NewDRAManagerCheckpoint() checkpoint.Entries = claimInfoStateList
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:27 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/kubelet/cm/dra/claiminfo.go
func (cache *claimInfoCache) syncToCheckpoint() error { claimInfoStateList := make(state.ClaimInfoStateList, 0, len(cache.claimInfo)) for _, infoClaim := range cache.claimInfo { claimInfoStateList = append(claimInfoStateList, infoClaim.ClaimInfoState) } return cache.state.Store(claimInfoStateList)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:31 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/kubelet/cm/dra/state/state_checkpoint_test.go
) const testingCheckpoint = "dramanager_checkpoint_test" // assertStateEqual marks provided test as failed if provided states differ func assertStateEqual(t *testing.T, restoredState, expectedState ClaimInfoStateList) { assert.Equal(t, expectedState, restoredState, "expected ClaimInfoState does not equal to restored one") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:13 UTC 2024 - 11.9K bytes - Viewed (0)