cache

Documentation

Index

• type Cache
  • func NewCache(clusterLister clusterlister.ClusterLister) Cache
• type Snapshot
  • func NewEmptySnapshot() Snapshot
  • func (s *Snapshot) GetCluster(clusterName string) *framework.ClusterInfo
  • func (s *Snapshot) GetClusters() []*framework.ClusterInfo
  • func (s *Snapshot) GetReadyClusterNames() sets.Set[string]
  • func (s *Snapshot) GetReadyClusters() []*framework.ClusterInfo
  • func (s *Snapshot) NumOfClusters() int

Types

type Cache

type Cache interface {
	AddCluster(cluster *clusterv1alpha1.Cluster)
	UpdateCluster(cluster *clusterv1alpha1.Cluster)
	DeleteCluster(cluster *clusterv1alpha1.Cluster)
	// Snapshot returns a snapshot of the current clusters info
	Snapshot() Snapshot
}

Cache is an interface for scheduler internal cache.

func NewCache

func NewCache(clusterLister clusterlister.ClusterLister) Cache

NewCache instantiates a cache used only by scheduler.

type Snapshot

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

Snapshot is a snapshot of cache ClusterInfo. The scheduler takes a snapshot at the beginning of each scheduling cycle and uses it for its operations in that cycle.

func NewEmptySnapshot

func NewEmptySnapshot() Snapshot

NewEmptySnapshot initializes a Snapshot struct and returns it.

func (*Snapshot) GetCluster

func (s *Snapshot) GetCluster(clusterName string) *framework.ClusterInfo

GetCluster returns the given clusters.

func (*Snapshot) GetClusters

func (s *Snapshot) GetClusters() []*framework.ClusterInfo

GetClusters returns all the clusters.

func (*Snapshot) GetReadyClusterNames

func (s *Snapshot) GetReadyClusterNames() sets.Set[string]

GetReadyClusterNames returns the clusterNames in ready status.

func (*Snapshot) GetReadyClusters

func (s *Snapshot) GetReadyClusters() []*framework.ClusterInfo

GetReadyClusters returns the clusters in ready status.

func (*Snapshot) NumOfClusters

func (s *Snapshot) NumOfClusters() int

NumOfClusters returns the number of clusters.