Add runtime events for pause,resume,checkpoint

Fixes #1068

Signed-off-by: Michael Crosby <crosbymichael@gmail.com>
This commit is contained in:
Michael Crosby
2017-07-11 12:38:20 -07:00
parent 106c7504f4
commit 58da62dd0f
4 changed files with 83 additions and 55 deletions

View File

@@ -283,6 +283,12 @@ func (s *Service) Pause(ctx context.Context, r *google_protobuf.Empty) (*google_
if err := s.initProcess.Pause(ctx); err != nil {
return nil, err
}
s.events <- &events.RuntimeEvent{
Type: events.RuntimeEvent_PAUSED,
ID: s.id,
ContainerID: s.id,
Timestamp: time.Now(),
}
return empty, nil
}
@@ -293,6 +299,12 @@ func (s *Service) Resume(ctx context.Context, r *google_protobuf.Empty) (*google
if err := s.initProcess.Resume(ctx); err != nil {
return nil, err
}
s.events <- &events.RuntimeEvent{
Type: events.RuntimeEvent_RESUMED,
ID: s.id,
ContainerID: s.id,
Timestamp: time.Now(),
}
return empty, nil
}
@@ -344,6 +356,12 @@ func (s *Service) Checkpoint(ctx context.Context, r *shimapi.CheckpointTaskReque
if err := s.initProcess.Checkpoint(ctx, r); err != nil {
return nil, err
}
s.events <- &events.RuntimeEvent{
Type: events.RuntimeEvent_CHECKPOINTED,
ID: s.id,
ContainerID: s.id,
Timestamp: time.Now(),
}
return empty, nil
}