logging

cli/daemon.go

@@ -8,6 +8,8 @@ import (
 
 	"github.com/fsouza/go-dockerclient"
 	"github.com/mcuadros/ofelia/core"
+	"github.com/mcuadros/ofelia/middlewares"
+	"github.com/op/go-logging"
 )
 
 // DaemonCommand daemon process
@@ -50,9 +52,11 @@ func (c *DaemonCommand) boot() error {
 		return err
 	}
 
+	logger := c.buildLogger()
 	c.scheduler = core.NewScheduler()
 	for _, j := range c.config.Jobs {
 		j.Client = d
+		j.Use(logger)
 		c.scheduler.AddJob(j)
 	}
 
@@ -91,3 +95,12 @@ func (c *DaemonCommand) shutdown() error {
 	fmt.Println("Waiting running jobs.")
 	return c.scheduler.Stop()
 }
+
+const logFormat = "%{color}%{shortfile} ▶ %{level:.4s} %{id:03x}%{color:reset} %{message}"
+
+func (c *DaemonCommand) buildLogger() *middlewares.Logger {
+	logging.SetFormatter(logging.MustStringFormatter(logFormat))
+
+	return middlewares.NewLogger(logging.MustGetLogger("ofelia"))
+
+}

core/execjob.go

@@ -70,6 +70,7 @@ func (j *ExecJob) startExec(e *Execution, exec *docker.Exec) error {
 
 func (j *ExecJob) inspectExec(exec *docker.Exec) error {
 	i, err := j.Client.InspectExec(exec.ID)
+
 	if err != nil {
 		return fmt.Errorf("error inspecting exec: %s", err)
 	}