diff options
author | Sebastien Douheret <sebastien.douheret@iot.bzh> | 2017-11-28 14:19:00 +0100 |
---|---|---|
committer | Sebastien Douheret <sebastien.douheret@iot.bzh> | 2017-11-30 01:36:12 +0100 |
commit | 75416fe01aa98b53c57315a050fc58f0879a238d (patch) | |
tree | 0bb2d5849fc352c839f8d6f85fdb2aa6b0aad03b /cmd-exec.go | |
parent | 5a34a70b861c9d504e9f07d3c8251c36dc2ce76c (diff) |
Used new agent lib name xaapiv1 and fix env setup.
Signed-off-by: Sebastien Douheret <sebastien.douheret@iot.bzh>
Diffstat (limited to 'cmd-exec.go')
-rw-r--r-- | cmd-exec.go | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/cmd-exec.go b/cmd-exec.go index c02496b..b8d88b5 100644 --- a/cmd-exec.go +++ b/cmd-exec.go @@ -5,7 +5,7 @@ import ( "os" "strings" - "github.com/iotbzh/xds-agent/lib/apiv1" + "github.com/iotbzh/xds-agent/lib/xaapiv1" "github.com/urfave/cli" ) @@ -49,7 +49,7 @@ func exec(ctx *cli.Context) error { Log.Infof("Execute: /exec %v", argsCommand) // Log useful info for debugging - ver := apiv1.XDSVersion{} + ver := xaapiv1.XDSVersion{} XdsVersionGet(&ver) Log.Infof("XDS version: %v", ver) @@ -78,25 +78,25 @@ func exec(ctx *cli.Context) error { } } - IOsk.On(apiv1.ExecOutEvent, func(ev apiv1.ExecOutMsg) { + IOsk.On(xaapiv1.ExecOutEvent, func(ev xaapiv1.ExecOutMsg) { outFunc(ev.Timestamp, ev.Stdout, ev.Stderr) }) - IOsk.On(apiv1.ExecExitEvent, func(ev apiv1.ExecExitMsg) { + IOsk.On(xaapiv1.ExecExitEvent, func(ev xaapiv1.ExecExitMsg) { exitChan <- exitResult{ev.Error, ev.Code} }) - IOsk.On(apiv1.EVTProjectChange, func(ev apiv1.EventMsg) { + IOsk.On(xaapiv1.EVTProjectChange, func(ev xaapiv1.EventMsg) { prj, _ := ev.DecodeProjectConfig() Log.Infof("Event %v (%v): %v", ev.Type, ev.Time, prj) }) - evReg := apiv1.EventRegisterArgs{Name: apiv1.EVTProjectChange} + evReg := xaapiv1.EventRegisterArgs{Name: xaapiv1.EVTProjectChange} if err := HTTPCli.Post("/events/register", &evReg, nil); err != nil { return cli.NewExitError(err, 1) } // Retrieve the project definition - prj := apiv1.ProjectConfig{} + prj := xaapiv1.ProjectConfig{} if err := HTTPCli.Get("/projects/"+prjID, &prj); err != nil { return cli.NewExitError(err, 1) } @@ -125,7 +125,7 @@ func exec(ctx *cli.Context) error { } // Send build command - args := apiv1.ExecArgs{ + args := xaapiv1.ExecArgs{ ID: prjID, SdkID: sdkid, Cmd: strings.Trim(argsCommand[0], " "), |