kubesim

Documentation

Index

• type KubeSim
  • func NewKubeSim(conf *config.Config, queue queue.PodQueue, sched scheduler.Scheduler) (*KubeSim, error)
  • func NewKubeSimFromConfigPath(confPath string, queue queue.PodQueue, sched scheduler.Scheduler) (*KubeSim, error)
  • func NewKubeSimFromConfigPathOrDie(confPath string, queue queue.PodQueue, sched scheduler.Scheduler) *KubeSim
  • func (k *KubeSim) AddSubmitter(name string, submitter submitter.Submitter)
  • func (k *KubeSim) List() ([]*v1.Node, error)
  • func (k *KubeSim) Run(ctx context.Context) error

Types

type KubeSim

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

KubeSim represents a simulated kubernetes cluster.

func NewKubeSim

func NewKubeSim(
	conf *config.Config, queue queue.PodQueue, sched scheduler.Scheduler,
) (*KubeSim, error)

NewKubeSim creates a new KubeSim with the given config, queue, and scheduler. Returns error if the configuration failed.

func NewKubeSimFromConfigPath

func NewKubeSimFromConfigPath(
	confPath string, queue queue.PodQueue, sched scheduler.Scheduler,
) (*KubeSim, error)

NewKubeSimFromConfigPath creates a new KubeSim with config from confPath (excluding file extension), queue, and scheduler. Returns error if the configuration failed.

func NewKubeSimFromConfigPathOrDie

func NewKubeSimFromConfigPathOrDie(
	confPath string, queue queue.PodQueue, sched scheduler.Scheduler,
) *KubeSim

NewKubeSimFromConfigPathOrDie creates a new KubeSim with config from confPath (excluding file extension), queue, and scheduler. If an error occurs during the initialization, it panics and stops the execution.

func (*KubeSim) AddSubmitter

func (k *KubeSim) AddSubmitter(name string, submitter submitter.Submitter)

AddSubmitter adds the new submitter to this KubeSim.

func (*KubeSim) List

func (k *KubeSim) List() ([]*v1.Node, error)

List implements "k8s.io/pkg/scheduler/algorithm".NodeLister interface. Never returns an error.

func (*KubeSim) Run

func (k *KubeSim) Run(ctx context.Context) error

Run executes the main loop, which invokes submitters and the scheduler, and binds pods to the selected nodes. This method blocks until ctx is done or this KubeSim finishes processing all pods.