framework

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

type ClusterScore struct {
	Cluster *clusterv1alpha1.Cluster
	Score   int64
}

type ClusterScoreList []ClusterScore

type ClusterToResultMap map[string]*Result

type Code int

type Diagnosis struct {
	ClusterToResultMap ClusterToResultMap
}

type FilterContext struct {
	// Context is the scheduling context.
	Context context.Context

	// BindingSpec contains the resource binding specification.
	BindingSpec *workv1alpha2.ResourceBindingSpec

	// BindingStatus contains the resource binding status.
	BindingStatus *workv1alpha2.ResourceBindingStatus

	// Cluster is the cluster being evaluated.
	Cluster *clusterv1alpha1.Cluster

	// ResourceBindingIndexer provides access to ResourceBindings for advanced scheduling logic.
	ResourceBindingIndexer cache.Indexer

	// AssigningBindings stores the ResourceBindings that are in the "assigning" state.
	AssigningBindings map[string]*workv1alpha2.ResourceBinding
}

type FilterPlugin interface {
	Plugin
	// Filter is called by the scheduling framework.
	Filter(ctx context.Context, bindingSpec *workv1alpha2.ResourceBindingSpec, bindingStatus *workv1alpha2.ResourceBindingStatus, cluster *clusterv1alpha1.Cluster) *Result
}

type FilterPluginWithContext interface {
	Plugin
	// FilterWithContext is called by the scheduling framework with consolidated parameters.
	FilterWithContext(filterCtx *FilterContext) *Result
}

type FitError struct {
	NumAllClusters int
	Diagnosis      Diagnosis
}

type Framework interface {

	// RunFilterPlugins runs the set of configured Filter plugins for resources on the given cluster.
	RunFilterPlugins(filterCtx *FilterContext) *Result

	// RunScorePlugins runs the set of configured Score plugins, it returns a map of plugin names to scores
	RunScorePlugins(ctx context.Context, spec *workv1alpha2.ResourceBindingSpec, clusters []*clusterv1alpha1.Cluster) (PluginToClusterScores, *Result)
}

type Plugin interface {
	Name() string
}

type PluginToClusterScores map[string]ClusterScoreList

type PluginToResult map[string]*Result

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

type ScoreExtensions interface {
	// NormalizeScore is called for all cluster scores produced
	// by the same plugin's "Score"
	NormalizeScore(ctx context.Context, scores ClusterScoreList) *Result
}

type ScorePlugin interface {
	Plugin
	// Score is called on each filtered cluster. It must return success and an integer
	// indicating the rank of the cluster. All scoring plugins must return success or
	// the resource will be rejected.
	Score(ctx context.Context, spec *workv1alpha2.ResourceBindingSpec, cluster *clusterv1alpha1.Cluster) (int64, *Result)

	// ScoreExtensions returns a ScoreExtensions interface
	// if it implements one, or nil if does not.
	ScoreExtensions() ScoreExtensions
}

type UnschedulableError struct {
	Message string
}