filter

Jan 18, 2017

Changes in this version

+ type WhitelistFilter struct

+ func (f *WhitelistFilter) Filter(config *cluster.ContainerConfig, nodes []*node.Node, soft bool) ([]*node.Node, error)

+ func (f *WhitelistFilter) GetFilters(config *cluster.ContainerConfig) ([]string, error)

+ func (f *WhitelistFilter) Name() string

May 3, 2016

Changes in this version

+ var ErrNoNodeWithFreeSlotsAvailable = errors.New("No node with enough open slots available in the cluster")

+ type SlotsFilter struct

+ func (f *SlotsFilter) Filter(_ *cluster.ContainerConfig, nodes []*node.Node, _ bool) ([]*node.Node, error)

+ func (f *SlotsFilter) GetFilters(config *cluster.ContainerConfig) ([]string, error)

+ func (f *SlotsFilter) Name() string

Apr 13, 2016

Changes in this version

type AffinityFilter

+ func (f *AffinityFilter) GetFilters(config *cluster.ContainerConfig) ([]string, error)

type ConstraintFilter

+ func (f *ConstraintFilter) GetFilters(config *cluster.ContainerConfig) ([]string, error)

type DependencyFilter

+ func (f *DependencyFilter) GetFilters(config *cluster.ContainerConfig) ([]string, error)

type Filter

+ GetFilters func(*cluster.ContainerConfig) ([]string, error)

type HealthFilter

+ func (f *HealthFilter) GetFilters(config *cluster.ContainerConfig) ([]string, error)

type PortFilter

+ func (p *PortFilter) GetFilters(config *cluster.ContainerConfig) ([]string, error)

Apr 6, 2015

Changes in this version

+ func List() []string

type AffinityFilter

+ func (f *AffinityFilter) Name() string

type ConstraintFilter

+ func (f *ConstraintFilter) Name() string

type DependencyFilter

+ func (f *DependencyFilter) Name() string

type Filter

+ Name func() string

type HealthFilter

+ func (f *HealthFilter) Name() string

type PortFilter

+ func (p *PortFilter) Name() string

Feb 25, 2015

Changes in this version

+ const EQ

+ const NOTEQ

+ var ErrNoHealthyNodeAvailable = errors.New("No healthy node available in the cluster")

+ var ErrNotSupported = errors.New("filter not supported")

+ var OPERATORS = []string

+ func ApplyFilters(filters []Filter, config *dockerclient.ContainerConfig, nodes []*cluster.Node) ([]*cluster.Node, error)

+ type AffinityFilter struct

+ func (f *AffinityFilter) Filter(config *dockerclient.ContainerConfig, nodes []*cluster.Node) ([]*cluster.Node, error)

+ type ConstraintFilter struct

+ func (f *ConstraintFilter) Filter(config *dockerclient.ContainerConfig, nodes []*cluster.Node) ([]*cluster.Node, error)

+ type DependencyFilter struct

+ func (f *DependencyFilter) Filter(config *dockerclient.ContainerConfig, nodes []*cluster.Node) ([]*cluster.Node, error)

+ func (f *DependencyFilter) String(config *dockerclient.ContainerConfig) string

+ type Filter interface

+ Filter func(*dockerclient.ContainerConfig, []*cluster.Node) ([]*cluster.Node, error)

+ func New(names []string) ([]Filter, error)

+ type HealthFilter struct

+ func (f *HealthFilter) Filter(_ *dockerclient.ContainerConfig, nodes []*cluster.Node) ([]*cluster.Node, error)

+ type PortFilter struct

+ func (p *PortFilter) Filter(config *dockerclient.ContainerConfig, nodes []*cluster.Node) ([]*cluster.Node, error)