Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

scheduler

package

Go to main page

Versions in this module

v0

v0.3.5

Apr 25, 2024

v0.3.4

Dec 6, 2023

Changes in this version

+ var ErrNoNodesAvailable = fmt.Errorf("no nodes available to schedule qemus")

+ var ErrNoVMIDAvailable = fmt.Errorf("no vmid available to schedule qemus")

+ type CancelFunc func()

+ type Manager struct

+ func NewManager(params SchedulerParams) (*Manager, error)

+ func (m *Manager) GetOrCreateScheduler(client *proxmox.Service) *Scheduler

+ func (m *Manager) NewScheduler(client *proxmox.Service, opts ...SchedulerOption) *Scheduler

+ type Scheduler struct

+ func (s *Scheduler) CreateQEMU(ctx context.Context, config *api.VirtualMachineCreateOptions) (framework.SchedulerResult, error)

+ func (s *Scheduler) IsRunning() bool

+ func (s *Scheduler) Run()

+ func (s *Scheduler) RunAsync()

+ func (s *Scheduler) RunFilterPlugins(ctx context.Context, state *framework.CycleState, ...) ([]*api.Node, error)

+ func (s *Scheduler) RunScorePlugins(ctx context.Context, state *framework.CycleState, ...) (framework.NodeScoreList, *framework.Status)

+ func (s *Scheduler) RunVMIDPlugins(ctx context.Context, state *framework.CycleState, ...) (int, error)

+ func (s *Scheduler) ScheduleOne(ctx context.Context)

+ func (s *Scheduler) SelectNode(ctx context.Context, config api.VirtualMachineCreateOptions) (string, error)

+ func (s *Scheduler) SelectVMID(ctx context.Context, config api.VirtualMachineCreateOptions) (int, error)

+ func (s *Scheduler) Stop()

+ func (s *Scheduler) WaitStatus(ctx context.Context, config *api.VirtualMachineCreateOptions) (framework.CycleState, error)

+ func (s *Scheduler) WithCancel() (*Scheduler, CancelFunc)

+ type SchedulerOption func(s *Scheduler)

+ func WithTimeout(timeout time.Duration) SchedulerOption

+ type SchedulerParams struct

+ Logger logr.Logger

+ PluginConfigFile string

+ func (p *SchedulerParams) PluginConfigs() plugins.PluginConfigs

v0.0.0-test2

Dec 6, 2023