/
get_instance.go
79 lines (74 loc) · 2.07 KB
/
get_instance.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
package daemonapi
import (
"net/http"
"github.com/labstack/echo/v4"
"github.com/opensvc/om3/core/instance"
"github.com/opensvc/om3/core/naming"
"github.com/opensvc/om3/daemon/api"
)
func (a *DaemonAPI) GetInstances(ctx echo.Context, params api.GetInstancesParams) error {
meta := Meta{
Context: ctx,
Node: params.Node,
Path: params.Path,
}
name := "GetInstances"
log := LogHandler(ctx, name)
if err := meta.Expand(); err != nil {
log.Errorf("%s: %s", name, err)
return JSONProblem(ctx, http.StatusInternalServerError, "Server error", "expand selection")
}
configs := instance.ConfigData.GetAll()
l := make(api.InstanceItems, 0)
for _, config := range configs {
if !meta.HasPath(config.Path.String()) {
continue
}
if !meta.HasNode(config.Node) {
continue
}
monitor := instance.MonitorData.Get(config.Path, config.Node)
status := instance.StatusData.Get(config.Path, config.Node)
d := api.InstanceItem{
Kind: "InstanceItem",
Meta: api.InstanceMeta{
Node: config.Node,
Object: config.Path.String(),
},
Data: api.Instance{
Config: config.Value,
Monitor: monitor,
Status: status,
},
}
l = append(l, d)
}
return ctx.JSON(http.StatusOK, api.InstanceList{Kind: "InstanceList", Items: l})
}
func (a *DaemonAPI) GetInstance(ctx echo.Context, nodename string, namespace string, kind naming.Kind, name string) error {
log := LogHandler(ctx, "GetInstance")
path, err := naming.NewPath(namespace, kind, name)
if err != nil {
log.Errorf("GetInstance: %s", err)
return JSONProblemf(ctx, http.StatusInternalServerError, "New path", "%s", err)
}
config := instance.ConfigData.Get(path, nodename)
if config == nil {
return ctx.NoContent(http.StatusNotFound)
}
monitor := instance.MonitorData.Get(path, nodename)
status := instance.StatusData.Get(path, nodename)
item := api.InstanceItem{
Kind: "InstanceItem",
Meta: api.InstanceMeta{
Node: nodename,
Object: path.String(),
},
Data: api.Instance{
Config: config,
Monitor: monitor,
Status: status,
},
}
return ctx.JSON(http.StatusOK, item)
}