From a578730a94384a839e24097606d59cdaf76a59e5 Mon Sep 17 00:00:00 2001 From: Kenfe-Mickael Laventure Date: Tue, 18 Jul 2017 13:47:28 +0200 Subject: [PATCH] Update linux events topic This also remove the duplicate events for Task{Create,Start,Delete} Signed-off-by: Kenfe-Mickael Laventure --- linux/shim/service.go | 18 +++++++++--------- services/tasks/service.go | 20 -------------------- 2 files changed, 9 insertions(+), 29 deletions(-) diff --git a/linux/shim/service.go b/linux/shim/service.go index b91bfff7e..3ba0268b2 100644 --- a/linux/shim/service.go +++ b/linux/shim/service.go @@ -404,23 +404,23 @@ func (s *Service) forward(client poster) { func getTopic(e interface{}) string { switch e.(type) { case *events.TaskCreate: - return "task-create" + return "/tasks/create" case *events.TaskStart: - return "task-start" + return "/tasks/start" case *events.TaskOOM: - return "task-oom" + return "/tasks/oom" case *events.TaskExit: - return "task-exit" + return "/tasks/exit" case *events.TaskDelete: - return "task-delete" + return "/tasks/delete" case *events.TaskExecAdded: - return "task-exec-added" + return "/tasks/exec-added" case *events.TaskPaused: - return "task-paused" + return "/tasks/paused" case *events.TaskResumed: - return "task-resumed" + return "/tasks/resumed" case *events.TaskCheckpointed: - return "task-checkpointed" + return "/tasks/checkpointed" } return "?" } diff --git a/services/tasks/service.go b/services/tasks/service.go index 81bd61910..70ca0e6dd 100644 --- a/services/tasks/service.go +++ b/services/tasks/service.go @@ -9,7 +9,6 @@ import ( "path/filepath" "github.com/boltdb/bolt" - eventsapi "github.com/containerd/containerd/api/services/events/v1" api "github.com/containerd/containerd/api/services/tasks/v1" "github.com/containerd/containerd/api/types" "github.com/containerd/containerd/api/types/task" @@ -148,12 +147,6 @@ func (s *Service) Create(ctx context.Context, r *api.CreateTaskRequest) (*api.Cr log.G(ctx).Error(err) } - if err := s.emit(ctx, "/tasks/create", &eventsapi.TaskCreate{ - ContainerID: r.ContainerID, - }); err != nil { - return nil, err - } - return &api.CreateTaskResponse{ ContainerID: r.ContainerID, Pid: state.Pid, @@ -169,12 +162,6 @@ func (s *Service) Start(ctx context.Context, r *api.StartTaskRequest) (*google_p return nil, err } - if err := s.emit(ctx, "/tasks/start", &eventsapi.TaskStart{ - ContainerID: r.ContainerID, - }); err != nil { - return nil, err - } - return empty, nil } @@ -191,13 +178,6 @@ func (s *Service) Delete(ctx context.Context, r *api.DeleteTaskRequest) (*api.De if err != nil { return nil, err } - if err := s.emit(ctx, "/tasks/delete", &eventsapi.TaskDelete{ - ContainerID: r.ContainerID, - Pid: exit.Pid, - ExitStatus: exit.Status, - }); err != nil { - return nil, err - } return &api.DeleteResponse{ ExitStatus: exit.Status, ExitedAt: exit.Timestamp,