Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsInTopology ¶
IsInTopology takes a Topology `top` (which is reported by a Node) and a list of Topologies `accessible` (which comes from a created volume, in the form of the AccessibleTopology) and returns true if `top` lies within `accessible` (meaning a node with that Topology can access a volume with that AccessibleTopology).
In order for `top` to lie within `accessible`, there must exist a topology in `accessible` such that for every subdomain/segment pair in that topology, there exists an equivalent subdomain/segment pair in `top`.
For examples, see the test for this function.
NOTE(dperny): It is unclear whether a topology can be partial. For example, can an accessible topology contain only a "region" subdomain, without a "zone" subdomain? This function assumes yes.
Types ¶
type ConstraintFilter ¶
type ConstraintFilter struct {
// contains filtered or unexported fields
}
ConstraintFilter selects only nodes that match certain labels.
func (*ConstraintFilter) Check ¶
func (f *ConstraintFilter) Check(n *NodeInfo) bool
Check returns true if the task's constraint is supported by the given node.
func (*ConstraintFilter) Explain ¶
func (f *ConstraintFilter) Explain(nodes int) string
Explain returns an explanation of a failure.
type Filter ¶
type Filter interface {
// SetTask returns true when the filter is enabled for a given task
// and assigns the task to the filter. It returns false if the filter
// isn't applicable to this task. For instance, a constraints filter
// would return `false` if the task doesn't contain any constraints.
SetTask(*api.Task) bool
// Check returns true if the task assigned by SetTask can be scheduled
// into the given node. This function should not be called if SetTask
// returned false.
Check(*NodeInfo) bool
// Explain what a failure of this filter means
Explain(nodes int) string
}
Filter checks whether the given task can run on the given node. A filter may only operate
type HostPortFilter ¶
type HostPortFilter struct {
// contains filtered or unexported fields
}
HostPortFilter checks that the node has a specific port available.
func (*HostPortFilter) Check ¶
func (f *HostPortFilter) Check(n *NodeInfo) bool
Check returns true if the task can be scheduled into the given node.
func (*HostPortFilter) Explain ¶
func (f *HostPortFilter) Explain(nodes int) string
Explain returns an explanation of a failure.
type MaxReplicasFilter ¶
type MaxReplicasFilter struct {
// contains filtered or unexported fields
}
MaxReplicasFilter selects only nodes that does not exceed max replicas per node.
func (*MaxReplicasFilter) Check ¶
func (f *MaxReplicasFilter) Check(n *NodeInfo) bool
Check returns true if there is less active (assigned or pre-assigned) tasks for this service on current node than set to MaxReplicas limit
func (*MaxReplicasFilter) Explain ¶
func (f *MaxReplicasFilter) Explain(nodes int) string
Explain returns an explanation of a failure.
type NodeInfo ¶
type NodeInfo struct {
*api.Node
Tasks map[string]*api.Task
ActiveTasksCount int
ActiveTasksCountByService map[string]int
AvailableResources *api.Resources
// contains filtered or unexported fields
}
NodeInfo contains a node and some additional metadata.
type Pipeline ¶
type Pipeline struct {
// contains filtered or unexported fields
}
Pipeline runs a set of filters against nodes.
func NewPipeline ¶
func NewPipeline() *Pipeline
NewPipeline returns a pipeline with the default set of filters.
type PlatformFilter ¶
type PlatformFilter struct {
// contains filtered or unexported fields
}
PlatformFilter selects only nodes that run the required platform.
func (*PlatformFilter) Check ¶
func (f *PlatformFilter) Check(n *NodeInfo) bool
Check returns true if the task can be scheduled into the given node.
func (*PlatformFilter) Explain ¶
func (f *PlatformFilter) Explain(nodes int) string
Explain returns an explanation of a failure.
type PluginFilter ¶
type PluginFilter struct {
// contains filtered or unexported fields
}
PluginFilter checks that the node has a specific volume plugin installed
func (*PluginFilter) Check ¶
func (f *PluginFilter) Check(n *NodeInfo) bool
Check returns true if the task can be scheduled into the given node. TODO(amitshukla): investigate storing Plugins as a map so it can be easily probed
func (*PluginFilter) Explain ¶
func (f *PluginFilter) Explain(nodes int) string
Explain returns an explanation of a failure.
type ReadyFilter ¶
type ReadyFilter struct {
}
ReadyFilter checks that the node is ready to schedule tasks.
func (*ReadyFilter) Check ¶
func (f *ReadyFilter) Check(n *NodeInfo) bool
Check returns true if the task can be scheduled into the given node.
func (*ReadyFilter) Explain ¶
func (f *ReadyFilter) Explain(nodes int) string
Explain returns an explanation of a failure.
type ResourceFilter ¶
type ResourceFilter struct {
// contains filtered or unexported fields
}
ResourceFilter checks that the node has enough resources available to run the task.
func (*ResourceFilter) Check ¶
func (f *ResourceFilter) Check(n *NodeInfo) bool
Check returns true if the task can be scheduled into the given node.
func (*ResourceFilter) Explain ¶
func (f *ResourceFilter) Explain(nodes int) string
Explain returns an explanation of a failure.
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
Scheduler assigns tasks to nodes.
type VolumesFilter ¶
type VolumesFilter struct {
// contains filtered or unexported fields
}
func (*VolumesFilter) Check ¶
func (f *VolumesFilter) Check(nodeInfo *NodeInfo) bool
func (*VolumesFilter) Explain ¶
func (f *VolumesFilter) Explain(nodes int) string
Source Files