Merge pull request #3170 from thaJeztah/unkeyed_fields
do not use unkeyed fields in composite literals
This commit is contained in:
commit
fdeb1084d3
@ -377,7 +377,7 @@ func (s *service) Pause(ctx context.Context, r *taskAPI.PauseRequest) (*ptypes.E
|
|||||||
return nil, errdefs.ToGRPC(err)
|
return nil, errdefs.ToGRPC(err)
|
||||||
}
|
}
|
||||||
s.send(&eventstypes.TaskPaused{
|
s.send(&eventstypes.TaskPaused{
|
||||||
container.ID,
|
ContainerID: container.ID,
|
||||||
})
|
})
|
||||||
return empty, nil
|
return empty, nil
|
||||||
}
|
}
|
||||||
@ -392,7 +392,7 @@ func (s *service) Resume(ctx context.Context, r *taskAPI.ResumeRequest) (*ptypes
|
|||||||
return nil, errdefs.ToGRPC(err)
|
return nil, errdefs.ToGRPC(err)
|
||||||
}
|
}
|
||||||
s.send(&eventstypes.TaskResumed{
|
s.send(&eventstypes.TaskResumed{
|
||||||
container.ID,
|
ContainerID: container.ID,
|
||||||
})
|
})
|
||||||
return empty, nil
|
return empty, nil
|
||||||
}
|
}
|
||||||
|
@ -430,7 +430,7 @@ func (s *service) Pause(ctx context.Context, r *taskAPI.PauseRequest) (*ptypes.E
|
|||||||
return nil, errdefs.ToGRPC(err)
|
return nil, errdefs.ToGRPC(err)
|
||||||
}
|
}
|
||||||
s.send(&eventstypes.TaskPaused{
|
s.send(&eventstypes.TaskPaused{
|
||||||
container.ID,
|
ContainerID: container.ID,
|
||||||
})
|
})
|
||||||
return empty, nil
|
return empty, nil
|
||||||
}
|
}
|
||||||
@ -445,7 +445,7 @@ func (s *service) Resume(ctx context.Context, r *taskAPI.ResumeRequest) (*ptypes
|
|||||||
return nil, errdefs.ToGRPC(err)
|
return nil, errdefs.ToGRPC(err)
|
||||||
}
|
}
|
||||||
s.send(&eventstypes.TaskResumed{
|
s.send(&eventstypes.TaskResumed{
|
||||||
container.ID,
|
ContainerID: container.ID,
|
||||||
})
|
})
|
||||||
return empty, nil
|
return empty, nil
|
||||||
}
|
}
|
||||||
|
@ -832,7 +832,7 @@ func (s *service) Pause(ctx context.Context, r *taskAPI.PauseRequest) (*ptypes.E
|
|||||||
}
|
}
|
||||||
|
|
||||||
s.publisher.Publish(ctx, runtime.TaskPausedEventTopic, &eventstypes.TaskPaused{
|
s.publisher.Publish(ctx, runtime.TaskPausedEventTopic, &eventstypes.TaskPaused{
|
||||||
r.ID,
|
ContainerID: r.ID,
|
||||||
})
|
})
|
||||||
|
|
||||||
return empty, nil
|
return empty, nil
|
||||||
@ -855,7 +855,7 @@ func (s *service) Resume(ctx context.Context, r *taskAPI.ResumeRequest) (*ptypes
|
|||||||
}
|
}
|
||||||
|
|
||||||
s.publisher.Publish(ctx, runtime.TaskResumedEventTopic, &eventstypes.TaskResumed{
|
s.publisher.Publish(ctx, runtime.TaskResumedEventTopic, &eventstypes.TaskResumed{
|
||||||
r.ID,
|
ContainerID: r.ID,
|
||||||
})
|
})
|
||||||
|
|
||||||
return empty, nil
|
return empty, nil
|
||||||
|
Loading…
Reference in New Issue
Block a user