@@ -106,11 +106,11 @@ func convertEvent(e *gogotypes.Any) (string, interface{}, error) {
106106 return "" , nil , errors .Wrap (err , "failed to unmarshalany" )
107107 }
108108
109- switch evt .(type ) {
109+ switch e := evt .(type ) {
110110 case * eventtypes.TaskExit :
111- containerID = evt .( * eventtypes. TaskExit ) .ContainerID
111+ containerID = e .ContainerID
112112 case * eventtypes.TaskOOM :
113- containerID = evt .( * eventtypes. TaskOOM ) .ContainerID
113+ containerID = e .ContainerID
114114 default :
115115 return "" , nil , errors .New ("unsupported event" )
116116 }
@@ -185,13 +185,12 @@ func (em *eventMonitor) stop() {
185185// handleEvent handles a containerd event.
186186func (em * eventMonitor ) handleEvent (any interface {}) error {
187187 ctx := ctrdutil .NamespacedContext ()
188- switch any .(type ) {
188+ switch e := any .(type ) {
189189 // If containerd-shim exits unexpectedly, there will be no corresponding event.
190190 // However, containerd could not retrieve container state in that case, so it's
191191 // fine to leave out that case for now.
192192 // TODO(random-liu): [P2] Handle containerd-shim exit.
193193 case * eventtypes.TaskExit :
194- e := any .(* eventtypes.TaskExit )
195194 cntr , err := em .containerStore .Get (e .ContainerID )
196195 if err == nil {
197196 if err := handleContainerExit (ctx , e , cntr ); err != nil {
@@ -213,7 +212,6 @@ func (em *eventMonitor) handleEvent(any interface{}) error {
213212 }
214213 return nil
215214 case * eventtypes.TaskOOM :
216- e := any .(* eventtypes.TaskOOM )
217215 logrus .Infof ("TaskOOM event %+v" , e )
218216 cntr , err := em .containerStore .Get (e .ContainerID )
219217 if err != nil {
0 commit comments