@@ -37,7 +37,7 @@ func main() {
3737
3838 // spawn entities
3939 metadata := config .GetAgentConfigMetadata ()
40- cfg , err := config .NewConfig (metadata , * log )
40+ cfg , err := config .NewConfig (metadata , log )
4141 if err != nil {
4242 log .Metadata (map [string ]interface {}{"error" : err })
4343 log .Error ("Failed to parse config file." )
@@ -51,15 +51,15 @@ func main() {
5151 if err != nil {
5252 panic (err .Error ())
5353 }
54- sensuConnector , err := sensu .NewConnector (cfg , * log )
54+ sensuConnector , err := sensu .NewConnector (cfg , log )
5555 if err != nil {
5656 log .Metadata (map [string ]interface {}{"error" : err })
5757 log .Error ("Failed to spawn RabbitMQ connector." )
5858 os .Exit (2 )
5959 }
6060 defer sensuConnector .Disconnect ()
6161
62- sensuScheduler , err := sensu .NewScheduler (cfg , * log )
62+ sensuScheduler , err := sensu .NewScheduler (cfg , log )
6363 if err != nil {
6464 log .Metadata (map [string ]interface {}{"error" : err })
6565 log .Error ("Failed to spawn check scheduler." )
@@ -93,12 +93,20 @@ func main() {
9393 res , err := sensuExecutor .Execute (req )
9494 if err != nil {
9595 reqstr := fmt .Sprintf ("Request{name=%s, command=%s, issued=%d}" , req .Name , req .Command , req .Issued )
96- log .Error ().Err (err ).Str ("request" , reqstr ).Msg ("Failed to execute requested command." )
96+ log .Metadata (map [string ]interface {}{
97+ "error" : err ,
98+ "request" : reqstr ,
99+ })
100+ log .Error ("Failed to execute requested command." )
97101 continue
98102 }
99103 results <- res
100104 default :
101- log .Error ().Err (err ).Str ("request" , fmt .Sprintf ("%v" , req )).Msg ("Failed to execute requested command." )
105+ log .Metadata (map [string ]interface {}{
106+ "error" : err ,
107+ "request" : req ,
108+ })
109+ log .Error ("Failed to execute requested command." )
102110 }
103111 }
104112 }()
0 commit comments