scheduler

Jun 28, 2016

Changes in this version

+ const AnnotationForcesCreate

+ const AnnotationForcesDestroy

+ const AnnotationForcesDestructiveUpdate

+ const AnnotationForcesInplaceUpdate

+ const UpdateTypeCreate

+ const UpdateTypeDestroy

+ const UpdateTypeDestructiveUpdate

+ const UpdateTypeIgnore

+ const UpdateTypeInplaceUpdate

+ const UpdateTypeMigrate

+ func Annotate(diff *structs.JobDiff, annotations *structs.PlanAnnotations) error

+ type Harness struct

+ CreateEvals []*structs.Evaluation

+ Evals []*structs.Evaluation

+ Planner Planner

+ Plans []*structs.Plan

+ ReblockEvals []*structs.Evaluation

+ State *state.StateStore

+ func NewHarness(t *testing.T) *Harness

+ func (h *Harness) AssertEvalStatus(t *testing.T, state string)

+ func (h *Harness) CreateEval(eval *structs.Evaluation) error

+ func (h *Harness) NextIndex() uint64

+ func (h *Harness) Process(factory Factory, eval *structs.Evaluation) error

+ func (h *Harness) ReblockEval(eval *structs.Evaluation) error

+ func (h *Harness) Scheduler(factory Factory) Scheduler

+ func (h *Harness) Snapshot() State

+ func (h *Harness) SubmitPlan(plan *structs.Plan) (*structs.PlanResult, State, error)

+ func (h *Harness) UpdateEval(eval *structs.Evaluation) error

type Planner

+ ReblockEval func(*structs.Evaluation) error

+ type RejectPlan struct

+ Harness *Harness

+ func (r *RejectPlan) CreateEval(*structs.Evaluation) error

+ func (r *RejectPlan) ReblockEval(*structs.Evaluation) error

+ func (r *RejectPlan) SubmitPlan(*structs.Plan) (*structs.PlanResult, State, error)

+ func (r *RejectPlan) UpdateEval(eval *structs.Evaluation) error

Feb 25, 2016

Changes in this version

+ type ComputedClassFeasibility byte

+ const EvalComputedClassEligible

+ const EvalComputedClassEscaped

+ const EvalComputedClassIneligible

+ const EvalComputedClassUnknown

+ type ConstraintChecker struct

+ func NewConstraintChecker(ctx Context, constraints []*structs.Constraint) *ConstraintChecker

+ func (c *ConstraintChecker) Feasible(option *structs.Node) bool

+ func (c *ConstraintChecker) SetConstraints(constraints []*structs.Constraint)

type Context

+ Eligibility func() *EvalEligibility

+ type DriverChecker struct

+ func NewDriverChecker(ctx Context, drivers map[string]struct{}) *DriverChecker

+ func (c *DriverChecker) Feasible(option *structs.Node) bool

+ func (c *DriverChecker) SetDrivers(d map[string]struct{})

type EvalContext

+ func (e *EvalContext) Eligibility() *EvalEligibility

+ type EvalEligibility struct

+ func NewEvalEligibility() *EvalEligibility

+ func (e *EvalEligibility) GetClasses() map[string]bool

+ func (e *EvalEligibility) HasEscaped() bool

+ func (e *EvalEligibility) JobStatus(class string) ComputedClassFeasibility

+ func (e *EvalEligibility) SetJob(job *structs.Job)

+ func (e *EvalEligibility) SetJobEligibility(eligible bool, class string)

+ func (e *EvalEligibility) SetTaskGroupEligibility(eligible bool, tg, class string)

+ func (e *EvalEligibility) TaskGroupStatus(tg, class string) ComputedClassFeasibility

+ type FeasibilityChecker interface

+ Feasible func(*structs.Node) bool

+ type FeasibilityWrapper struct

+ func NewFeasibilityWrapper(ctx Context, source FeasibleIterator, ...) *FeasibilityWrapper

+ func (w *FeasibilityWrapper) Next() *structs.Node

