добавил роуты апи для удаление и получения информации об функциях

Author: deissh

pkg/manager/inspect.go

@@ -0,0 +1,11 @@
+package manager
+
+import (
+"github.com/docker/docker/api/types"
+"golang.org/x/net/context"
+)
+
+func (m *Core) Inspect(id string) (types.ContainerJSON, error) {
+res, err := m.client.ContainerInspect(context.Background(), id)
+return res, err
+}

pkg/manager/stop.go

@@ -1,15 +1,10 @@
 package manager
 
 import (
-"github.com/docker/docker/api/types"
 "golang.org/x/net/context"
 )
 
 // id - id контейнера
 func (c *Core) Stop(id string) error {
-// todo: добавить поиск по лейблам
-return c.client.ContainerRemove(
-context.Background(),
-id,
-types.ContainerRemoveOptions{})
+return c.client.ContainerStop(context.Background(), id, nil)
 }

pkg/server/delete.go

@@ -0,0 +1,39 @@
+package server
+
+import (
+"github.com/deissh/lambda/pkg/manager"
+"github.com/gin-gonic/gin"
+"log"
+"net/http"
+)
+
+func deleteHandler(m manager.Core) gin.HandlerFunc {
+return func(c *gin.Context) {
+uuid := c.Param("uuid")
+
+containers, err := m.GetActive()
+if err != nil {
+c.JSON(http.StatusInternalServerError, gin.H{
+"error": err.Error(),
+})
+log.Println(err)
+return
+}
+
+for _, cont := range containers {
+for _, name := range cont.Names {
+// fix docker name
+if name == "/"+uuid {
+if err := m.Stop(cont.ID); err != nil {
+log.Println(err)
+c.JSON(http.StatusInternalServerError, gin.H{
+"error": err.Error(),
+})
+}
+
+c.JSON(http.StatusOK, gin.H{})
+}
+}
+}
+}
+}

pkg/server/inspect.go

@@ -0,0 +1,47 @@
+package server
+
+import (
+"github.com/deissh/lambda/pkg/manager"
+"github.com/gin-gonic/gin"
+"log"
+"net/http"
+)
+
+func inspectHandler(m manager.Core) gin.HandlerFunc {
+return func(c *gin.Context) {
+uuid := c.Param("uuid")
+
+containers, err := m.GetActive()
+if err != nil {
+c.JSON(http.StatusInternalServerError, gin.H{
+"error": err.Error(),
+})
+log.Println(err)
+return
+}
+
+// todo: убрать вложеность
+for _, cont := range containers {
+for _, name := range cont.Names {
+// fix docker name
+if name == "/"+uuid {
+data, err := m.Inspect(cont.ID)
+if err != nil {
+c.JSON(http.StatusOK, gin.H{
+"error": err.Error(),
+})
+log.Println(err)
+return
+}
+
+c.JSON(http.StatusOK, gin.H{
+"inspect": data,
+})
+return
+}
+}
+}
+
+c.JSON(http.StatusNotFound, gin.H{})
+}
+}

pkg/server/server.go

@@ -40,6 +40,7 @@ func (s core) Routing() {
 {
 g.GET("/")
 g.POST("/create", createHandler(s.manager))
-g.GET("/function/:uuid")
+g.DELETE("/:uuid", deleteHandler(s.manager))
+g.GET("/inspect/:uuid", inspectHandler(s.manager))
 }
 }