diff --git a/client/driver/docker.go b/client/driver/docker.go index b0b23bea522d..ae4465c28fba 100644 --- a/client/driver/docker.go +++ b/client/driver/docker.go @@ -17,12 +17,13 @@ import ( "time" "github.com/armon/circbuf" - docker "github.com/fsouza/go-dockerclient" + "github.com/fsouza/go-dockerclient" "github.com/docker/docker/cli/config/configfile" "github.com/docker/docker/reference" "github.com/docker/docker/registry" + "github.com/armon/go-metrics" "github.com/hashicorp/go-multierror" "github.com/hashicorp/go-plugin" "github.com/hashicorp/nomad/client/allocdir" @@ -478,6 +479,9 @@ type DockerHandle struct { client *docker.Client waitClient *docker.Client logger *log.Logger + jobName string + taskGroupName string + taskName string Image string ImageID string containerID string @@ -898,6 +902,9 @@ func (d *DockerDriver) Start(ctx *ExecContext, task *structs.Task) (*StartRespon executor: exec, pluginClient: pluginClient, logger: d.logger, + jobName: d.DriverContext.jobName, + taskGroupName: d.DriverContext.taskGroupName, + taskName: d.DriverContext.taskName, Image: d.driverConfig.ImageName, ImageID: d.imageID, containerID: container.ID, @@ -1771,6 +1778,9 @@ func (d *DockerDriver) Open(ctx *ExecContext, handleID string) (DriverHandle, er executor: exec, pluginClient: pluginClient, logger: d.logger, + jobName: d.DriverContext.jobName, + taskGroupName: d.DriverContext.taskGroupName, + taskName: d.DriverContext.taskName, Image: pid.Image, ImageID: pid.ImageID, containerID: pid.ContainerID, @@ -1924,6 +1934,21 @@ func (h *DockerHandle) run() { h.logger.Printf("[ERR] driver.docker: failed to inspect container %s: %v", h.containerID, ierr) } else if container.State.OOMKilled { werr = fmt.Errorf("OOM Killed") + labels := []metrics.Label{ + { + Name: "job", + Value: h.jobName, + }, + { + Name: "task_group", + Value: h.taskGroupName, + }, + { + Name: "task", + Value: h.taskName, + }, + } + metrics.IncrCounterWithLabels([]string{"driver", "docker", "oom"}, 1, labels) } close(h.doneCh)