+ func (w *FeasibilityWrapper) Reset()

+ func (w *FeasibilityWrapper) SetTaskGroup(tg string)

type State

+ AllocsByNodeTerminal func(node string, terminal bool) ([]*structs.Allocation, error)

Nov 19, 2015

Changes in this version

type Context

+ ConstraintCache func() map[string]version.Constraints

+ RegexpCache func() map[string]*regexp.Regexp

+ type EvalCache struct

+ func (e *EvalCache) ConstraintCache() map[string]version.Constraints

+ func (e *EvalCache) RegexpCache() map[string]*regexp.Regexp

+ type ProposedAllocConstraintIterator struct

+ func NewProposedAllocConstraintIterator(ctx Context, source FeasibleIterator) *ProposedAllocConstraintIterator

+ func (iter *ProposedAllocConstraintIterator) Next() *structs.Node

+ func (iter *ProposedAllocConstraintIterator) Reset()

+ func (iter *ProposedAllocConstraintIterator) SetJob(job *structs.Job)

+ func (iter *ProposedAllocConstraintIterator) SetTaskGroup(tg *structs.TaskGroup)

type Scheduler

+ func NewSystemScheduler(logger *log.Logger, state State, planner Planner) Scheduler

+ type SystemScheduler struct

+ func (s *SystemScheduler) Process(eval *structs.Evaluation) error

+ type SystemStack struct

+ func NewSystemStack(ctx Context) *SystemStack

+ func (s *SystemStack) Select(tg *structs.TaskGroup) (*RankedNode, *structs.Resources)

+ func (s *SystemStack) SetJob(job *structs.Job)

+ func (s *SystemStack) SetNodes(baseNodes []*structs.Node)

Sep 28, 2015

Changes in this version

+ var BuiltinSchedulers = map[string]Factory

+ type BinPackIterator struct

+ func NewBinPackIterator(ctx Context, source RankIterator, evict bool, priority int) *BinPackIterator

+ func (iter *BinPackIterator) Next() *RankedNode

+ func (iter *BinPackIterator) Reset()

+ func (iter *BinPackIterator) SetPriority(p int)

+ func (iter *BinPackIterator) SetTasks(tasks []*structs.Task)

+ type ConstraintIterator struct

+ func NewConstraintIterator(ctx Context, source FeasibleIterator, constraints []*structs.Constraint) *ConstraintIterator

+ func (iter *ConstraintIterator) Next() *structs.Node

+ func (iter *ConstraintIterator) Reset()

+ func (iter *ConstraintIterator) SetConstraints(c []*structs.Constraint)

+ type Context interface

+ Logger func() *log.Logger

+ Metrics func() *structs.AllocMetric

+ Plan func() *structs.Plan

+ ProposedAllocs func(nodeID string) ([]*structs.Allocation, error)

+ Reset func()

+ State func() State

+ type DriverIterator struct

+ func NewDriverIterator(ctx Context, source FeasibleIterator, drivers map[string]struct{}) *DriverIterator

+ func (iter *DriverIterator) Next() *structs.Node

+ func (iter *DriverIterator) Reset()

+ func (iter *DriverIterator) SetDrivers(d map[string]struct{})

+ type EvalContext struct

+ func NewEvalContext(s State, p *structs.Plan, log *log.Logger) *EvalContext

+ func (e *EvalContext) Logger() *log.Logger

+ func (e *EvalContext) Metrics() *structs.AllocMetric

+ func (e *EvalContext) Plan() *structs.Plan

+ func (e *EvalContext) ProposedAllocs(nodeID string) ([]*structs.Allocation, error)

+ func (e *EvalContext) Reset()

+ func (e *EvalContext) SetState(s State)

+ func (e *EvalContext) State() State

+ type Factory func(*log.Logger, State, Planner) Scheduler

+ type FeasibleIterator interface

+ Next func() *structs.Node

+ Reset func()

+ type FeasibleRankIterator struct

+ func NewFeasibleRankIterator(ctx Context, source FeasibleIterator) *FeasibleRankIterator

