searcher

Documentation

Index

• Constants
• func Evaluate(conditions map[string]string, scopes Scopes, cluster model.SchedulerCluster) float64
• func FilterSchedulerClusters(conditions map[string]string, schedulerClusters []model.SchedulerCluster) []model.SchedulerCluster
• type Scopes
• type Searcher
  • func LoadPlugin(dir string) (Searcher, error)
  • func New(pluginDir string) Searcher

Constants

const (
	// Condition security domain key.
	ConditionSecurityDomain = "security_domain"

	// Condition IDC key.
	ConditionIDC = "idc"

	// Condition netTopology key.
	ConditionNetTopology = "net_topology"

	// Condition location key.
	ConditionLocation = "location"
)

Functions

func Evaluate

func Evaluate(conditions map[string]string, scopes Scopes, cluster model.SchedulerCluster) float64

Evaluate the degree of matching between scheduler cluster and dfdaemon.

func FilterSchedulerClusters

func FilterSchedulerClusters(conditions map[string]string, schedulerClusters []model.SchedulerCluster) []model.SchedulerCluster

Filter the scheduler clusters that dfdaemon can be used.

Types

type Scopes

type Scopes struct {
	IDC         string `mapstructure:"idc"`
	Location    string `mapstructure:"location"`
	NetTopology string `mapstructure:"net_topology"`
}

Scheduler cluster scopes.

type Searcher

type Searcher interface {
	// FindSchedulerClusters finds scheduler clusters that best matches the evaluation.
	FindSchedulerClusters(context.Context, []model.SchedulerCluster, *managerv1.ListSchedulersRequest) ([]model.SchedulerCluster, error)
}

func LoadPlugin

func LoadPlugin(dir string) (Searcher, error)

func New

func New(pluginDir string) Searcher