evaluator

Documentation

Index

• Constants
• type Evaluator
  • func LoadPlugin(dir string) (Evaluator, error)
  • func New(algorithm string, pluginDir string) Evaluator
  • func NewEvaluatorBase() Evaluator

Constants

const (
	// DefaultAlgorithm is a rule-based scheduling algorithm
	DefaultAlgorithm = "default"

	// MLAlgorithm is a machine learning scheduling algorithm
	MLAlgorithm = "ml"

	// PluginAlgorithm is a scheduling algorithm based on plugin extension
	PluginAlgorithm = "plugin"
)

Types

type Evaluator

type Evaluator interface {
	// Evaluate todo Normalization
	Evaluate(parent *supervisor.Peer, child *supervisor.Peer, taskPieceCount int32) float64

	// NeedAdjustParent determine whether the peer needs a new parent node
	NeedAdjustParent(peer *supervisor.Peer) bool

	// IsBadNode determine if peer is a failed node
	IsBadNode(peer *supervisor.Peer) bool
}

func LoadPlugin

func LoadPlugin(dir string) (Evaluator, error)

func New

func New(algorithm string, pluginDir string) Evaluator

func NewEvaluatorBase

func NewEvaluatorBase() Evaluator