Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ClaimInfoStateList (0.45 sec)

  1. 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)
  2. pkg/kubelet/cm/dra/state/checkpoint.go

    const checkpointVersion = "v1"
    
    // DRAManagerCheckpoint struct is used to store pod dynamic resources assignments in a checkpoint
    type DRAManagerCheckpoint struct {
    	Version  string             `json:"version"`
    	Entries  ClaimInfoStateList `json:"entries,omitempty"`
    	Checksum checksum.Checksum  `json:"checksum"`
    }
    
    // DraManagerCheckpoint struct is an old implementation of the DraManagerCheckpoint
    type DRAManagerCheckpointWithoutResourceHandles struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 15:23:10 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  3. 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)
  4. 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)
Back to top