Browse code

Revert "Add -a option to service/node ps"

This reverts commit 139fff2bf0ebe12b61871ba8ec8be8d51c2338db.

Signed-off-by: Vincent Demeester <vincent@sbr.pm>

Vincent Demeester authored on 2016/11/29 02:08:45
Showing 5 changed files
... ...
@@ -17,7 +17,6 @@ import (
17 17
 
18 18
 type psOptions struct {
19 19
 	nodeIDs   []string
20
-	all       bool
21 20
 	noResolve bool
22 21
 	noTrunc   bool
23 22
 	filter    opts.FilterOpt
... ...
@@ -44,7 +43,6 @@ func newPsCommand(dockerCli *command.DockerCli) *cobra.Command {
44 44
 	flags.BoolVar(&opts.noTrunc, "no-trunc", false, "Do not truncate output")
45 45
 	flags.BoolVar(&opts.noResolve, "no-resolve", false, "Do not map IDs to Names")
46 46
 	flags.VarP(&opts.filter, "filter", "f", "Filter output based on conditions provided")
47
-	flags.BoolVarP(&opts.all, "all", "a", false, "Show all tasks (default shows tasks that are or will be running)")
48 47
 
49 48
 	return cmd
50 49
 }
... ...
@@ -74,11 +72,6 @@ func runPs(dockerCli *command.DockerCli, opts psOptions) error {
74 74
 		filter := opts.filter.Value()
75 75
 		filter.Add("node", node.ID)
76 76
 
77
-		if !opts.all && !filter.Include("desired-state") {
78
-			filter.Add("desired-state", string(swarm.TaskStateRunning))
79
-			filter.Add("desired-state", string(swarm.TaskStateAccepted))
80
-		}
81
-
82 77
 		nodeTasks, err := client.TaskList(ctx, types.TaskListOptions{Filters: filter})
83 78
 		if err != nil {
84 79
 			errs = append(errs, err.Error())
... ...
@@ -2,7 +2,6 @@ package service
2 2
 
3 3
 import (
4 4
 	"github.com/docker/docker/api/types"
5
-	"github.com/docker/docker/api/types/swarm"
6 5
 	"github.com/docker/docker/cli"
7 6
 	"github.com/docker/docker/cli/command"
8 7
 	"github.com/docker/docker/cli/command/idresolver"
... ...
@@ -15,7 +14,6 @@ import (
15 15
 
16 16
 type psOptions struct {
17 17
 	serviceID string
18
-	all       bool
19 18
 	quiet     bool
20 19
 	noResolve bool
21 20
 	noTrunc   bool
... ...
@@ -39,7 +37,6 @@ func newPsCommand(dockerCli *command.DockerCli) *cobra.Command {
39 39
 	flags.BoolVar(&opts.noTrunc, "no-trunc", false, "Do not truncate output")
40 40
 	flags.BoolVar(&opts.noResolve, "no-resolve", false, "Do not map IDs to Names")
41 41
 	flags.VarP(&opts.filter, "filter", "f", "Filter output based on conditions provided")
42
-	flags.BoolVarP(&opts.all, "all", "a", false, "Show all tasks (default shows tasks that are or will be running)")
43 42
 
44 43
 	return cmd
45 44
 }
... ...
@@ -67,11 +64,6 @@ func runPS(dockerCli *command.DockerCli, opts psOptions) error {
67 67
 		}
68 68
 	}
69 69
 
70
-	if !opts.all && !filter.Include("desired-state") {
71
-		filter.Add("desired-state", string(swarm.TaskStateRunning))
72
-		filter.Add("desired-state", string(swarm.TaskStateAccepted))
73
-	}
74
-
75 70
 	tasks, err := client.TaskList(ctx, types.TaskListOptions{Filters: filter})
76 71
 	if err != nil {
77 72
 		return err
... ...
@@ -22,7 +22,7 @@ Usage:  docker node ps [OPTIONS] [NODE...]
22 22
 List tasks running on one or more nodes, defaults to current node.
23 23
 
24 24
 Options:
25
-  -a, --all            Show all tasks (default shows tasks that are or will be running)
25
+  -a, --all            Display all instances
26 26
   -f, --filter value   Filter output based on conditions provided
27 27
       --help           Print usage
28 28
       --no-resolve     Do not map IDs to Names
... ...
@@ -22,7 +22,6 @@ Usage:  docker service ps [OPTIONS] SERVICE
22 22
 List the tasks of a service
23 23
 
24 24
 Options:
25
-  -a, --all             Show all tasks (default shows tasks that are or will be running)
26 25
   -f, --filter filter   Filter output based on conditions provided
27 26
       --help            Print usage
28 27
       --no-resolve      Do not map IDs to Names
... ...
@@ -219,88 +219,6 @@ func (s *DockerSwarmSuite) TestSwarmNodeTaskListFilter(c *check.C) {
219 219
 	c.Assert(out, checker.Not(checker.Contains), name+".1")
220 220
 	c.Assert(out, checker.Not(checker.Contains), name+".2")
221 221
 	c.Assert(out, checker.Not(checker.Contains), name+".3")
222
-
223
-	out, err = d.Cmd("node", "ps", "--filter", "desired-state=running", "self")
224
-	c.Assert(err, checker.IsNil)
225
-	c.Assert(out, checker.Contains, name+".1")
226
-	c.Assert(out, checker.Contains, name+".2")
227
-	c.Assert(out, checker.Contains, name+".3")
228
-
229
-	out, err = d.Cmd("node", "ps", "--filter", "desired-state=shutdown", "self")
230
-	c.Assert(err, checker.IsNil)
231
-	c.Assert(out, checker.Not(checker.Contains), name+".1")
232
-	c.Assert(out, checker.Not(checker.Contains), name+".2")
233
-	c.Assert(out, checker.Not(checker.Contains), name+".3")
234
-}
235
-
236
-func (s *DockerSwarmSuite) TestSwarmServiceTaskListAll(c *check.C) {
237
-	d := s.AddDaemon(c, true, true)
238
-
239
-	name := "service-task-list-1"
240
-	out, err := d.Cmd("service", "create", "--name", name, "--replicas=3", "busybox", "top")
241
-	c.Assert(err, checker.IsNil)
242
-	c.Assert(strings.TrimSpace(out), checker.Not(checker.Equals), "")
243
-
244
-	// make sure task has been deployed.
245
-	waitAndAssert(c, defaultReconciliationTimeout, d.checkActiveContainerCount, checker.Equals, 3)
246
-
247
-	out, err = d.Cmd("service", "ps", name)
248
-	c.Assert(err, checker.IsNil)
249
-	c.Assert(out, checker.Contains, name+".1")
250
-	c.Assert(out, checker.Contains, name+".2")
251
-	c.Assert(out, checker.Contains, name+".3")
252
-
253
-	// Get the last container id so we can restart it to cause a task error in the history
254
-	containerID, err := d.Cmd("ps", "-q", "-l")
255
-	c.Assert(err, checker.IsNil)
256
-
257
-	_, err = d.Cmd("stop", strings.TrimSpace(containerID))
258
-	c.Assert(err, checker.IsNil)
259
-
260
-	waitAndAssert(c, defaultReconciliationTimeout, d.checkActiveContainerCount, checker.Equals, 3)
261
-
262
-	out, err = d.Cmd("service", "ps", name)
263
-	c.Assert(err, checker.IsNil)
264
-	c.Assert(out, checker.Count, name, 3)
265
-
266
-	out, err = d.Cmd("service", "ps", name, "-a")
267
-	c.Assert(err, checker.IsNil)
268
-	c.Assert(out, checker.Count, name, 4)
269
-}
270
-
271
-func (s *DockerSwarmSuite) TestSwarmNodeTaskListAll(c *check.C) {
272
-	d := s.AddDaemon(c, true, true)
273
-
274
-	name := "node-task-list"
275
-	out, err := d.Cmd("service", "create", "--name", name, "--replicas=3", "busybox", "top")
276
-	c.Assert(err, checker.IsNil)
277
-	c.Assert(strings.TrimSpace(out), checker.Not(checker.Equals), "")
278
-
279
-	// make sure task has been deployed.
280
-	waitAndAssert(c, defaultReconciliationTimeout, d.checkActiveContainerCount, checker.Equals, 3)
281
-
282
-	out, err = d.Cmd("service", "ps", name)
283
-	c.Assert(err, checker.IsNil)
284
-	c.Assert(out, checker.Contains, name+".1")
285
-	c.Assert(out, checker.Contains, name+".2")
286
-	c.Assert(out, checker.Contains, name+".3")
287
-
288
-	// Get the last container id so we can restart it to cause a task error in the history
289
-	containerID, err := d.Cmd("ps", "-q", "-l")
290
-	c.Assert(err, checker.IsNil)
291
-
292
-	_, err = d.Cmd("stop", strings.TrimSpace(containerID))
293
-	c.Assert(err, checker.IsNil)
294
-
295
-	waitAndAssert(c, defaultReconciliationTimeout, d.checkActiveContainerCount, checker.Equals, 3)
296
-
297
-	out, err = d.Cmd("node", "ps", "self")
298
-	c.Assert(err, checker.IsNil)
299
-	c.Assert(out, checker.Count, name, 3)
300
-
301
-	out, err = d.Cmd("node", "ps", "self", "-a")
302
-	c.Assert(err, checker.IsNil)
303
-	c.Assert(out, checker.Count, name, 4)
304 222
 }
305 223
 
306 224
 // Test case for #25375