github/weave-scope
1
0
Fork 0
mirror of https://github.com/weaveworks/scope.git synced 2026-03-04 02:30:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

ecs reporter: Associate containers with ECS tasks and services as parents

Browse Source
This commit is contained in:
Mike Lang
2016-11-22 15:37:21 -08:00
parent 88499b4e9d
commit a2d329dee7
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
probe/awsecs/reporter.go
View File

@@ -85,18 +85,23 @@ func (r Reporter) Tag(rpt report.Report) (report.Report, error) {
// new task node
node := report.MakeNodeWith(taskNodeID(taskArn), map[string]string{"family": info.family})
rpt.ECSTask = rpt.ECSTask.AddNode(node)
for _, containerID := range info.containerIDs {
// TODO set task node as parent of container
log.Debugf("task %v has container %v", taskArn, containerID)
// parents sets to merge into all matching container nodes
parentsSets := report.MakeSets()
parentsSets.Add(report.ECSTask, report.MakeStringSet(taskNodeID(taskArn)))
if serviceName, ok := taskServices[taskArn]; ok {
parentsSets.Add(report.ECSService, report.MakeStringSet(serviceNodeID(serviceName)))
}
if serviceName, ok := taskServices[taskArn]; ok {
// TODO set service node as parent of task node
log.Debugf("service %v has task %v", serviceName, taskArn)
for _, containerID := range info.containerIDs {
if containerNode, ok := rpt.Container.Nodes[containerID]; ok {
rpt.Container.Nodes[containerID] = containerNode.WithParents(parentsSets)
} else {
log.Warnf("Got task info for non-existent container %v, this shouldn't be able to happen", containerID)
}
}
}
}