var _ … type stateCheckpoint … // NewStateCheckpoint creates new State for keeping track of pod resource allocations with checkpoint backend func NewStateCheckpoint(stateDir, checkpointName string) (State, error) { … } // restores state from a checkpoint and creates it if it doesn't exist func (sc *stateCheckpoint) restoreState() error { … } // saves state to a checkpoint, caller is responsible for locking func (sc *stateCheckpoint) storeState() error { … } // GetContainerResourceAllocation returns current resources allocated to a pod's container func (sc *stateCheckpoint) GetContainerResourceAllocation(podUID string, containerName string) (v1.ResourceRequirements, bool) { … } // GetPodResourceAllocation returns current pod resource allocation func (sc *stateCheckpoint) GetPodResourceAllocation() PodResourceAllocation { … } // GetPodResizeStatus returns the last resize decision for a pod func (sc *stateCheckpoint) GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) { … } // GetResizeStatus returns the set of resize decisions made func (sc *stateCheckpoint) GetResizeStatus() PodResizeStatus { … } // SetContainerResourceAllocation sets resources allocated to a pod's container func (sc *stateCheckpoint) SetContainerResourceAllocation(podUID string, containerName string, alloc v1.ResourceRequirements) error { … } // SetPodResourceAllocation sets pod resource allocation func (sc *stateCheckpoint) SetPodResourceAllocation(a PodResourceAllocation) error { … } // SetPodResizeStatus sets the last resize decision for a pod func (sc *stateCheckpoint) SetPodResizeStatus(podUID string, resizeStatus v1.PodResizeStatus) error { … } // SetResizeStatus sets the resize decisions func (sc *stateCheckpoint) SetResizeStatus(rs PodResizeStatus) error { … } // Delete deletes allocations for specified pod func (sc *stateCheckpoint) Delete(podUID string, containerName string) error { … } // ClearState clears the state and saves it in a checkpoint func (sc *stateCheckpoint) ClearState() error { … } type noopStateCheckpoint … // NewNoopStateCheckpoint creates a dummy state checkpoint manager func NewNoopStateCheckpoint() State { … } func (sc *noopStateCheckpoint) GetContainerResourceAllocation(_ string, _ string) (v1.ResourceRequirements, bool) { … } func (sc *noopStateCheckpoint) GetPodResourceAllocation() PodResourceAllocation { … } func (sc *noopStateCheckpoint) GetPodResizeStatus(_ string) (v1.PodResizeStatus, bool) { … } func (sc *noopStateCheckpoint) GetResizeStatus() PodResizeStatus { … } func (sc *noopStateCheckpoint) SetContainerResourceAllocation(_ string, _ string, _ v1.ResourceRequirements) error { … } func (sc *noopStateCheckpoint) SetPodResourceAllocation(_ PodResourceAllocation) error { … } func (sc *noopStateCheckpoint) SetPodResizeStatus(_ string, _ v1.PodResizeStatus) error { … } func (sc *noopStateCheckpoint) SetResizeStatus(_ PodResizeStatus) error { … } func (sc *noopStateCheckpoint) Delete(_ string, _ string) error { … } func (sc *noopStateCheckpoint) ClearState() error { … }
Codebase Browser
kubernetes