kubesim

package

v0.0.0-...-57dc925 Latest Latest Go to latest Published: Aug 12, 2022 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/elchead/k8s-cluster-simulator

Documentation ¶

Index ¶

func ReadConfig(path string) (*config.Config, error)
type KubeSim
- func NewKubeSim(conf *config.Config, queue queue.PodQueue, sched scheduler.Scheduler, ...) (*KubeSim, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ReadConfig ¶

func ReadConfig(path string) (*config.Config, error)

ReadConfig reads and parses a config from the path (excluding file extension).

Types ¶

type KubeSim ¶

type KubeSim struct {
	Clock clock.Clock

	MigrationClient *migration.Client
	// contains filtered or unexported fields
}

KubeSim represents a simulated kubernetes cluster.

func NewKubeSim ¶

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

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

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.

Source Files ¶

View all Source files

kubesim.go

Directories ¶

Path	Synopsis
clock
config
jobparser
log
metrics
migration
node
pod
queue
scheduler
submitter
util

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL