| 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 creats 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) |
| }, |
| } |
| |
| 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 |
| } |