Дописал запуск контейнеров и api для этого

Author: deissh

cmd/manager/main.go

@@ -8,14 +8,14 @@ import (
 func main() {
 log.SetFlags(log.LstdFlags | log.Lshortfile)
 
-m, _ := manager.Create()
+m := manager.Create()
 
 active, err := m.GetActive()
 if err != nil {
 log.Panic(err)
 }
 
-for _, container := range active{
+for _, container := range active {
 log.Println(container.ID)
 }
 }

cmd/www/main.go

@@ -13,5 +13,5 @@ func main() {
 
 log.Println("starting server")
 
-log.Fatal(server.Run("0.0.0.0", "8080"))
+log.Fatal(server.Run("0.0.0.0", "3000"))
 }

pkg/manager/manager.go

@@ -9,13 +9,13 @@ type Core struct {
 client *client.Client
 }
 
-func Create() (Core, error) {
+func Create() Core {
 cli, err := client.NewEnvClient()
 if err != nil {
 log.Panic(err)
 }
 
 return Core{
 client: cli,
-}, nil
-}
+}
+}

pkg/manager/run.go

@@ -0,0 +1,56 @@
+package manager
+
+import (
+"github.com/deissh/lambda/pkg/typings"
+"github.com/docker/docker/api/types"
+"github.com/docker/docker/api/types/container"
+"github.com/docker/go-connections/nat"
+"golang.org/x/net/context"
+)
+
+func (c *Core) Create(info typings.FunctionInfo) error {
+// получаем контейнер
+//_, err := c.client.ImagePull(
+//	context.Background(),
+//	info.Repository.ImageName,
+//	types.ImagePullOptions{})
+//if err != nil {
+//	log.Println(err)
+//	return err
+//}
+
+// создаем контейнер и настраиваем сеть
+//todo: добавить сеть для контейнеров
+resp, err := c.client.ContainerCreate(
+context.Background(),
+&container.Config{
+Image: info.Repository.ImageName,
+},
+&container.HostConfig{
+AutoRemove: true,
+PortBindings: map[nat.Port][]nat.PortBinding{
+"8080/tcp": {
+{
+HostIP: "",
+HostPort: info.Service.Port,
+},
+},
+},
+},
+nil,
+info.Uuid)
+if err != nil {
+return err
+}
+
+// запускаем контейнер
+err = c.client.ContainerStart(
+context.Background(),
+resp.ID,
+types.ContainerStartOptions{})
+if err != nil {
+panic(err)
+}
+
+return nil
+}

pkg/server/create.go

@@ -1,22 +1,36 @@
 package server
 
 import (
+"github.com/deissh/lambda/pkg/manager"
 "github.com/deissh/lambda/pkg/typings"
 "github.com/gin-gonic/gin"
+"log"
 "net/http"
 )
 
-func createHandler(c *gin.Context) {
-var body typings.FunctionInfo
+func createHandler(m manager.Core) gin.HandlerFunc {
+return func(c *gin.Context) {
+var body typings.FunctionInfo
 
-if err := c.ShouldBindJSON(&body); err != nil {
-c.JSON(http.StatusBadRequest, gin.H{
-"error": err.Error(),
+if err := c.ShouldBind(&body); err != nil {
+c.JSON(http.StatusBadRequest, gin.H{
+"error": err.Error(),
+})
+
+log.Println(err.Error())
+return
+}
+
+if err := m.Create(body); err != nil {
+c.JSON(http.StatusBadRequest, gin.H{
+"error": err.Error(),
+})
+
+return
+}
+
+c.JSON(200, gin.H{
+"message": "ok",
 })
-return
 }
-
-c.JSON(200, gin.H{
-"message": "ok",
-})
-}
+}

pkg/server/server.go

@@ -1,14 +1,16 @@
 package server
 
 import (
+"github.com/deissh/lambda/pkg/manager"
 "github.com/gin-gonic/gin"
 "log"
 )
 
 type core struct {
-ip string
-port string
-router *gin.Engine
+ip string
+port string
+router *gin.Engine
+manager manager.Core
 }
 
 func Run(host string, port string) error {
@@ -20,6 +22,7 @@ func Run(host string, port string) error {
 }
 
 func (s core) Start() error {
+s.manager = manager.Create()
 s.router = gin.Default()
 
 log.Println("starting server")
@@ -32,10 +35,11 @@ func (s core) Start() error {
 }
 
 func (s core) Routing() {
+
 g := s.router.Group("/v1")
 {
 g.GET("/")
-g.POST("/create", createHandler)
-g.Any("/function/:uuid")
+g.POST("/create", createHandler(s.manager))
+g.GET("/function/:uuid")
 }
-}
+}

pkg/typings/function.go

@@ -3,16 +3,20 @@ package typings
 type FunctionInfo struct {
 Name string `json:"name" binding:"required"`
 Uuid string `json:"uuid" binding:"required"`
-Runtime struct{
+Runtime struct {
 Executor string `json:"executor" binding:"required"`
-Cmd string `json:"cmd" binding:"required"`
-Params string `json:"params"`
-Env []struct{
-Name string `json:"name"`
+Cmd  string `json:"cmd"`
+Params  string `json:"params"`
+Env  []struct {
+Name  string `json:"name"`
 Value string `json:"value"`
 } `json:"env"`
 } `json:"runtime" binding:"required"`
-Repository struct{
-Url string `json:"url" binding:"required"`
+Repository struct {
+ImageName string `json:"image" binding:"required"`
 } `json:"repository" binding:"required"`
-}
+Service struct {
+Port string `json:"port" binding:"required"`
+Host string `json:"host" binding:"required"`
+} `json:"service" binding:"required"`
+}