1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980 |
- package container
- import (
- "fmt"
- "strings"
- "golang.org/x/net/context"
- "github.com/docker/docker/api/client"
- "github.com/docker/docker/cli"
- "github.com/docker/go-connections/nat"
- "github.com/spf13/cobra"
- )
- type portOptions struct {
- container string
- port string
- }
- // NewPortCommand creates a new cobra.Command for `docker port`
- func NewPortCommand(dockerCli *client.DockerCli) *cobra.Command {
- var opts portOptions
- cmd := &cobra.Command{
- Use: "port CONTAINER [PRIVATE_PORT[/PROTO]]",
- Short: "List port mappings or a specific mapping for the container",
- Args: cli.RequiresRangeArgs(1, 2),
- RunE: func(cmd *cobra.Command, args []string) error {
- opts.container = args[0]
- if len(args) > 1 {
- opts.port = args[1]
- }
- return runPort(dockerCli, &opts)
- },
- }
- cmd.SetFlagErrorFunc(flagErrorFunc)
- return cmd
- }
- func runPort(dockerCli *client.DockerCli, opts *portOptions) error {
- ctx := context.Background()
- c, err := dockerCli.Client().ContainerInspect(ctx, opts.container)
- if err != nil {
- return err
- }
- if opts.port != "" {
- port := opts.port
- proto := "tcp"
- parts := strings.SplitN(port, "/", 2)
- if len(parts) == 2 && len(parts[1]) != 0 {
- port = parts[0]
- proto = parts[1]
- }
- natPort := port + "/" + proto
- newP, err := nat.NewPort(proto, port)
- if err != nil {
- return err
- }
- if frontends, exists := c.NetworkSettings.Ports[newP]; exists && frontends != nil {
- for _, frontend := range frontends {
- fmt.Fprintf(dockerCli.Out(), "%s:%s\n", frontend.HostIP, frontend.HostPort)
- }
- return nil
- }
- return fmt.Errorf("Error: No public port '%s' published for %s", natPort, opts.container)
- }
- for from, frontends := range c.NetworkSettings.Ports {
- for _, frontend := range frontends {
- fmt.Fprintf(dockerCli.Out(), "%s -> %s:%s\n", from, frontend.HostIP, frontend.HostPort)
- }
- }
- return nil
- }
|