35 lines
939 B
Go
35 lines
939 B
Go
package swarm
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/docker/cli/cli/command"
|
|
"github.com/docker/cli/cli/command/idresolver"
|
|
"github.com/docker/cli/cli/command/stack/options"
|
|
"github.com/docker/cli/cli/command/task"
|
|
"github.com/moby/moby/api/types/swarm"
|
|
)
|
|
|
|
// RunPS is the swarm implementation of docker stack ps
|
|
func RunPS(ctx context.Context, dockerCLI command.Cli, opts options.PS) error {
|
|
filter := getStackFilterFromOpt(opts.Namespace, opts.Filter)
|
|
|
|
apiClient := dockerCLI.Client()
|
|
tasks, err := apiClient.TaskList(ctx, swarm.TaskListOptions{Filters: filter})
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if len(tasks) == 0 {
|
|
return fmt.Errorf("nothing found in stack: %s", opts.Namespace)
|
|
}
|
|
|
|
format := opts.Format
|
|
if len(format) == 0 {
|
|
format = task.DefaultFormat(dockerCLI.ConfigFile(), opts.Quiet)
|
|
}
|
|
|
|
return task.Print(ctx, dockerCLI, tasks, idresolver.New(apiClient, opts.NoResolve), !opts.NoTrunc, opts.Quiet, format)
|
|
}
|