|
@@ -131,7 +131,7 @@ func StartContainer(containerName string, containerType string) (structs.Contain
|
|
|
var existingContainer *types.Container = nil
|
|
var existingContainer *types.Container = nil
|
|
|
for _, container := range containers {
|
|
for _, container := range containers {
|
|
|
for _, name := range container.Names {
|
|
for _, name := range container.Names {
|
|
|
- if name == "/"+containerName {
|
|
|
|
|
|
|
+ if name == containerName {
|
|
|
existingContainer = &container
|
|
existingContainer = &container
|
|
|
break
|
|
break
|
|
|
}
|
|
}
|
|
@@ -333,6 +333,7 @@ func DockerPoller() {
|
|
|
select {
|
|
select {
|
|
|
case <-ticker.C:
|
|
case <-ticker.C:
|
|
|
logger.Info("polling docker")
|
|
logger.Info("polling docker")
|
|
|
|
|
+ // todo (maybe not necessary?)
|
|
|
// fetch the status of all containers and compare with app's state
|
|
// fetch the status of all containers and compare with app's state
|
|
|
// if there's a change, send an event to the EventBus
|
|
// if there's a change, send an event to the EventBus
|
|
|
return
|
|
return
|