scheduler

Aug 30, 2024

Changes in this version

type Scheduler

+ func (s *Scheduler) GetUpdatedByExtender(moduleName string) (string, error)

Jul 3, 2024

Changes in this version

+ type Scheduler struct

+ func NewScheduler(ctx context.Context) *Scheduler

+ func (s *Scheduler) AddExtender(ext extenders.Extender) error

+ func (s *Scheduler) AddModuleVertex(module node.ModuleInterface) error

+ func (s *Scheduler) AddWeightVertex(vertex *node.Node) error

+ func (s *Scheduler) ApplyExtenders(extendersEnv string) error

+ func (s *Scheduler) EventCh() chan extenders.ExtenderEvent

+ func (s *Scheduler) Filter(extName extenders.ExtenderName, moduleName string, logLabels map[string]string) (*bool, error)

+ func (s *Scheduler) GetEnabledModuleNames() []string

+ func (s *Scheduler) GetGraphImage() (image.Image, error)

+ func (s *Scheduler) GetGraphState(logLabels map[string]string) ([]string, map[string]bool, error)

+ func (s *Scheduler) GetModuleNodes() ([]*node.Node, error)

+ func (s *Scheduler) IsModuleEnabled(moduleName string) bool

+ func (s *Scheduler) PrintSummary() (map[string]bool, error)

+ func (s *Scheduler) RecalculateGraph(logLabels map[string]string) (bool, []string)