|
@@ -0,0 +1,80 @@
|
|
|
|
+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.RequiresMinMaxArgs(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
|
|
|
|
+}
|