arbitrator

package

v1.4.1 Latest Latest Go to latest Published: Feb 26, 2024 License: Apache-2.0 Imports: 39 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/koordinator-sh/koordinator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewHandler(arbitrator Arbitrator, client client.Client) handler.EventHandler
type Arbitrator
- func New(args *config.MigrationControllerArgs, options Options) (Arbitrator, error)
type MigrationFilter
type Options
type SortFn

Constants ¶

View Source

const (
	AnnotationPassedArbitration = "descheduler.koordinator.sh/passed-arbitration"
	AnnotationPodArbitrating    = "descheduler.koordinator.sh/pod-arbitrating"
)

View Source

const (
	JobKind = "Job"
)

Variables ¶

This section is empty.

Functions ¶

func NewHandler ¶

func NewHandler(arbitrator Arbitrator, client client.Client) handler.EventHandler

Types ¶

type Arbitrator ¶

type Arbitrator interface {
	MigrationFilter
	AddPodMigrationJob(job *v1alpha1.PodMigrationJob)
	DeletePodMigrationJob(job *v1alpha1.PodMigrationJob)
}

func New ¶

func New(args *config.MigrationControllerArgs, options Options) (Arbitrator, error)

New creates an arbitratorImpl based on parameters.

type MigrationFilter ¶

type MigrationFilter interface {
	Filter(pod *corev1.Pod) bool
	PreEvictionFilter(pod *corev1.Pod) bool
	TrackEvictedPod(pod *corev1.Pod)
}

type Options ¶

type Options struct {
	Client        client.Client
	EventRecorder events.EventRecorder
	Manager       controllerruntime.Manager
	Handle        framework.Handle
}

type SortFn ¶

type SortFn func(jobs []*v1alpha1.PodMigrationJob, podOfJob map[*v1alpha1.PodMigrationJob]*corev1.Pod) []*v1alpha1.PodMigrationJob

SortFn stably sorts PodMigrationJobs slice based on a certain strategy. Users can implement different SortFn according to their needs.

func SortJobsByController ¶

func SortJobsByController() SortFn

SortJobsByController returns a SortFn that places PodMigrationJobs in the same job in adjacent positions.

func SortJobsByCreationTime ¶

func SortJobsByCreationTime() SortFn

SortJobsByCreationTime returns a SortFn that stably sorts PodMigrationJobs by create time.

func SortJobsByMigratingNum ¶

func SortJobsByMigratingNum(c client.Client) SortFn

SortJobsByMigratingNum returns a SortFn that stably sorts PodMigrationJobs the number of migrating PMJs in the same Job.

func SortJobsByPod ¶

func SortJobsByPod(sorter func(pods []*corev1.Pod)) SortFn

SortJobsByPod sort a SortFn that sorts PodMigrationJobs by their Pods, including priority, QoS.

Source Files ¶

View all Source files

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