-
Notifications
You must be signed in to change notification settings - Fork 35
/
containers.go
41 lines (35 loc) · 823 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
package cluster
import (
"context"
api "github.com/ehazlett/stellar/api/services/cluster/v1"
)
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 := s.client(node.Address)
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{
ID: node.ID,
Address: node.Address,
},
})
}
c.Close()
}
return &api.ContainersResponse{
Containers: containers,
}, nil
}