Versions in this module Expand all Collapse all v0 v0.1.0 Oct 30, 2025 Changes in this version + func ComputeStrategyFingerprint(strategies []*domain.SchedulingStrategy) string + func GetKubernetesPod(podUID string) (apiv1.Pod, bool) + func SetKubernetesPodCache(podUID string, pod apiv1.Pod) + func StartPodWatcher(cache *StrategyCache, kubeClient *kubernetes.Clientset) (stopCh chan struct{}, err error) + type PodChangeDetector struct + func NewPodChangeDetector() *PodChangeDetector + func (d *PodChangeDetector) ComputeFingerprint(pods []*domain.PodInfo) string + type PodEvent struct + Pod apiv1.Pod + Type string + type PodFingerprint struct + Processes []ProcessFingerprint + UID string + type PodWatcher struct + func NewPodWatcher() *PodWatcher + func (w *PodWatcher) OnPodChange(callback func()) + func (w *PodWatcher) SimulateEvent(event PodEvent) + func (w *PodWatcher) Start() error + func (w *PodWatcher) Stop() + type ProcessFingerprint struct + Command string + PID int + type StrategyCache struct + func NewStrategyCache() *StrategyCache + func NewStrategyCacheWithTTL(ttl time.Duration) *StrategyCache + func (c *StrategyCache) GetCacheHits() int + func (c *StrategyCache) GetCacheMisses() int + func (c *StrategyCache) GetStats() map[string]interface{} + func (c *StrategyCache) GetStrategies(currentPods []*domain.PodInfo, inputStrategies []*domain.SchedulingStrategy) []*domain.SchedulingStrategy + func (c *StrategyCache) GetStrategiesQuick(inputStrategies []*domain.SchedulingStrategy) []*domain.SchedulingStrategy + func (c *StrategyCache) HasPodsChanged(pods []*domain.PodInfo) bool + func (c *StrategyCache) Invalidate() + func (c *StrategyCache) IsValid() bool + func (c *StrategyCache) SetStrategies(strategies []*domain.SchedulingStrategy) + func (c *StrategyCache) UpdatePodSnapshot(pods []*domain.PodInfo) + func (c *StrategyCache) UpdateStrategySnapshot(strategies []*domain.SchedulingStrategy)
Go to main page