loadawarestore

package

v0.0.0-...-dcfb068 Latest Latest Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const Name commonstores.StoreName = "LoadAwareStore"

This section is empty.

func NewCache(handler handler.CacheHandler) commonstores.CommonStore

func NewSnapshot(handler handler.CacheHandler) commonstores.CommonStore

type LoadAwareStore struct {
	commonstores.BaseStore

	// NodeMetricInfo
	Store generationstore.Store
	// contains filtered or unexported fields
}

LoadAwareStore implementing the CommonStore interface.

func (s *LoadAwareStore) AddCNR(cnr *katalystv1alpha1.CustomNodeResource) error

func (s *LoadAwareStore) AddPod(pod *v1.Pod) error

func (s *LoadAwareStore) AssumePod(podInfo *framework.CachePodInfo) error

func (s *LoadAwareStore) ForgetPod(podInfo *framework.CachePodInfo) error

func (s *LoadAwareStore) GetLoadAwareNodeMetricInfo(nodeName string, resourceType podutil.PodResourceType) *framework.LoadAwareNodeMetricInfo

func (s *LoadAwareStore) GetLoadAwareNodeUsage(nodeName string, resourceType podutil.PodResourceType) *framework.LoadAwareNodeUsage

func (c *LoadAwareStore) Name() commonstores.StoreName

func (s *LoadAwareStore) RemoveCNR(cnr *katalystv1alpha1.CustomNodeResource) error

func (s *LoadAwareStore) RemovePod(pod *v1.Pod) error

func (s *LoadAwareStore) UpdateCNR(oldCNR, newCNR *katalystv1alpha1.CustomNodeResource) error

func (s *LoadAwareStore) UpdatePod(oldPod *v1.Pod, newPod *v1.Pod) error

func (s *LoadAwareStore) UpdateSnapshot(store commonstores.CommonStore) error

UpdateSnapshot synchronize the data in the Cache to Snapshot, generally using generationstore for incremental updates.

type NodeMetricInfo struct {
	// contains filtered or unexported fields
}

ATTENTION: the NodeMetricInfo's lifecycle is accompanied by CNR, not CNR.Status.NodeMetricStatus

func NewNodeMetricInfo(nodeName string, cnr *katalystv1alpha1.CustomNodeResource) *NodeMetricInfo

func (i *NodeMetricInfo) CanBeRecycle() bool

func (i *NodeMetricInfo) Clone() *NodeMetricInfo

func (i *NodeMetricInfo) GetGeneration() int64

func (i *NodeMetricInfo) PodOp(pInfo *podBasicInfo, isCacheStore, isAdd bool)

func (i *NodeMetricInfo) Reset(cnr *katalystv1alpha1.CustomNodeResource)

func (i *NodeMetricInfo) SetGeneration(generation int64)

type PodMetricInfos struct {
	ProfileMilliCPU, ProfileMEM int64
	RequestMilliCPU, RequestMEM int64
	ProfilePods                 sets.String
}

func (i *PodMetricInfos) Clone() *PodMetricInfos