+ func (iter *FeasibleRankIterator) Next() *RankedNode

+ func (iter *FeasibleRankIterator) Reset()

+ type GenericScheduler struct

+ func (s *GenericScheduler) Process(eval *structs.Evaluation) error

+ type GenericStack struct

+ func NewGenericStack(batch bool, ctx Context, baseNodes []*structs.Node) *GenericStack

+ func (s *GenericStack) Select(tg *structs.TaskGroup) (*RankedNode, *structs.Resources)

+ func (s *GenericStack) SetJob(job *structs.Job)

+ func (s *GenericStack) SetNodes(baseNodes []*structs.Node)

+ type JobAntiAffinityIterator struct

+ func NewJobAntiAffinityIterator(ctx Context, source RankIterator, penalty float64, jobID string) *JobAntiAffinityIterator

+ func (iter *JobAntiAffinityIterator) Next() *RankedNode

+ func (iter *JobAntiAffinityIterator) Reset()

+ func (iter *JobAntiAffinityIterator) SetJob(jobID string)

+ type LimitIterator struct

+ func NewLimitIterator(ctx Context, source RankIterator, limit int) *LimitIterator

+ func (iter *LimitIterator) Next() *RankedNode

+ func (iter *LimitIterator) Reset()

+ func (iter *LimitIterator) SetLimit(limit int)

+ type MaxScoreIterator struct

+ func NewMaxScoreIterator(ctx Context, source RankIterator) *MaxScoreIterator

+ func (iter *MaxScoreIterator) Next() *RankedNode

+ func (iter *MaxScoreIterator) Reset()

+ type Planner interface

+ CreateEval func(*structs.Evaluation) error

+ SubmitPlan func(*structs.Plan) (*structs.PlanResult, State, error)

+ UpdateEval func(*structs.Evaluation) error

+ type RankIterator interface

+ Next func() *RankedNode

+ Reset func()

+ type RankedNode struct

+ Node *structs.Node

+ Proposed []*structs.Allocation

+ Score float64

+ TaskResources map[string]*structs.Resources

+ func (r *RankedNode) GoString() string

+ func (r *RankedNode) ProposedAllocs(ctx Context) ([]*structs.Allocation, error)

+ func (r *RankedNode) SetTaskResources(task *structs.Task, resource *structs.Resources)

+ type Scheduler interface

+ Process func(*structs.Evaluation) error

+ func NewBatchScheduler(logger *log.Logger, state State, planner Planner) Scheduler

+ func NewScheduler(name string, logger *log.Logger, state State, planner Planner) (Scheduler, error)

+ func NewServiceScheduler(logger *log.Logger, state State, planner Planner) Scheduler

+ type SetStatusError struct

+ Err error

+ EvalStatus string

+ func (s *SetStatusError) Error() string

+ type Stack interface

+ Select func(tg *structs.TaskGroup) (*RankedNode, *structs.Resources)

+ SetJob func(job *structs.Job)

+ SetNodes func([]*structs.Node)

+ type State interface

+ AllocsByJob func(jobID string) ([]*structs.Allocation, error)

+ AllocsByNode func(node string) ([]*structs.Allocation, error)

+ JobByID func(id string) (*structs.Job, error)

+ NodeByID func(nodeID string) (*structs.Node, error)

+ Nodes func() (memdb.ResultIterator, error)

+ type StaticIterator struct

+ func NewRandomIterator(ctx Context, nodes []*structs.Node) *StaticIterator

+ func NewStaticIterator(ctx Context, nodes []*structs.Node) *StaticIterator

+ func (iter *StaticIterator) Next() *structs.Node

+ func (iter *StaticIterator) Reset()

+ func (iter *StaticIterator) SetNodes(nodes []*structs.Node)

+ type StaticRankIterator struct

+ func NewStaticRankIterator(ctx Context, nodes []*RankedNode) *StaticRankIterator

+ func (iter *StaticRankIterator) Next() *RankedNode

+ func (iter *StaticRankIterator) Reset()