forked from ehazlett/stellar
/
containers.go
42 lines (36 loc) · 859 Bytes
/
containers.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
package cluster
import (
"context"
api "github.com/ehazlett/stellar/api/services/cluster/v1"
"github.com/ehazlett/stellar/client"
)
func (s *service) Containers(ctx context.Context, req *api.ContainersRequest) (*api.ContainersResponse, error) {
var containers []*api.Container
resp, err := s.Nodes(ctx, &api.NodesRequest{})
if err != nil {
return nil, err
}
for _, node := range resp.Nodes {
c, err := client.NewClient(node.Addr)
if err != nil {
return nil, err
}
cont, err := c.Node().Containers(req.Filters...)
if err != nil {
return nil, err
}
for _, container := range cont {
containers = append(containers, &api.Container{
Container: container,
Node: &api.Node{
Name: node.Name,
Addr: node.Addr,
},
})
}
c.Close()
}
return &api.ContainersResponse{
Containers: containers,
}, nil
}