evaluator

Documentation

Index

• func Register(name string, evaluator Evaluator)
• type Evaluator
  • func Get(name string) Evaluator
• type Factory
  • func NewEvaluatorFactory(cfg *config.SchedulerConfig) *Factory
  • func (ef *Factory) Evaluate(dst *supervisor.Peer, src *supervisor.Peer) float64
  • func (ef *Factory) IsBadNode(peer *supervisor.Peer) bool
  • func (ef *Factory) NeedAdjustParent(peer *supervisor.Peer) bool
  • func (ef *Factory) Register(name string, evaluator Evaluator)
  • func (ef *Factory) RegisterGetEvaluatorFunc(priority int, fun getEvaluatorFunc)

Functions

func Register

func Register(name string, evaluator Evaluator)

Types

type Evaluator

type Evaluator interface {

	// Evaluate todo Normalization
	Evaluate(parent *supervisor.Peer, child *supervisor.Peer) 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 Get

func Get(name string) Evaluator

type Factory

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

func NewEvaluatorFactory

func NewEvaluatorFactory(cfg *config.SchedulerConfig) *Factory

func (*Factory) Evaluate

func (ef *Factory) Evaluate(dst *supervisor.Peer, src *supervisor.Peer) float64

func (*Factory) IsBadNode

func (ef *Factory) IsBadNode(peer *supervisor.Peer) bool

func (*Factory) NeedAdjustParent

func (ef *Factory) NeedAdjustParent(peer *supervisor.Peer) bool

func (*Factory) Register

func (ef *Factory) Register(name string, evaluator Evaluator)

func (*Factory) RegisterGetEvaluatorFunc

func (ef *Factory) RegisterGetEvaluatorFunc(priority int, fun getEvaluatorFunc)