mirror of https://github.com/docker/cli.git
Merge pull request #29196 from aluzzardi/service-ps-output
service ps: Revert output to 1.12 behavior.
This commit is contained in:
commit
ded2ece9ad
|
@ -14,11 +14,12 @@ import (
|
||||||
"github.com/docker/docker/api/types/swarm"
|
"github.com/docker/docker/api/types/swarm"
|
||||||
"github.com/docker/docker/cli/command"
|
"github.com/docker/docker/cli/command"
|
||||||
"github.com/docker/docker/cli/command/idresolver"
|
"github.com/docker/docker/cli/command/idresolver"
|
||||||
|
"github.com/docker/docker/pkg/stringid"
|
||||||
"github.com/docker/go-units"
|
"github.com/docker/go-units"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
psTaskItemFmt = "%s\t%s\t%s\t%s\t%s %s ago\t%s\t%s\n"
|
psTaskItemFmt = "%s\t%s\t%s\t%s\t%s\t%s %s ago\t%s\t%s\n"
|
||||||
maxErrLength = 30
|
maxErrLength = 30
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -67,7 +68,7 @@ func Print(dockerCli *command.DockerCli, ctx context.Context, tasks []swarm.Task
|
||||||
|
|
||||||
// Ignore flushing errors
|
// Ignore flushing errors
|
||||||
defer writer.Flush()
|
defer writer.Flush()
|
||||||
fmt.Fprintln(writer, strings.Join([]string{"NAME", "IMAGE", "NODE", "DESIRED STATE", "CURRENT STATE", "ERROR", "PORTS"}, "\t"))
|
fmt.Fprintln(writer, strings.Join([]string{"ID", "NAME", "IMAGE", "NODE", "DESIRED STATE", "CURRENT STATE", "ERROR", "PORTS"}, "\t"))
|
||||||
|
|
||||||
if err := print(writer, ctx, tasks, resolver, noTrunc); err != nil {
|
if err := print(writer, ctx, tasks, resolver, noTrunc); err != nil {
|
||||||
return err
|
return err
|
||||||
|
@ -90,25 +91,36 @@ func PrintQuiet(dockerCli *command.DockerCli, tasks []swarm.Task) error {
|
||||||
}
|
}
|
||||||
|
|
||||||
func print(out io.Writer, ctx context.Context, tasks []swarm.Task, resolver *idresolver.IDResolver, noTrunc bool) error {
|
func print(out io.Writer, ctx context.Context, tasks []swarm.Task, resolver *idresolver.IDResolver, noTrunc bool) error {
|
||||||
prevService := ""
|
prevName := ""
|
||||||
prevSlot := 0
|
|
||||||
for _, task := range tasks {
|
for _, task := range tasks {
|
||||||
name, err := resolver.Resolve(ctx, task, task.ID)
|
id := task.ID
|
||||||
|
if !noTrunc {
|
||||||
|
id = stringid.TruncateID(id)
|
||||||
|
}
|
||||||
|
|
||||||
|
serviceName, err := resolver.Resolve(ctx, swarm.Service{}, task.ServiceID)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
nodeValue, err := resolver.Resolve(ctx, swarm.Node{}, task.NodeID)
|
nodeValue, err := resolver.Resolve(ctx, swarm.Node{}, task.NodeID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
name := ""
|
||||||
|
if task.Slot != 0 {
|
||||||
|
name = fmt.Sprintf("%v.%v", serviceName, task.Slot)
|
||||||
|
} else {
|
||||||
|
name = fmt.Sprintf("%v.%v", serviceName, task.NodeID)
|
||||||
|
}
|
||||||
|
|
||||||
// Indent the name if necessary
|
// Indent the name if necessary
|
||||||
indentedName := name
|
indentedName := name
|
||||||
// Since the new format of the task name is <ServiceName>.<Slot>.<taskID>, we should only compare
|
if name == prevName {
|
||||||
// <ServiceName> and <Slot> here.
|
|
||||||
if prevService == task.ServiceID && prevSlot == task.Slot {
|
|
||||||
indentedName = fmt.Sprintf(" \\_ %s", indentedName)
|
indentedName = fmt.Sprintf(" \\_ %s", indentedName)
|
||||||
}
|
}
|
||||||
prevService = task.ServiceID
|
prevName = name
|
||||||
prevSlot = task.Slot
|
|
||||||
|
|
||||||
// Trim and quote the error message.
|
// Trim and quote the error message.
|
||||||
taskErr := task.Status.Err
|
taskErr := task.Status.Err
|
||||||
|
@ -134,6 +146,7 @@ func print(out io.Writer, ctx context.Context, tasks []swarm.Task, resolver *idr
|
||||||
fmt.Fprintf(
|
fmt.Fprintf(
|
||||||
out,
|
out,
|
||||||
psTaskItemFmt,
|
psTaskItemFmt,
|
||||||
|
id,
|
||||||
indentedName,
|
indentedName,
|
||||||
image,
|
image,
|
||||||
nodeValue,
|
nodeValue,
|
||||||
|
|
Loading…
Reference in New Issue