Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewStateMemory (0.2 sec)

  1. pkg/kubelet/status/state/state_mem.go

    )
    
    type stateMemory struct {
    	sync.RWMutex
    	podAllocation   PodResourceAllocation
    	podResizeStatus PodResizeStatus
    }
    
    var _ State = &stateMemory{}
    
    // NewStateMemory creates new State to track resources allocated to pods
    func NewStateMemory() State {
    	klog.V(2).InfoS("Initialized new in-memory state store for pod resource allocation tracking")
    	return &stateMemory{
    		podAllocation:   PodResourceAllocation{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 24 18:21:21 UTC 2023
    - 4K bytes
    - Viewed (0)
  2. pkg/kubelet/status/fake_status_manager.go

    	klog.InfoS("SetPodResizeStatus()")
    	return nil
    }
    
    // NewFakeManager creates empty/fake memory manager
    func NewFakeManager() Manager {
    	return &fakeManager{
    		state: state.NewStateMemory(),
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 05:59:34 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  3. pkg/kubelet/status/state/state_checkpoint.go

    	if err != nil {
    		return nil, fmt.Errorf("failed to initialize checkpoint manager for pod allocation tracking: %v", err)
    	}
    	stateCheckpoint := &stateCheckpoint{
    		cache:             NewStateMemory(),
    		checkpointManager: checkpointManager,
    		checkpointName:    checkpointName,
    	}
    
    	if err := stateCheckpoint.restoreState(); err != nil {
    		//lint:ignore ST1005 user-facing error message
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 13 00:16:44 UTC 2023
    - 6.9K bytes
    - Viewed (0)
Back to top