Versions in this module Expand all Collapse all v1 v1.12.0 Jul 26, 2016 Changes in this version + type ConstraintFilter struct + func (f *ConstraintFilter) Check(n *NodeInfo) bool + func (f *ConstraintFilter) SetTask(t *api.Task) bool + type Expr struct + Key string + func ParseExprs(env []string) ([]Expr, error) + func (e *Expr) Match(whats ...string) bool + type Filter interface + Check func(*NodeInfo) bool + SetTask func(*api.Task) bool + type NodeInfo struct + AvailableResources api.Resources + Tasks map[string]*api.Task + type Pipeline struct + func NewPipeline() *Pipeline + func (p *Pipeline) Process(n *NodeInfo) bool + func (p *Pipeline) SetTask(t *api.Task) + type PluginFilter struct + func (f *PluginFilter) Check(n *NodeInfo) bool + func (f *PluginFilter) SetTask(t *api.Task) bool + type ReadyFilter struct + func (f *ReadyFilter) Check(n *NodeInfo) bool + func (f *ReadyFilter) SetTask(_ *api.Task) bool + type ResourceFilter struct + func (f *ResourceFilter) Check(n *NodeInfo) bool + func (f *ResourceFilter) SetTask(t *api.Task) bool + type Scheduler struct + func New(store *store.MemoryStore) *Scheduler + func (s *Scheduler) Run(ctx context.Context) error + func (s *Scheduler) Stop()
Go to main page