docker
/
docs
mirror of https://github.com/docker/docs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

do not block if one node is availalble

This commit is contained in:
Victor Vieux 2014-11-20 22:39:45 +00:00
parent 20319a5049
commit 16b22dcca2
1 changed files with 22 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
manage.go
View File

@ -41,29 +41,31 @@ func manage(c *cli.Context) {
cluster := cluster.NewCluster() cluster := cluster.NewCluster()
cluster.Events(&logHandler{}) cluster.Events(&logHandler{})
if c.String("token") != "" { go func() {
nodes, err := discovery.FetchSlaves(c.String("token")) if c.String("token") != "" {
if err != nil { nodes, err := discovery.FetchSlaves(c.String("token"))
log.Fatal(err) if err != nil {
log.Fatal(err)
}
if err := refresh(cluster, nodes); err != nil {
log.Fatal(err)
}
go func() {
for {
time.Sleep(25 * time.Second)
nodes, err = discovery.FetchSlaves(c.String("token"))
if err == nil {
refresh(cluster, nodes)
}
} }
}() if err := refresh(cluster, nodes); err != nil {
} else { log.Fatal(err)
if err := refresh(cluster, c.Args()); err != nil { }
log.Fatal(err) go func() {
for {
time.Sleep(25 * time.Second)
nodes, err = discovery.FetchSlaves(c.String("token"))
if err == nil {
refresh(cluster, nodes)
}
}
}()
} else {
if err := refresh(cluster, c.Args()); err != nil {
log.Fatal(err)
}
} }
} }()
s := scheduler.NewScheduler(cluster, &strategy.BinPackingPlacementStrategy{}, []filter.Filter{&filter.AttributeFilter{}, &filter.PortFilter{}}) s := scheduler.NewScheduler(cluster, &strategy.BinPackingPlacementStrategy{}, []filter.Filter{&filter.AttributeFilter{}, &filter.PortFilter{}})